diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsForLocalFS.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsForLocalFS.java index 235e9c2dc9..1ef6f3cdcf 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsForLocalFS.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsForLocalFS.java @@ -88,28 +88,28 @@ protected InputStream getInputStream(int bufferSize, byte[] key, byte[] iv) @Ignore("ChecksumFSInputChecker doesn't support ByteBuffer read") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testByteBufferRead() throws Exception {} @Ignore("ChecksumFSOutputSummer doesn't support Syncable") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testSyncable() throws IOException {} @Ignore("ChecksumFSInputChecker doesn't support ByteBuffer read") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testCombinedOp() throws Exception {} @Ignore("ChecksumFSInputChecker doesn't support enhanced ByteBuffer access") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testHasEnhancedByteBufferAccess() throws Exception { } @Ignore("ChecksumFSInputChecker doesn't support seekToNewSource") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testSeekToNewSource() throws Exception { } } diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsNormal.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsNormal.java index e9c313fde3..b5382c1efc 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsNormal.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsNormal.java @@ -83,41 +83,41 @@ protected InputStream getInputStream(int bufferSize, byte[] key, byte[] iv) @Ignore("Wrapped stream doesn't support Syncable") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testSyncable() throws IOException {} @Ignore("Wrapped stream doesn't support PositionedRead") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testPositionedRead() throws IOException {} @Ignore("Wrapped stream doesn't support ReadFully") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testReadFully() throws IOException {} @Ignore("Wrapped stream doesn't support Seek") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testSeek() throws IOException {} @Ignore("Wrapped stream doesn't support ByteBufferRead") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testByteBufferRead() throws IOException {} @Ignore("Wrapped stream doesn't support ByteBufferRead, Seek") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testCombinedOp() throws IOException {} @Ignore("Wrapped stream doesn't support SeekToNewSource") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testSeekToNewSource() throws IOException {} @Ignore("Wrapped stream doesn't support HasEnhancedByteBufferAccess") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testHasEnhancedByteBufferAccess() throws IOException {} } diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestGlobPattern.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestGlobPattern.java index 99cb645e82..b409a8f929 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestGlobPattern.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestGlobPattern.java @@ -72,7 +72,7 @@ private void shouldThrow(String... globs) { shouldThrow("[", "[[]]", "{", "\\"); } - @Test(timeout=1000) public void testPathologicalPatterns() { + @Test(timeout=10000) public void testPathologicalPatterns() { String badFilename = "job_1429571161900_4222-1430338332599-tda%2D%2D+******************************+++...%270%27%28Stage-1430338580443-39-2000-SUCCEEDED-production%2Dhigh-1430338340360.jhist"; assertMatch(true, badFilename, badFilename); } diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestSymlinkLocalFSFileSystem.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestSymlinkLocalFSFileSystem.java index 6fc2d62d8c..98449493fa 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestSymlinkLocalFSFileSystem.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestSymlinkLocalFSFileSystem.java @@ -41,24 +41,24 @@ public static void testSetup() throws Exception { @Ignore("RawLocalFileSystem#mkdir does not treat existence of directory" + " as an error") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testMkdirExistingLink() throws IOException {} @Ignore("FileSystem#create defaults to creating parents," + " throwing an IOException instead of FileNotFoundException") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testCreateFileViaDanglingLinkParent() throws IOException {} @Ignore("RawLocalFileSystem does not throw an exception if the path" + " already exists") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testCreateFileDirExistingLink() throws IOException {} @Ignore("ChecksumFileSystem does not support append") @Override - @Test(timeout=1000) + @Test(timeout=10000) public void testAccessFileViaInterSymlinkAbsTarget() throws IOException {} @Override diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestSortedMapWritable.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestSortedMapWritable.java index 8c98808384..3d5bb1eab9 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestSortedMapWritable.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestSortedMapWritable.java @@ -166,7 +166,7 @@ public void testEqualsAndHashCode() { assertTrue(failureReason, !mapB.equals(mapA)); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testPutAll() { SortedMapWritable map1 = new SortedMapWritable(); SortedMapWritable map2 = new SortedMapWritable(); diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCodecPool.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCodecPool.java index c889a59b26..1fb25cb908 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCodecPool.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCodecPool.java @@ -43,7 +43,7 @@ public void setup() { this.codec.setConf(new Configuration()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testCompressorPoolCounts() { // Get two compressors and return them Compressor comp1 = CodecPool.getCompressor(codec); @@ -64,7 +64,7 @@ public void testCompressorPoolCounts() { CodecPool.getLeasedCompressorsCount(codec)); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testCompressorNotReturnSameInstance() { Compressor comp = CodecPool.getCompressor(codec); CodecPool.returnCompressor(comp); @@ -79,7 +79,7 @@ public void testCompressorNotReturnSameInstance() { } } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testDecompressorPoolCounts() { // Get two decompressors and return them Decompressor decomp1 = CodecPool.getDecompressor(codec); @@ -100,7 +100,7 @@ public void testDecompressorPoolCounts() { CodecPool.getLeasedCompressorsCount(codec)); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testMultiThreadedCompressorPool() throws InterruptedException { final int iterations = 4; ExecutorService threadpool = Executors.newFixedThreadPool(3); @@ -137,7 +137,7 @@ public Boolean call() throws Exception { assertEquals(LEASE_COUNT_ERR, 0, CodecPool.getLeasedCompressorsCount(codec)); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testMultiThreadedDecompressorPool() throws InterruptedException { final int iterations = 4; ExecutorService threadpool = Executors.newFixedThreadPool(3); @@ -175,7 +175,7 @@ public Boolean call() throws Exception { CodecPool.getLeasedDecompressorsCount(codec)); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testDecompressorNotReturnSameInstance() { Decompressor decomp = CodecPool.getDecompressor(codec); CodecPool.returnDecompressor(decomp); diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/TestUserGroupInformation.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/TestUserGroupInformation.java index 510987ee45..00062c0a37 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/TestUserGroupInformation.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/TestUserGroupInformation.java @@ -878,7 +878,7 @@ public void testHasSufficientTimeElapsed() throws Exception { method.setAccessible(false); } - @Test(timeout=1000) + @Test(timeout=10000) public void testSetLoginUser() throws IOException { UserGroupInformation ugi = UserGroupInformation.createRemoteUser("test-user"); UserGroupInformation.setLoginUser(ugi); diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/service/TestCompositeService.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/service/TestCompositeService.java index 9493740ad6..6189c0ed19 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/service/TestCompositeService.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/service/TestCompositeService.java @@ -312,7 +312,7 @@ public void testAddServiceInInit() throws Throwable { assertInState(STATE.INITED, child); } - @Test (timeout = 1000) + @Test (timeout = 10000) public void testAddIfService() { CompositeService testService = new CompositeService("TestService") { Service service; @@ -363,7 +363,7 @@ public void serviceInit(Configuration conf) { // Tests for adding child service to parent // - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedChildBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -376,7 +376,7 @@ public void testAddUninitedChildBeforeInit() throws Throwable { assertInState(STATE.STOPPED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedChildInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -396,7 +396,7 @@ public void testAddUninitedChildInInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedChildInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -408,7 +408,7 @@ public void testAddUninitedChildInStart() throws Throwable { assertInState(STATE.NOTINITED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedChildInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -419,7 +419,7 @@ public void testAddUninitedChildInStop() throws Throwable { assertInState(STATE.NOTINITED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedChildBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -433,7 +433,7 @@ public void testAddInitedChildBeforeInit() throws Throwable { assertInState(STATE.STOPPED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedChildInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -446,7 +446,7 @@ public void testAddInitedChildInInit() throws Throwable { assertInState(STATE.STOPPED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedChildInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -459,7 +459,7 @@ public void testAddInitedChildInStart() throws Throwable { assertInState(STATE.STOPPED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedChildInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -471,7 +471,7 @@ public void testAddInitedChildInStop() throws Throwable { assertInState(STATE.INITED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedChildBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -489,7 +489,7 @@ public void testAddStartedChildBeforeInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedChildInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -503,7 +503,7 @@ public void testAddStartedChildInInit() throws Throwable { assertInState(STATE.STOPPED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedChildInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -517,7 +517,7 @@ public void testAddStartedChildInStart() throws Throwable { assertInState(STATE.STOPPED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedChildInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -530,7 +530,7 @@ public void testAddStartedChildInStop() throws Throwable { assertInState(STATE.STARTED, child); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedChildBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -549,7 +549,7 @@ public void testAddStoppedChildBeforeInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedChildInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -570,7 +570,7 @@ public void testAddStoppedChildInInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedChildInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -583,7 +583,7 @@ public void testAddStoppedChildInStart() throws Throwable { parent.stop(); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedChildInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService child = new BreakableService(); @@ -600,7 +600,7 @@ public void testAddStoppedChildInStop() throws Throwable { // Tests for adding sibling service to parent // - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedSiblingBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -617,7 +617,7 @@ public void testAddUninitedSiblingBeforeInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedSiblingInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -636,7 +636,7 @@ public void testAddUninitedSiblingInInit() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedSiblingInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -653,7 +653,7 @@ public void testAddUninitedSiblingInStart() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddUninitedSiblingInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -670,7 +670,7 @@ public void testAddUninitedSiblingInStop() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedSiblingBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -688,7 +688,7 @@ public void testAddInitedSiblingBeforeInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedSiblingInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -706,7 +706,7 @@ public void testAddInitedSiblingInInit() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedSiblingInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -724,7 +724,7 @@ public void testAddInitedSiblingInStart() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddInitedSiblingInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -735,7 +735,7 @@ public void testAddInitedSiblingInStop() throws Throwable { parent.init(new Configuration()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedSiblingBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -754,7 +754,7 @@ public void testAddStartedSiblingBeforeInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedSiblingInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -774,7 +774,7 @@ public void testAddStartedSiblingInInit() throws Throwable { } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedSiblingInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -793,7 +793,7 @@ public void testAddStartedSiblingInStart() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStartedSiblingInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -812,7 +812,7 @@ public void testAddStartedSiblingInStop() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedSiblingBeforeInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -832,7 +832,7 @@ public void testAddStoppedSiblingBeforeInit() throws Throwable { 1, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedSiblingInInit() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -856,7 +856,7 @@ public void testAddStoppedSiblingInInit() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedSiblingInStart() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); @@ -876,7 +876,7 @@ public void testAddStoppedSiblingInStart() throws Throwable { 2, parent.getServices().size()); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testAddStoppedSiblingInStop() throws Throwable { CompositeService parent = new CompositeService("parent"); BreakableService sibling = new BreakableService(); diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/util/TestClassUtil.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/util/TestClassUtil.java index 4bc36e2ec0..98e182236c 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/util/TestClassUtil.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/util/TestClassUtil.java @@ -26,7 +26,7 @@ import org.junit.Test; public class TestClassUtil { - @Test(timeout=1000) + @Test(timeout=10000) public void testFindContainingJar() { String containingJar = ClassUtil.findContainingJar(Logger.class); Assert.assertNotNull("Containing jar not found for Logger", diff --git a/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/portmap/TestPortmap.java b/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/portmap/TestPortmap.java index f217e843d7..ba132bb7ab 100644 --- a/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/portmap/TestPortmap.java +++ b/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/portmap/TestPortmap.java @@ -53,7 +53,7 @@ public static void tearDown() { pm.shutdown(); } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testIdle() throws InterruptedException, IOException { Socket s = new Socket(); try { @@ -75,7 +75,7 @@ public void testIdle() throws InterruptedException, IOException { } } - @Test(timeout = 1000) + @Test(timeout = 10000) public void testRegistration() throws IOException, InterruptedException { XDR req = new XDR(); RpcCall.getInstance(++xid, RpcProgramPortmap.PROGRAM,