diff --git a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTest.java b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTest.java index 4d3825311aef3cd874ba5cf20d6b6f4456890e8c..5cbe1be7eeafb06a181c6cc0024905a97706d305 100644 --- a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTest.java +++ b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTest.java @@ -139,7 +139,7 @@ public class YarnFileStageTest extends TestLogger { * @param addSchemeToLocalPath * whether add the file:// scheme to the local path to copy from */ - public static void testCopyFromLocalRecursive( + static void testCopyFromLocalRecursive( FileSystem targetFileSystem, Path targetDir, TemporaryFolder tempFolder, diff --git a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTestS3ITCase.java b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTestS3ITCase.java index 74fb5963179d6df497e1bf298a4f7f3933f93eea..e1e95b1c379d185a5e6771cbde2d55331e3cfbb6 100644 --- a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTestS3ITCase.java +++ b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTestS3ITCase.java @@ -42,7 +42,6 @@ import java.util.Map; import java.util.UUID; import static org.hamcrest.Matchers.greaterThan; -import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertThat; import static org.junit.Assume.assumeFalse; import static org.junit.Assume.assumeNoException; @@ -166,9 +165,6 @@ public class YarnFileStageTestS3ITCase extends TestLogger { YarnFileStageTest.testCopyFromLocalRecursive(fs.getHadoopFileSystem(), new org.apache.hadoop.fs.Path(directory.toUri()), tempFolder, true); - - // now directory must be gone - assertFalse(fs.exists(directory)); } finally { // clean up fs.delete(basePath, true);