From 29d7a8e085a5655c00a3163546e22a5d1331ea60 Mon Sep 17 00:00:00 2001 From: Nico Kruber Date: Fri, 24 Nov 2017 14:54:41 +0100 Subject: [PATCH] [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. --- .../src/test/java/org/apache/flink/yarn/YarnFileStageTest.java | 2 +- .../java/org/apache/flink/yarn/YarnFileStageTestS3ITCase.java | 3 --- 2 files changed, 1 insertion(+), 4 deletions(-) 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 4d3825311aef3..5cbe1be7eeafb 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 void testCopyFromLocalRecursiveWithoutScheme() throws Exception { * @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 74fb5963179d6..8d53287df9473 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 @@ -166,9 +166,6 @@ private void testRecursiveUploadForYarn(String scheme, String pathSuffix) throws 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);