HDFS-16281. Fix flaky unit tests failed due to timeout (#3574)

This commit is contained in:
litao 2021-10-26 14:54:11 +08:00 committed by GitHub
parent b923fa7a1c
commit c1a8285363
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
7 changed files with 11 additions and 11 deletions

View File

@ -103,7 +103,7 @@ public class TestViewFileSystemOverloadSchemeHdfsFileSystemContract
}
@Override
@Test
@Test(timeout = 60000)
public void testAppend() throws IOException {
AppendTestUtil.testAppend(fs, new Path("/append/f"));
}

View File

@ -496,7 +496,7 @@ public class TestViewFileSystemOverloadSchemeWithHdfsScheme {
* When InnerCache disabled, all matching ViewFileSystemOverloadScheme
* initialized scheme file systems would not use FileSystem cache.
*/
@Test(timeout = 3000)
@Test(timeout = 30000)
public void testViewFsOverloadSchemeWithNoInnerCacheAndHdfsTargets()
throws Exception {
final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
@ -523,7 +523,7 @@ public class TestViewFileSystemOverloadSchemeWithHdfsScheme {
* initialized scheme file systems should continue to take advantage of
* FileSystem cache.
*/
@Test(timeout = 3000)
@Test(timeout = 30000)
public void testViewFsOverloadSchemeWithNoInnerCacheAndLocalSchemeTargets()
throws Exception {
final Path localTragetPath = new Path(localTargetDir.toURI());
@ -545,7 +545,7 @@ public class TestViewFileSystemOverloadSchemeWithHdfsScheme {
/**
* Tests the rename with nfly mount link.
*/
@Test(timeout = 3000)
@Test(timeout = 30000)
public void testNflyRename() throws Exception {
final Path hdfsTargetPath1 = new Path(defaultFSURI + HDFS_USER_FOLDER);
final Path hdfsTargetPath2 = new Path(defaultFSURI + HDFS_USER_FOLDER + 1);
@ -577,7 +577,7 @@ public class TestViewFileSystemOverloadSchemeWithHdfsScheme {
/**
* Tests the write and read contents with nfly mount link.
*/
@Test(timeout = 3000)
@Test(timeout = 30000)
public void testNflyWriteRead() throws Exception {
final Path hdfsTargetPath1 = new Path(defaultFSURI + HDFS_USER_FOLDER);
final Path hdfsTargetPath2 = new Path(defaultFSURI + HDFS_USER_FOLDER + 1);
@ -604,7 +604,7 @@ public class TestViewFileSystemOverloadSchemeWithHdfsScheme {
* target file. 3. Tests the read works with repairOnRead flag. 4. Tests that
* previously deleted file fully recovered and exists.
*/
@Test(timeout = 3000)
@Test(timeout = 30000)
public void testNflyRepair() throws Exception {
final NflyFSystem.NflyKey repairKey = NflyFSystem.NflyKey.repairOnRead;
final Path hdfsTargetPath1 = new Path(defaultFSURI + HDFS_USER_FOLDER);

View File

@ -63,7 +63,7 @@ public class TestHDFSFileSystemContract extends FileSystemContractBaseTest {
return defaultWorkingDirectory;
}
@Test
@Test(timeout = 60000)
public void testAppend() throws IOException {
AppendTestUtil.testAppend(fs, new Path("/testAppend/f"));
}

View File

@ -224,7 +224,7 @@ public class TestSnapshotCommands {
fs.delete(new Path("/Fully/QPath"), true);
}
@Test (timeout=60000)
@Test (timeout=120000)
public void testSnapshotDiff()throws Exception {
Configuration config = new HdfsConfiguration();
Path snapDirPath = new Path(fs.getUri().toString() + "/snap_dir");

View File

@ -158,7 +158,7 @@ public class TestDiskBalancerCommand {
* Tests running multiple commands under on setup. This mainly covers
* {@link org.apache.hadoop.hdfs.server.diskbalancer.command.Command#close}
*/
@Test(timeout = 60000)
@Test(timeout = 120000)
public void testRunMultipleCommandsUnderOneSetup() throws Exception {
final int numDatanodes = 1;

View File

@ -192,7 +192,7 @@ public class TestNamenodeStorageDirectives {
* Types.
* @throws IOException
*/
@Test(timeout=60000)
@Test(timeout=120000)
public void testTargetStorageTypes() throws ReconfigurationException,
InterruptedException, TimeoutException, IOException {
// DISK and not anything else.

View File

@ -396,7 +396,7 @@ public class TestWebHdfsFileSystemContract extends FileSystemContractBaseTest {
}
}
@Test
@Test(timeout = 60000)
public void testResponseCode() throws IOException {
final WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)fs;
final Path root = new Path("/");