[hotfix] [hadoopCompat] Fix tests to verify results new Hadoop input …

…API. This closes apache#4325.
silenceland · Jul 18, 2017 · ba7ec5e · ba7ec5e
1 parent 471345c
commit ba7ec5e
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
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
@@ -70,6 +70,7 @@ protected void testProgram() throws Exception {
 		postSubmit();
 		resultPath = getTempDirPath("result2");
 		internalRun(false);
+		postSubmit();
 	}
 
 	private void internalRun(boolean isTestDeprecatedAPI) throws Exception {

diff --git a/...-tests/src/test/java/org/apache/flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java b/...-tests/src/test/java/org/apache/flink/test/hadoop/mapreduce/WordCountMapreduceITCase.java
@@ -70,6 +70,7 @@ protected void testProgram() throws Exception {
 		postSubmit();
 		resultPath = getTempDirPath("result2");
 		internalRun(false);
+		postSubmit();
 	}
 
 	private void internalRun(boolean isTestDeprecatedAPI) throws Exception {

diff --git a/...tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala b/...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()
   }
 }
 
diff --git a/...src/test/scala/org/apache/flink/api/scala/hadoop/mapreduce/WordCountMapreduceITCase.scala b/...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 = {