You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/12/04 09:01:37 UTC
flink git commit: [FLINK-8148][yarn/s3] fix test instability in
YarnFileStageTestS3ITCase
Repository: flink
Updated Branches:
refs/heads/master 49f690986 -> 4bd0ef1b5
[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.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4bd0ef1b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4bd0ef1b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4bd0ef1b
Branch: refs/heads/master
Commit: 4bd0ef1b5208ff3a853fbb7c3d74edc5317d0245
Parents: 49f6909
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Fri Nov 24 14:54:41 2017 +0100
Committer: zentol <ch...@apache.org>
Committed: Mon Dec 4 10:01:25 2017 +0100
----------------------------------------------------------------------
.../src/test/java/org/apache/flink/yarn/YarnFileStageTest.java | 2 +-
.../java/org/apache/flink/yarn/YarnFileStageTestS3ITCase.java | 4 ----
2 files changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/4bd0ef1b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTest.java
----------------------------------------------------------------------
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 4d38253..5cbe1be 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 <tt>file://</tt> scheme to the local path to copy from
*/
- public static void testCopyFromLocalRecursive(
+ static void testCopyFromLocalRecursive(
FileSystem targetFileSystem,
Path targetDir,
TemporaryFolder tempFolder,
http://git-wip-us.apache.org/repos/asf/flink/blob/4bd0ef1b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTestS3ITCase.java
----------------------------------------------------------------------
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 74fb596..e1e95b1 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);