diff --git a/common/src/test/java/io/druid/collections/BlockingPoolTest.java b/common/src/test/java/io/druid/collections/BlockingPoolTest.java index a1d673a902a..409ee4796a2 100644 --- a/common/src/test/java/io/druid/collections/BlockingPoolTest.java +++ b/common/src/test/java/io/druid/collections/BlockingPoolTest.java @@ -79,7 +79,7 @@ public class BlockingPoolTest emptyPool.takeBatch(1, 0); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testTake() { final ReferenceCountingResourceHolder holder = pool.take(100); @@ -89,7 +89,7 @@ public class BlockingPoolTest assertEquals(10, pool.getPoolSize()); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testTakeTimeout() { final List> batchHolder = pool.takeBatch(10, 100L); @@ -98,7 +98,7 @@ public class BlockingPoolTest batchHolder.forEach(ReferenceCountingResourceHolder::close); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testTakeBatch() { final List> holder = pool.takeBatch(6, 100L); @@ -109,7 +109,7 @@ public class BlockingPoolTest assertEquals(10, pool.getPoolSize()); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testWaitAndTakeBatch() throws InterruptedException, ExecutionException { List> batchHolder = pool.takeBatch(10, 10); @@ -132,14 +132,14 @@ public class BlockingPoolTest assertEquals(10, pool.getPoolSize()); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testTakeBatchTooManyObjects() { final List> holder = pool.takeBatch(100, 100L); assertTrue(holder.isEmpty()); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testConcurrentTake() throws ExecutionException, InterruptedException { final int limit1 = pool.maxSize() / 2; @@ -225,7 +225,7 @@ public class BlockingPoolTest assertEquals(pool.maxSize(), pool.getPoolSize()); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testConcurrentTakeBatch() throws ExecutionException, InterruptedException { final int batch1 = pool.maxSize() / 2; @@ -255,7 +255,7 @@ public class BlockingPoolTest assertEquals(pool.maxSize(), pool.getPoolSize()); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testConcurrentBatchClose() throws ExecutionException, InterruptedException { final int batch1 = pool.maxSize() / 2; @@ -299,7 +299,7 @@ public class BlockingPoolTest assertEquals(pool.maxSize(), pool.getPoolSize()); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testConcurrentTakeBatchClose() throws ExecutionException, InterruptedException { final List> r1 = pool.takeBatch(1, 10); diff --git a/common/src/test/java/io/druid/collections/ReferenceCountingResourceHolderTest.java b/common/src/test/java/io/druid/collections/ReferenceCountingResourceHolderTest.java index 4321e2ba07c..2a36e341410 100644 --- a/common/src/test/java/io/druid/collections/ReferenceCountingResourceHolderTest.java +++ b/common/src/test/java/io/druid/collections/ReferenceCountingResourceHolderTest.java @@ -83,7 +83,7 @@ public class ReferenceCountingResourceHolderTest }); } - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testResourceHandlerClearedByJVM() throws InterruptedException { long initialLeakedResources = ReferenceCountingResourceHolder.leakedResources(); @@ -92,7 +92,7 @@ public class ReferenceCountingResourceHolderTest verifyCleanerRun(released, initialLeakedResources); } - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testResourceHandlerWithReleaserClearedByJVM() throws InterruptedException { long initialLeakedResources = ReferenceCountingResourceHolder.leakedResources(); diff --git a/common/src/test/java/io/druid/collections/StupidPoolTest.java b/common/src/test/java/io/druid/collections/StupidPoolTest.java index 3cfdc3b878c..2a4d138317a 100644 --- a/common/src/test/java/io/druid/collections/StupidPoolTest.java +++ b/common/src/test/java/io/druid/collections/StupidPoolTest.java @@ -68,7 +68,7 @@ public class StupidPoolTest resourceHolderObj.get(); } - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testResourceHandlerClearedByJVM() throws InterruptedException { String leakedString = createDanglingObjectHandler(); diff --git a/extensions-contrib/materialized-view-selection/src/test/java/io/druid/query/materializedview/DatasourceOptimizerTest.java b/extensions-contrib/materialized-view-selection/src/test/java/io/druid/query/materializedview/DatasourceOptimizerTest.java index 0d34cfe73a5..b8a338f8776 100644 --- a/extensions-contrib/materialized-view-selection/src/test/java/io/druid/query/materializedview/DatasourceOptimizerTest.java +++ b/extensions-contrib/materialized-view-selection/src/test/java/io/druid/query/materializedview/DatasourceOptimizerTest.java @@ -133,7 +133,7 @@ public class DatasourceOptimizerTest extends CuratorTestBase tearDownServerAndCurator(); } - @Test(timeout = 10 * 1000) + @Test(timeout = 60_000L) public void testOptimize() throws InterruptedException { // insert datasource metadata diff --git a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java index f76788d4984..965651c19eb 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java +++ b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java @@ -1641,7 +1641,7 @@ public class KafkaIndexTaskTest Assert.assertEquals(ImmutableList.of("d", "e"), readSegmentColumn("dim1", desc2)); } - @Test(timeout = 30_000L) + @Test(timeout = 60_000L) public void testRunWithOffsetOutOfRangeExceptionAndPause() throws Exception { final KafkaIndexTask task = createTask( @@ -1671,7 +1671,7 @@ public class KafkaIndexTaskTest } } - @Test(timeout = 30_000L) + @Test(timeout = 60_000L) public void testRunWithOffsetOutOfRangeExceptionAndNextOffsetGreaterThanLeastAvailable() throws Exception { resetOffsetAutomatically = true; diff --git a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/NamespacedExtractorModuleTest.java b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/NamespacedExtractorModuleTest.java index d3e9d842074..f2d1a5b042d 100644 --- a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/NamespacedExtractorModuleTest.java +++ b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/NamespacedExtractorModuleTest.java @@ -136,7 +136,7 @@ public class NamespacedExtractorModuleTest } } - @Test//(timeout = 10_000) + @Test//(timeout = 60_000L) public void testDeleteNamespaces() throws Exception { final File tmpFile = temporaryFolder.newFile(); diff --git a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/UriCacheGeneratorTest.java b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/UriCacheGeneratorTest.java index f77d2be3901..b5216d2eea5 100644 --- a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/UriCacheGeneratorTest.java +++ b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/UriCacheGeneratorTest.java @@ -507,7 +507,7 @@ public class UriCacheGeneratorTest Assert.assertNotNull(generator.generateCache(extractionNamespace, null, null, scheduler)); } - @Test(timeout = 10_000) + @Test(timeout = 60_000L) public void testDeleteOnScheduleFail() throws Exception { Assert.assertNull(scheduler.scheduleAndWait( diff --git a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/CacheSchedulerTest.java b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/CacheSchedulerTest.java index 2bfff068228..dd142857f81 100644 --- a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/CacheSchedulerTest.java +++ b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/CacheSchedulerTest.java @@ -180,7 +180,7 @@ public class CacheSchedulerTest lifecycle.stop(); } - @Test(timeout = 10_000) + @Test(timeout = 60_000L) public void testSimpleSubmission() throws InterruptedException { UriExtractionNamespace namespace = new UriExtractionNamespace( @@ -199,7 +199,7 @@ public class CacheSchedulerTest Assert.assertEquals("val", cache.get("key")); } - @Test(timeout = 10_000) + @Test(timeout = 60_000L) public void testPeriodicUpdatesScheduled() throws InterruptedException { final int repeatCount = 5; @@ -233,7 +233,7 @@ public class CacheSchedulerTest } - @Test(timeout = 10_000) // This is very fast when run locally. Speed on Travis completely depends on noisy neighbors. + @Test(timeout = 60_000L) // This is very fast when run locally. Speed on Travis completely depends on noisy neighbors. public void testConcurrentAddDelete() throws InterruptedException { final int threads = 10; @@ -306,7 +306,7 @@ public class CacheSchedulerTest checkNoMoreRunning(); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testSimpleDelete() throws InterruptedException { testDelete(); @@ -355,7 +355,7 @@ public class CacheSchedulerTest ); } - @Test(timeout = 10_000) + @Test(timeout = 60_000L) public void testShutdown() throws InterruptedException { @@ -389,7 +389,7 @@ public class CacheSchedulerTest Assert.assertTrue(cacheManager.scheduledExecutorService().isTerminated()); } - @Test(timeout = 10_000) + @Test(timeout = 60_000L) public void testRunCount() throws InterruptedException { final int numWaits = 5; @@ -415,7 +415,7 @@ public class CacheSchedulerTest * Tests that even if entry.close() wasn't called, the scheduled task is cancelled when the entry becomes * unreachable. */ - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testEntryCloseForgotten() throws InterruptedException { scheduleDanglingEntry(); diff --git a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/JdbcExtractionNamespaceTest.java b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/JdbcExtractionNamespaceTest.java index f44385bce06..ccc04dafb79 100644 --- a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/JdbcExtractionNamespaceTest.java +++ b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/JdbcExtractionNamespaceTest.java @@ -362,7 +362,7 @@ public class JdbcExtractionNamespaceTest Thread.sleep(2); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testMappingWithoutFilter() throws InterruptedException { @@ -389,7 +389,7 @@ public class JdbcExtractionNamespaceTest } } - @Test(timeout = 20_000L) + @Test(timeout = 60_000L) public void testMappingWithFilter() throws InterruptedException { @@ -421,7 +421,7 @@ public class JdbcExtractionNamespaceTest } } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testSkipOld() throws InterruptedException { diff --git a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/NamespaceExtractionCacheManagersTest.java b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/NamespaceExtractionCacheManagersTest.java index 66d94d16812..3d2d5aefc8f 100644 --- a/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/NamespaceExtractionCacheManagersTest.java +++ b/extensions-core/lookups-cached-global/src/test/java/io/druid/server/lookup/namespace/cache/NamespaceExtractionCacheManagersTest.java @@ -70,7 +70,7 @@ public class NamespaceExtractionCacheManagersTest manager = createCacheManager.apply(lifecycle); } - @Test(timeout = 30000L) + @Test(timeout = 60_000L) public void testRacyCreation() throws Exception { final int concurrentThreads = 10; @@ -116,7 +116,7 @@ public class NamespaceExtractionCacheManagersTest /** * Tests that even if CacheHandler.close() wasn't called, the cache is cleaned up when it becomes unreachable. */ - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testCacheCloseForgotten() throws InterruptedException { Assert.assertEquals(0, manager.cacheCount()); diff --git a/indexing-service/src/test/java/io/druid/indexing/common/actions/LockAcquireActionTest.java b/indexing-service/src/test/java/io/druid/indexing/common/actions/LockAcquireActionTest.java index 16638713d73..4fd0f85933f 100644 --- a/indexing-service/src/test/java/io/druid/indexing/common/actions/LockAcquireActionTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/common/actions/LockAcquireActionTest.java @@ -71,7 +71,7 @@ public class LockAcquireActionTest Assert.assertEquals(expected.getTimeoutMs(), actual.getTimeoutMs()); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testWithLockType() { final Task task = NoopTask.create(); @@ -86,7 +86,7 @@ public class LockAcquireActionTest Assert.assertNotNull(lock); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testWithoutLockType() { final Task task = NoopTask.create(); diff --git a/indexing-service/src/test/java/io/druid/indexing/common/actions/LockTryAcquireActionTest.java b/indexing-service/src/test/java/io/druid/indexing/common/actions/LockTryAcquireActionTest.java index 29f06f52172..8ee0c0eb857 100644 --- a/indexing-service/src/test/java/io/druid/indexing/common/actions/LockTryAcquireActionTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/common/actions/LockTryAcquireActionTest.java @@ -67,7 +67,7 @@ public class LockTryAcquireActionTest Assert.assertEquals(expected.getInterval(), actual.getInterval()); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testWithLockType() { final Task task = NoopTask.create(); @@ -81,7 +81,7 @@ public class LockTryAcquireActionTest Assert.assertNotNull(lock); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testWithoutLockType() { final Task task = NoopTask.create(); diff --git a/indexing-service/src/test/java/io/druid/indexing/overlord/OverlordBlinkLeadershipTest.java b/indexing-service/src/test/java/io/druid/indexing/overlord/OverlordBlinkLeadershipTest.java index 2b54f18651f..fb79e1fbc26 100644 --- a/indexing-service/src/test/java/io/druid/indexing/overlord/OverlordBlinkLeadershipTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/overlord/OverlordBlinkLeadershipTest.java @@ -69,7 +69,7 @@ public class OverlordBlinkLeadershipTest * org.apache.curator.framework.recipes.leader.LeaderSelectorListener#takeLeadership} implementation in * {@link TaskMaster} and start it again. */ - @Test(timeout = 10_000) + @Test(timeout = 60_000L) public void testOverlordBlinkLeadership() { try { diff --git a/indexing-service/src/test/java/io/druid/indexing/overlord/RemoteTaskRunnerRunPendingTasksConcurrencyTest.java b/indexing-service/src/test/java/io/druid/indexing/overlord/RemoteTaskRunnerRunPendingTasksConcurrencyTest.java index 9d8903411f0..21f549a7fa5 100644 --- a/indexing-service/src/test/java/io/druid/indexing/overlord/RemoteTaskRunnerRunPendingTasksConcurrencyTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/overlord/RemoteTaskRunnerRunPendingTasksConcurrencyTest.java @@ -57,7 +57,7 @@ public class RemoteTaskRunnerRunPendingTasksConcurrencyTest } // This task reproduces the races described in https://github.com/druid-io/druid/issues/2842 - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testConcurrency() throws Exception { rtrTestUtils.makeWorker("worker0", 3); diff --git a/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockBoxConcurrencyTest.java b/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockBoxConcurrencyTest.java index 7c73e088c5c..a9bbc173cb1 100644 --- a/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockBoxConcurrencyTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockBoxConcurrencyTest.java @@ -82,7 +82,7 @@ public class TaskLockBoxConcurrencyTest service.shutdownNow(); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testDoInCriticalSectionWithDifferentTasks() throws ExecutionException, InterruptedException, EntryExistsException { @@ -163,7 +163,7 @@ public class TaskLockBoxConcurrencyTest Assert.assertTrue(result.isRevoked()); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testDoInCriticalSectionWithOverlappedIntervals() throws Exception { final List intervals = ImmutableList.of( diff --git a/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockboxTest.java b/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockboxTest.java index 4238459cd0b..5318708404a 100644 --- a/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockboxTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLockboxTest.java @@ -408,7 +408,7 @@ public class TaskLockboxTest ); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testAcquireLockAfterRevoked() throws EntryExistsException, InterruptedException { final Interval interval = Intervals.of("2017-01-01/2017-01-02"); diff --git a/indexing-service/src/test/java/io/druid/indexing/overlord/hrtr/HttpRemoteTaskRunnerTest.java b/indexing-service/src/test/java/io/druid/indexing/overlord/hrtr/HttpRemoteTaskRunnerTest.java index c46c12052ce..d696940c9bf 100644 --- a/indexing-service/src/test/java/io/druid/indexing/overlord/hrtr/HttpRemoteTaskRunnerTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/overlord/hrtr/HttpRemoteTaskRunnerTest.java @@ -79,7 +79,7 @@ public class HttpRemoteTaskRunnerTest Simulates startup of Overlord and Workers being discovered with no previously known tasks. Fresh tasks are given and expected to be completed. */ - @Test(timeout = 30000L) + @Test(timeout = 60_000L) public void testFreshStart() throws Exception { TestDruidNodeDiscovery druidNodeDiscovery = new TestDruidNodeDiscovery(); @@ -167,7 +167,7 @@ public class HttpRemoteTaskRunnerTest Simulates one task not getting acknowledged to be running after assigning it to a worker. But, other tasks are successfully assigned to other worker and get completed. */ - @Test(timeout = 10000L) + @Test(timeout = 60_000L) public void testOneStuckTaskAssignmentDoesntBlockOthers() throws Exception { TestDruidNodeDiscovery druidNodeDiscovery = new TestDruidNodeDiscovery(); @@ -254,7 +254,7 @@ public class HttpRemoteTaskRunnerTest /* Simulates restart of the Overlord where taskRunner, on start, discovers workers with prexisting tasks. */ - @Test(timeout = 10000L) + @Test(timeout = 60_000L) public void testTaskRunnerRestart() throws Exception { TestDruidNodeDiscovery druidNodeDiscovery = new TestDruidNodeDiscovery(); @@ -399,7 +399,7 @@ public class HttpRemoteTaskRunnerTest } - @Test(timeout = 10000L) + @Test(timeout = 60_000L) public void testWorkerDisapperAndReappearBeforeItsCleanup() throws Exception { TestDruidNodeDiscovery druidNodeDiscovery = new TestDruidNodeDiscovery(); @@ -562,7 +562,7 @@ public class HttpRemoteTaskRunnerTest Assert.assertTrue(future2.get().isSuccess()); } - @Test(timeout = 10000L) + @Test(timeout = 60_000L) public void testWorkerDisapperAndReappearAfterItsCleanup() throws Exception { TestDruidNodeDiscovery druidNodeDiscovery = new TestDruidNodeDiscovery(); @@ -725,7 +725,7 @@ public class HttpRemoteTaskRunnerTest Assert.assertTrue(taskRunner.run(task2).get().isFailure()); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testMarkWorkersLazy() throws Exception { TestDruidNodeDiscovery druidNodeDiscovery = new TestDruidNodeDiscovery(); diff --git a/indexing-service/src/test/java/io/druid/indexing/overlord/http/OverlordTest.java b/indexing-service/src/test/java/io/druid/indexing/overlord/http/OverlordTest.java index ea1d7429774..468146f7a63 100644 --- a/indexing-service/src/test/java/io/druid/indexing/overlord/http/OverlordTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/overlord/http/OverlordTest.java @@ -199,7 +199,7 @@ public class OverlordTest EmittingLogger.registerEmitter(serviceEmitter); } - @Test(timeout = 2000L) + @Test(timeout = 60_000L) public void testOverlordRun() throws Exception { // basic task master lifecycle test diff --git a/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskManagerTest.java b/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskManagerTest.java index ddf162cf264..6eac5993cca 100644 --- a/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskManagerTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskManagerTest.java @@ -163,7 +163,7 @@ public class WorkerTaskManagerTest workerTaskManager.stop(); } - @Test(timeout = 10000L) + @Test(timeout = 60_000L) public void testTaskRun() throws Exception { Task task1 = createNoopTask("task1-assigned-via-assign-dir"); diff --git a/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskMonitorTest.java b/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskMonitorTest.java index 0c8781aa995..f3abe4dd4e3 100644 --- a/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskMonitorTest.java +++ b/indexing-service/src/test/java/io/druid/indexing/worker/WorkerTaskMonitorTest.java @@ -215,7 +215,7 @@ public class WorkerTaskMonitorTest testingCluster.stop(); } - @Test(timeout = 30_000L) + @Test(timeout = 60_000L) public void testRunTask() throws Exception { Assert.assertTrue( @@ -271,7 +271,7 @@ public class WorkerTaskMonitorTest Assert.assertEquals(TaskState.SUCCESS, taskAnnouncement.getTaskStatus().getStatusCode()); } - @Test(timeout = 30_000L) + @Test(timeout = 60_000L) public void testGetAnnouncements() throws Exception { cf.create() @@ -309,7 +309,7 @@ public class WorkerTaskMonitorTest Assert.assertEquals(DUMMY_NODE.getPlaintextPort(), announcements.get(0).getTaskLocation().getPort()); } - @Test(timeout = 30_000L) + @Test(timeout = 60_000L) public void testRestartCleansOldStatus() throws Exception { task = TestTasks.unending("test"); @@ -345,7 +345,7 @@ public class WorkerTaskMonitorTest Assert.assertEquals(TaskState.FAILED, announcements.get(0).getTaskStatus().getStatusCode()); } - @Test(timeout = 30_000L) + @Test(timeout = 60_000L) public void testStatusAnnouncementsArePersistent() throws Exception { cf.create() diff --git a/java-util/src/test/java/io/druid/concurrent/ConcurrentAwaitableCounterTest.java b/java-util/src/test/java/io/druid/concurrent/ConcurrentAwaitableCounterTest.java index c13fa7b7d7c..8757571a5db 100644 --- a/java-util/src/test/java/io/druid/concurrent/ConcurrentAwaitableCounterTest.java +++ b/java-util/src/test/java/io/druid/concurrent/ConcurrentAwaitableCounterTest.java @@ -28,7 +28,7 @@ import java.util.concurrent.TimeUnit; public class ConcurrentAwaitableCounterTest { - @Test(timeout = 1000) + @Test(timeout = 60_000L) public void smokeTest() throws InterruptedException { ConcurrentAwaitableCounter counter = new ConcurrentAwaitableCounter(); diff --git a/java-util/src/test/java/io/druid/java/util/emitter/core/EmitterTest.java b/java-util/src/test/java/io/druid/java/util/emitter/core/EmitterTest.java index 0320c76d24c..fc695ed5b09 100644 --- a/java-util/src/test/java/io/druid/java/util/emitter/core/EmitterTest.java +++ b/java-util/src/test/java/io/druid/java/util/emitter/core/EmitterTest.java @@ -367,7 +367,7 @@ public class EmitterTest Assert.assertTrue("httpClient.succeeded()", httpClient.succeeded()); } - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testFailedEmission() throws Exception { final UnitEvent event1 = new UnitEvent("test", 1); diff --git a/java-util/src/test/java/io/druid/java/util/metrics/JvmMonitorTest.java b/java-util/src/test/java/io/druid/java/util/metrics/JvmMonitorTest.java index 1a01a74a610..3b7b6469cfc 100644 --- a/java-util/src/test/java/io/druid/java/util/metrics/JvmMonitorTest.java +++ b/java-util/src/test/java/io/druid/java/util/metrics/JvmMonitorTest.java @@ -31,7 +31,7 @@ import java.util.List; public class JvmMonitorTest { - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testGcCounts() throws InterruptedException { GcTrackingEmitter emitter = new GcTrackingEmitter(); diff --git a/processing/src/test/java/io/druid/query/ChainedExecutionQueryRunnerTest.java b/processing/src/test/java/io/druid/query/ChainedExecutionQueryRunnerTest.java index f83cf51b12a..d1ad6f0e0dd 100644 --- a/processing/src/test/java/io/druid/query/ChainedExecutionQueryRunnerTest.java +++ b/processing/src/test/java/io/druid/query/ChainedExecutionQueryRunnerTest.java @@ -58,7 +58,7 @@ public class ChainedExecutionQueryRunnerTest neverRelease.lock(); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testQueryCancellation() throws Exception { ExecutorService exec = PrioritizedExecutorService.create( @@ -182,7 +182,7 @@ public class ChainedExecutionQueryRunnerTest EasyMock.verify(watcher); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testQueryTimeout() throws Exception { ExecutorService exec = PrioritizedExecutorService.create( diff --git a/processing/src/test/java/io/druid/query/groupby/GroupByQueryRunnerFailureTest.java b/processing/src/test/java/io/druid/query/groupby/GroupByQueryRunnerFailureTest.java index 55c05ddec98..83c632a1f4d 100644 --- a/processing/src/test/java/io/druid/query/groupby/GroupByQueryRunnerFailureTest.java +++ b/processing/src/test/java/io/druid/query/groupby/GroupByQueryRunnerFailureTest.java @@ -180,7 +180,7 @@ public class GroupByQueryRunnerFailureTest this.runner = factory.mergeRunners(MoreExecutors.sameThreadExecutor(), ImmutableList.of(runner)); } - @Test(timeout = 10000) + @Test(timeout = 60_000L) public void testNotEnoughMergeBuffersOnQueryable() { expectedException.expect(QueryInterruptedException.class); @@ -209,7 +209,7 @@ public class GroupByQueryRunnerFailureTest GroupByQueryRunnerTestHelper.runQuery(factory, runner, query); } - @Test(timeout = 10000) + @Test(timeout = 60_000L) public void testResourceLimitExceededOnBroker() { expectedException.expect(ResourceLimitExceededException.class); @@ -247,7 +247,7 @@ public class GroupByQueryRunnerFailureTest GroupByQueryRunnerTestHelper.runQuery(factory, runner, query); } - @Test(timeout = 10000, expected = InsufficientResourcesException.class) + @Test(timeout = 60_000L, expected = InsufficientResourcesException.class) public void testInsufficientResourcesOnBroker() { final GroupByQuery query = GroupByQuery diff --git a/processing/src/test/java/io/druid/query/groupby/epinephelinae/StreamingMergeSortedGrouperTest.java b/processing/src/test/java/io/druid/query/groupby/epinephelinae/StreamingMergeSortedGrouperTest.java index e66cd77b0ac..8045fdc6836 100644 --- a/processing/src/test/java/io/druid/query/groupby/epinephelinae/StreamingMergeSortedGrouperTest.java +++ b/processing/src/test/java/io/druid/query/groupby/epinephelinae/StreamingMergeSortedGrouperTest.java @@ -80,7 +80,7 @@ public class StreamingMergeSortedGrouperTest ); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testEmptyIterator() { final TestColumnSelectorFactory columnSelectorFactory = GrouperTestUtil.newColumnSelectorFactory(); @@ -91,13 +91,13 @@ public class StreamingMergeSortedGrouperTest Assert.assertTrue(!grouper.iterator(true).hasNext()); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testStreamingAggregateWithLargeBuffer() throws ExecutionException, InterruptedException { testStreamingAggregate(1024); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testStreamingAggregateWithMinimumBuffer() throws ExecutionException, InterruptedException { testStreamingAggregate(60); diff --git a/processing/src/test/java/io/druid/segment/data/CompressionStrategyTest.java b/processing/src/test/java/io/druid/segment/data/CompressionStrategyTest.java index 7c817867fa0..659f55dc9dd 100644 --- a/processing/src/test/java/io/druid/segment/data/CompressionStrategyTest.java +++ b/processing/src/test/java/io/druid/segment/data/CompressionStrategyTest.java @@ -119,7 +119,7 @@ public class CompressionStrategyTest Assert.assertArrayEquals("Uncompressed data does not match", originalData, checkArray); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testConcurrency() throws Exception { final int numThreads = 20; diff --git a/server/src/test/java/io/druid/client/HttpServerInventoryViewTest.java b/server/src/test/java/io/druid/client/HttpServerInventoryViewTest.java index 7f7f8883518..b1823afee84 100644 --- a/server/src/test/java/io/druid/client/HttpServerInventoryViewTest.java +++ b/server/src/test/java/io/druid/client/HttpServerInventoryViewTest.java @@ -67,7 +67,7 @@ import java.util.concurrent.atomic.AtomicInteger; */ public class HttpServerInventoryViewTest { - @Test(timeout = 10000) + @Test(timeout = 60_000L) public void testSimple() throws Exception { ObjectMapper jsonMapper = TestHelper.makeJsonMapper(); diff --git a/server/src/test/java/io/druid/curator/CuratorUtilsTest.java b/server/src/test/java/io/druid/curator/CuratorUtilsTest.java index d327868d0e4..239ee9063f6 100644 --- a/server/src/test/java/io/druid/curator/CuratorUtilsTest.java +++ b/server/src/test/java/io/druid/curator/CuratorUtilsTest.java @@ -40,7 +40,7 @@ public class CuratorUtilsTest extends CuratorTestBase tearDownServerAndCurator(); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testCreateIfNotExists() throws Exception { curator.start(); @@ -65,7 +65,7 @@ public class CuratorUtilsTest extends CuratorTestBase Assert.assertEquals("baz", StringUtils.fromUtf8(curator.getData().forPath("/foo/bar"))); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testCreateIfNotExistsPayloadTooLarge() throws Exception { curator.start(); @@ -89,7 +89,7 @@ public class CuratorUtilsTest extends CuratorTestBase Assert.assertNull(curator.checkExists().forPath("/foo/bar")); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testCreateOrSet() throws Exception { curator.start(); @@ -116,7 +116,7 @@ public class CuratorUtilsTest extends CuratorTestBase Assert.assertEquals("qux", StringUtils.fromUtf8(curator.getData().forPath("/foo/bar"))); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testCreateOrSetPayloadTooLarge() throws Exception { curator.start(); diff --git a/server/src/test/java/io/druid/curator/discovery/CuratorDruidLeaderSelectorTest.java b/server/src/test/java/io/druid/curator/discovery/CuratorDruidLeaderSelectorTest.java index 8182737da63..546a2034459 100644 --- a/server/src/test/java/io/druid/curator/discovery/CuratorDruidLeaderSelectorTest.java +++ b/server/src/test/java/io/druid/curator/discovery/CuratorDruidLeaderSelectorTest.java @@ -47,7 +47,7 @@ public class CuratorDruidLeaderSelectorTest extends CuratorTestBase setupServerAndCurator(); } - @Test(timeout = 15000) + @Test(timeout = 60_000L) public void testSimple() throws Exception { curator.start(); diff --git a/server/src/test/java/io/druid/curator/discovery/CuratorDruidNodeAnnouncerAndDiscoveryTest.java b/server/src/test/java/io/druid/curator/discovery/CuratorDruidNodeAnnouncerAndDiscoveryTest.java index d3ec923a43b..d8a11a2b900 100644 --- a/server/src/test/java/io/druid/curator/discovery/CuratorDruidNodeAnnouncerAndDiscoveryTest.java +++ b/server/src/test/java/io/druid/curator/discovery/CuratorDruidNodeAnnouncerAndDiscoveryTest.java @@ -52,7 +52,7 @@ public class CuratorDruidNodeAnnouncerAndDiscoveryTest extends CuratorTestBase setupServerAndCurator(); } - @Test(timeout = 5000) + @Test(timeout = 60_000L) public void testAnnouncementAndDiscovery() throws Exception { ObjectMapper objectMapper = new DefaultObjectMapper(); diff --git a/server/src/test/java/io/druid/metadata/SQLMetadataStorageActionHandlerTest.java b/server/src/test/java/io/druid/metadata/SQLMetadataStorageActionHandlerTest.java index 7f4f6178c2e..d0466f5aa86 100644 --- a/server/src/test/java/io/druid/metadata/SQLMetadataStorageActionHandlerTest.java +++ b/server/src/test/java/io/druid/metadata/SQLMetadataStorageActionHandlerTest.java @@ -217,7 +217,7 @@ public class SQLMetadataStorageActionHandlerTest } } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testRepeatInsert() throws Exception { final String entryId = "abcd"; diff --git a/server/src/test/java/io/druid/query/lookup/LookupReferencesManagerTest.java b/server/src/test/java/io/druid/query/lookup/LookupReferencesManagerTest.java index a1898e5436b..843e147876c 100644 --- a/server/src/test/java/io/druid/query/lookup/LookupReferencesManagerTest.java +++ b/server/src/test/java/io/druid/query/lookup/LookupReferencesManagerTest.java @@ -434,7 +434,7 @@ public class LookupReferencesManagerTest Assert.assertTrue(state.getToDrop().contains("one")); } - @Test(timeout = 20000) + @Test(timeout = 60_000L) public void testRealModeWithMainThread() throws Exception { LookupReferencesManager lookupReferencesManager = new LookupReferencesManager( diff --git a/server/src/test/java/io/druid/segment/realtime/RealtimeManagerTest.java b/server/src/test/java/io/druid/segment/realtime/RealtimeManagerTest.java index 25533ac4d1e..81f67006b4e 100644 --- a/server/src/test/java/io/druid/segment/realtime/RealtimeManagerTest.java +++ b/server/src/test/java/io/druid/segment/realtime/RealtimeManagerTest.java @@ -376,7 +376,7 @@ public class RealtimeManagerTest Assert.assertEquals(0, plumber2.getPersistCount()); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testNormalStop() throws InterruptedException { final TestFirehose firehose = new TestFirehose(rows.iterator()); @@ -421,7 +421,7 @@ public class RealtimeManagerTest Assert.assertTrue(plumber2.isFinishedJob()); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testStopByInterruption() { final SleepingFirehose firehose = new SleepingFirehose(); @@ -454,7 +454,7 @@ public class RealtimeManagerTest Assert.assertFalse(plumber.isFinishedJob()); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testQueryWithInterval() throws InterruptedException { List expectedResults = Arrays.asList( @@ -532,7 +532,7 @@ public class RealtimeManagerTest } } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testQueryWithSegmentSpec() throws InterruptedException { List expectedResults = Arrays.asList( @@ -611,7 +611,7 @@ public class RealtimeManagerTest } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testQueryWithMultipleSegmentSpec() throws InterruptedException { diff --git a/server/src/test/java/io/druid/segment/realtime/appenderator/AppenderatorTest.java b/server/src/test/java/io/druid/segment/realtime/appenderator/AppenderatorTest.java index a052583ed88..3b74c71d244 100644 --- a/server/src/test/java/io/druid/segment/realtime/appenderator/AppenderatorTest.java +++ b/server/src/test/java/io/druid/segment/realtime/appenderator/AppenderatorTest.java @@ -414,7 +414,7 @@ public class AppenderatorTest } } - @Test(timeout = 10000L) + @Test(timeout = 60_000L) public void testTotalRowCount() throws Exception { try (final AppenderatorTester tester = new AppenderatorTester(3, true)) { diff --git a/server/src/test/java/io/druid/segment/realtime/appenderator/StreamAppenderatorDriverTest.java b/server/src/test/java/io/druid/segment/realtime/appenderator/StreamAppenderatorDriverTest.java index 603d5db13d3..5592a99858b 100644 --- a/server/src/test/java/io/druid/segment/realtime/appenderator/StreamAppenderatorDriverTest.java +++ b/server/src/test/java/io/druid/segment/realtime/appenderator/StreamAppenderatorDriverTest.java @@ -126,7 +126,7 @@ public class StreamAppenderatorDriverTest extends EasyMockSupport driver.close(); } - @Test(timeout = 2000L) + @Test(timeout = 60_000L) public void testSimple() throws Exception { final TestCommitterSupplier committerSupplier = new TestCommitterSupplier<>(); @@ -204,7 +204,7 @@ public class StreamAppenderatorDriverTest extends EasyMockSupport Assert.assertEquals(numSegments * MAX_ROWS_PER_SEGMENT, segmentsAndMetadata.getCommitMetadata()); } - @Test(timeout = 5000L, expected = TimeoutException.class) + @Test(timeout = 60_000L, expected = TimeoutException.class) public void testHandoffTimeout() throws Exception { final TestCommitterSupplier committerSupplier = new TestCommitterSupplier<>(); diff --git a/server/src/test/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseTest.java b/server/src/test/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseTest.java index ffe066f5d02..02aa14a412d 100644 --- a/server/src/test/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseTest.java +++ b/server/src/test/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseTest.java @@ -241,7 +241,7 @@ public class EventReceiverFirehoseTest ); } - @Test(timeout = 40_000L) + @Test(timeout = 60_000L) public void testShutdownWithPrevTime() throws Exception { EasyMock.expect(req.getAttribute(AuthConfig.DRUID_AUTHORIZATION_CHECKED)) @@ -261,7 +261,7 @@ public class EventReceiverFirehoseTest } } - @Test(timeout = 40_000L) + @Test(timeout = 60_000L) public void testShutdown() throws Exception { EasyMock.expect(req.getAttribute(AuthConfig.DRUID_AUTHORIZATION_CHECKED)) diff --git a/server/src/test/java/io/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java b/server/src/test/java/io/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java index 5dfc753f686..f7e1df3c041 100644 --- a/server/src/test/java/io/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java +++ b/server/src/test/java/io/druid/segment/realtime/plumber/RealtimePlumberSchoolTest.java @@ -248,13 +248,13 @@ public class RealtimePlumberSchoolTest FileUtils.deleteDirectory(tmpDir); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testPersist() throws Exception { testPersist(null); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testPersistWithCommitMetadata() throws Exception { final Object commitMetadata = "dummyCommitMetadata"; @@ -309,7 +309,7 @@ public class RealtimePlumberSchoolTest plumber.finishJob(); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testPersistFails() throws Exception { Sink sink = new Sink( @@ -356,7 +356,7 @@ public class RealtimePlumberSchoolTest Assert.assertEquals(1, metrics.failedPersists()); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testPersistHydrantGaps() throws Exception { final Object commitMetadata = "dummyCommitMetadata"; @@ -461,7 +461,7 @@ public class RealtimePlumberSchoolTest Assert.assertEquals(0, restoredPlumber2.getSinks().size()); } - @Test(timeout = 60000) + @Test(timeout = 60_000L) public void testDimOrderInheritance() throws Exception { final Object commitMetadata = "dummyCommitMetadata"; diff --git a/server/src/test/java/io/druid/server/AsyncQueryForwardingServletTest.java b/server/src/test/java/io/druid/server/AsyncQueryForwardingServletTest.java index c7c91ff5a94..3870eb09487 100644 --- a/server/src/test/java/io/druid/server/AsyncQueryForwardingServletTest.java +++ b/server/src/test/java/io/druid/server/AsyncQueryForwardingServletTest.java @@ -164,7 +164,7 @@ public class AsyncQueryForwardingServletTest extends BaseJettyTest Assert.assertNotEquals("gzip", postNoGzip.getContentEncoding()); } - @Test(timeout = 60_000) + @Test(timeout = 60_000L) public void testDeleteBroadcast() throws Exception { CountDownLatch latch = new CountDownLatch(2); diff --git a/server/src/test/java/io/druid/server/audit/SQLAuditManagerTest.java b/server/src/test/java/io/druid/server/audit/SQLAuditManagerTest.java index 24fb1496a57..6accd613b68 100644 --- a/server/src/test/java/io/druid/server/audit/SQLAuditManagerTest.java +++ b/server/src/test/java/io/druid/server/audit/SQLAuditManagerTest.java @@ -64,7 +64,7 @@ public class SQLAuditManagerTest ); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testAuditEntrySerde() throws IOException { AuditEntry entry = new AuditEntry( @@ -83,7 +83,7 @@ public class SQLAuditManagerTest Assert.assertEquals(entry, serde); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testCreateAuditEntry() throws IOException { AuditEntry entry = new AuditEntry( @@ -109,7 +109,7 @@ public class SQLAuditManagerTest } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testFetchAuditHistory() { AuditEntry entry = new AuditEntry( @@ -135,7 +135,7 @@ public class SQLAuditManagerTest Assert.assertEquals(entry, auditEntries.get(1)); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testFetchAuditHistoryByKeyAndTypeWithLimit() { AuditEntry entry1 = new AuditEntry( @@ -171,7 +171,7 @@ public class SQLAuditManagerTest Assert.assertEquals(entry1, auditEntries.get(0)); } - @Test(timeout = 10_000L) + @Test(timeout = 60_000L) public void testFetchAuditHistoryByTypeWithLimit() { AuditEntry entry1 = new AuditEntry( diff --git a/server/src/test/java/io/druid/server/coordination/ChangeRequestHttpSyncerTest.java b/server/src/test/java/io/druid/server/coordination/ChangeRequestHttpSyncerTest.java index 0af314bd4aa..73ba16accd7 100644 --- a/server/src/test/java/io/druid/server/coordination/ChangeRequestHttpSyncerTest.java +++ b/server/src/test/java/io/druid/server/coordination/ChangeRequestHttpSyncerTest.java @@ -50,7 +50,7 @@ import java.util.concurrent.atomic.AtomicInteger; */ public class ChangeRequestHttpSyncerTest { - @Test(timeout = 10000) + @Test(timeout = 60_000L) public void testSimple() throws Exception { ObjectMapper jsonMapper = TestHelper.makeJsonMapper(); diff --git a/server/src/test/java/io/druid/server/coordination/SegmentLoadDropHandlerTest.java b/server/src/test/java/io/druid/server/coordination/SegmentLoadDropHandlerTest.java index 26eaeef058a..30ae75eb8bc 100644 --- a/server/src/test/java/io/druid/server/coordination/SegmentLoadDropHandlerTest.java +++ b/server/src/test/java/io/druid/server/coordination/SegmentLoadDropHandlerTest.java @@ -449,7 +449,7 @@ public class SegmentLoadDropHandlerTest Assert.assertTrue(infoDir.delete()); } - @Test(timeout = 1000L) + @Test(timeout = 60_000L) public void testProcessBatch() throws Exception { segmentLoadDropHandler.start(); diff --git a/server/src/test/java/io/druid/server/coordination/ZkCoordinatorTest.java b/server/src/test/java/io/druid/server/coordination/ZkCoordinatorTest.java index 35433da5a44..bfbe8b34eb1 100644 --- a/server/src/test/java/io/druid/server/coordination/ZkCoordinatorTest.java +++ b/server/src/test/java/io/druid/server/coordination/ZkCoordinatorTest.java @@ -81,7 +81,7 @@ public class ZkCoordinatorTest extends CuratorTestBase tearDownServerAndCurator(); } - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testLoadDrop() throws Exception { EmittingLogger.registerEmitter(new NoopServiceEmitter()); diff --git a/server/src/test/java/io/druid/server/coordinator/CuratorDruidCoordinatorTest.java b/server/src/test/java/io/druid/server/coordinator/CuratorDruidCoordinatorTest.java index 256d819cd90..d1d13e2bca1 100644 --- a/server/src/test/java/io/druid/server/coordinator/CuratorDruidCoordinatorTest.java +++ b/server/src/test/java/io/druid/server/coordinator/CuratorDruidCoordinatorTest.java @@ -240,7 +240,7 @@ public class CuratorDruidCoordinatorTest extends CuratorTestBase tearDownServerAndCurator(); } - @Test(timeout = 10_000) + @Test(timeout = 60_000L) public void testMoveSegment() throws Exception { segmentViewInitLatch = new CountDownLatch(1); diff --git a/server/src/test/java/io/druid/server/coordinator/HttpLoadQueuePeonTest.java b/server/src/test/java/io/druid/server/coordinator/HttpLoadQueuePeonTest.java index c2388359a1e..069279d2b43 100644 --- a/server/src/test/java/io/druid/server/coordinator/HttpLoadQueuePeonTest.java +++ b/server/src/test/java/io/druid/server/coordinator/HttpLoadQueuePeonTest.java @@ -98,7 +98,7 @@ public class HttpLoadQueuePeonTest } }; - @Test(timeout = 10000) + @Test(timeout = 60_000L) public void testSimple() throws Exception { HttpLoadQueuePeon httpLoadQueuePeon = new HttpLoadQueuePeon( @@ -135,7 +135,7 @@ public class HttpLoadQueuePeonTest httpLoadQueuePeon.stop(); } - @Test(timeout = 10000) + @Test(timeout = 60_000L) public void testLoadDropAfterStop() throws Exception { HttpLoadQueuePeon httpLoadQueuePeon = new HttpLoadQueuePeon( diff --git a/server/src/test/java/io/druid/server/initialization/jetty/LimitRequestsFilterTest.java b/server/src/test/java/io/druid/server/initialization/jetty/LimitRequestsFilterTest.java index 70c620fcfc1..18893e3da48 100644 --- a/server/src/test/java/io/druid/server/initialization/jetty/LimitRequestsFilterTest.java +++ b/server/src/test/java/io/druid/server/initialization/jetty/LimitRequestsFilterTest.java @@ -33,7 +33,7 @@ import java.util.concurrent.CountDownLatch; */ public class LimitRequestsFilterTest { - @Test(timeout = 5000L) + @Test(timeout = 60_000L) public void testSimple() throws Exception { LimitRequestsFilter filter = new LimitRequestsFilter(2); diff --git a/server/src/test/java/io/druid/server/lookup/cache/LookupCoordinatorManagerTest.java b/server/src/test/java/io/druid/server/lookup/cache/LookupCoordinatorManagerTest.java index 3eb29e25494..f07adfd4db0 100644 --- a/server/src/test/java/io/druid/server/lookup/cache/LookupCoordinatorManagerTest.java +++ b/server/src/test/java/io/druid/server/lookup/cache/LookupCoordinatorManagerTest.java @@ -1028,7 +1028,7 @@ public class LookupCoordinatorManagerTest } - @Test(timeout = 2_000) + @Test(timeout = 60_000L) public void testLookupManagementLoop() throws Exception { Map lookup1 = ImmutableMap.of( diff --git a/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java b/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java index 705e483ddfd..9794e6bfc2d 100644 --- a/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java +++ b/sql/src/test/java/io/druid/sql/avatica/DruidAvaticaHandlerTest.java @@ -551,7 +551,7 @@ public class DruidAvaticaHandlerTest extends CalciteTestBase } - @Test(timeout = 90000) + @Test(timeout = 90_000L) public void testConcurrentQueries() throws Exception { final List> futures = new ArrayList<>();