提交 4bd0ef1b 编写于 作者: N Nico Kruber 提交者: zentol

[FLINK-8148][yarn/s3] fix test instability in YarnFileStageTestS3ITCase

Remove a check for a deleted directory since we may not see our own delete yet
with S3.

This closes #5066.
上级 49f69098
...@@ -139,7 +139,7 @@ public class YarnFileStageTest extends TestLogger { ...@@ -139,7 +139,7 @@ public class YarnFileStageTest extends TestLogger {
* @param addSchemeToLocalPath * @param addSchemeToLocalPath
* whether add the <tt>file://</tt> scheme to the local path to copy from * whether add the <tt>file://</tt> scheme to the local path to copy from
*/ */
public static void testCopyFromLocalRecursive( static void testCopyFromLocalRecursive(
FileSystem targetFileSystem, FileSystem targetFileSystem,
Path targetDir, Path targetDir,
TemporaryFolder tempFolder, TemporaryFolder tempFolder,
......
...@@ -42,7 +42,6 @@ import java.util.Map; ...@@ -42,7 +42,6 @@ import java.util.Map;
import java.util.UUID; import java.util.UUID;
import static org.hamcrest.Matchers.greaterThan; import static org.hamcrest.Matchers.greaterThan;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertThat; import static org.junit.Assert.assertThat;
import static org.junit.Assume.assumeFalse; import static org.junit.Assume.assumeFalse;
import static org.junit.Assume.assumeNoException; import static org.junit.Assume.assumeNoException;
...@@ -166,9 +165,6 @@ public class YarnFileStageTestS3ITCase extends TestLogger { ...@@ -166,9 +165,6 @@ public class YarnFileStageTestS3ITCase extends TestLogger {
YarnFileStageTest.testCopyFromLocalRecursive(fs.getHadoopFileSystem(), YarnFileStageTest.testCopyFromLocalRecursive(fs.getHadoopFileSystem(),
new org.apache.hadoop.fs.Path(directory.toUri()), tempFolder, true); new org.apache.hadoop.fs.Path(directory.toUri()), tempFolder, true);
// now directory must be gone
assertFalse(fs.exists(directory));
} finally { } finally {
// clean up // clean up
fs.delete(basePath, true); fs.delete(basePath, true);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册