big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HADOOP-14377. Increase Common test timeouts from 1 second to 10 seconds. Contributed by Eric Badger

Browse Source
This commit is contained in:
Jason Lowe 2017-05-09 16:08:34 -05:00
parent a2f680493f
commit f7faac8e90
10 changed files with 62 additions and 62 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsForLocalFS.java
View File

@ -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 {
}
}

16
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/crypto/TestCryptoStreamsNormal.java
View File

@ -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 {}
}

2
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestGlobPattern.java
View File

@ -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);
}

8
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/TestSymlinkLocalFSFileSystem.java
View File

@ -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

2
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestSortedMapWritable.java
View File

@ -166,7 +166,7 @@ public void testEqualsAndHashCode() {
assertTrue(failureReason, !mapB.equals(mapA));
}
@Test(timeout = 1000)
@Test(timeout = 10000)
public void testPutAll() {
SortedMapWritable<Text> map1 = new SortedMapWritable<Text>();
SortedMapWritable<Text> map2 = new SortedMapWritable<Text>();

12
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/compress/TestCodecPool.java
View File

@ -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);

2
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/TestUserGroupInformation.java
View File

@ -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);

66
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/service/TestCompositeService.java
View File

@ -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();

2
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/util/TestClassUtil.java
View File

@ -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",

4
hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/portmap/TestPortmap.java
View File

@ -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,