You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/07/18 07:42:02 UTC
flink git commit: [hotfix] [hadoopCompat] Fix tests to verify results
new Hadoop input API.
Repository: flink
Updated Branches:
refs/heads/master 471345c0e -> ba7ec5e19
[hotfix] [hadoopCompat] Fix tests to verify results new Hadoop input API.
This closes #4325.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba7ec5e1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ba7ec5e1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ba7ec5e1
Branch: refs/heads/master
Commit: ba7ec5e191c2ad85bcae78c3563d736599cb7a83
Parents: 471345c
Author: Fabian Hueske <fh...@apache.org>
Authored: Tue Jul 11 15:33:22 2017 +0200
Committer: Fabian Hueske <fh...@apache.org>
Committed: Tue Jul 18 09:40:49 2017 +0200
----------------------------------------------------------------------
.../org/apache/flink/test/hadoop/mapred/WordCountMapredITCase.java | 1 +
.../flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java | 1 +
.../flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala | 1 +
.../flink/api/scala/hadoop/mapreduce/WordCountMapreduceITCase.scala | 1 +
4 files changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ba7ec5e1/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapred/WordCountMapredITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapred/WordCountMapredITCase.java b/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapred/WordCountMapredITCase.java
index 21f6985..409bb40 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapred/WordCountMapredITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapred/WordCountMapredITCase.java
@@ -70,6 +70,7 @@ public class WordCountMapredITCase extends JavaProgramTestBase {
postSubmit();
resultPath = getTempDirPath("result2");
internalRun(false);
+ postSubmit();
}
private void internalRun(boolean isTestDeprecatedAPI) throws Exception {
http://git-wip-us.apache.org/repos/asf/flink/blob/ba7ec5e1/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java b/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java
index 0092fe7..632b406 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java
@@ -70,6 +70,7 @@ public class WordCountMapreduceITCase extends JavaProgramTestBase {
postSubmit();
resultPath = getTempDirPath("result2");
internalRun(false);
+ postSubmit();
}
private void internalRun(boolean isTestDeprecatedAPI) throws Exception {
http://git-wip-us.apache.org/repos/asf/flink/blob/ba7ec5e1/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala
index 9d04ca59..e7069e1 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala
@@ -84,6 +84,7 @@ class WordCountMapredITCase extends JavaProgramTestBase {
postSubmit()
resultPath = getTempDirPath("result2")
internalRun(testDeprecatedAPI = false)
+ postSubmit()
}
}
http://git-wip-us.apache.org/repos/asf/flink/blob/ba7ec5e1/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapreduce/WordCountMapreduceITCase.scala
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapreduce/WordCountMapreduceITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapreduce/WordCountMapreduceITCase.scala
index 3b23a13..c3031e9 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapreduce/WordCountMapreduceITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapreduce/WordCountMapreduceITCase.scala
@@ -55,6 +55,7 @@ class WordCountMapreduceITCase extends JavaProgramTestBase {
postSubmit()
resultPath = getTempDirPath("result2")
internalRun(testDeprecatedAPI = false)
+ postSubmit()
}
private def internalRun (testDeprecatedAPI: Boolean): Unit = {