You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/12/29 08:53:48 UTC
[flink] branch master updated: [FLINK-20793][core] Fix the
NamesTest and JarSubmissionITCase due to code style refactor
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 679c974 [FLINK-20793][core] Fix the NamesTest and JarSubmissionITCase due to code style refactor
679c974 is described below
commit 679c974a24de55d5a12d1fa58cb679dd242098ba
Author: huangxingbo <hx...@gmail.com>
AuthorDate: Tue Dec 29 10:58:18 2020 +0800
[FLINK-20793][core] Fix the NamesTest and JarSubmissionITCase due to code style refactor
This closes #14514.
---
.../src/test/java/org/apache/flink/api/java/operators/NamesTest.java | 5 +++--
.../flink/runtime/webmonitor/handlers/JarSubmissionITCase.java | 2 +-
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/flink-java/src/test/java/org/apache/flink/api/java/operators/NamesTest.java b/flink-java/src/test/java/org/apache/flink/api/java/operators/NamesTest.java
index 41dabe7..ffeeebb 100644
--- a/flink-java/src/test/java/org/apache/flink/api/java/operators/NamesTest.java
+++ b/flink-java/src/test/java/org/apache/flink/api/java/operators/NamesTest.java
@@ -62,7 +62,7 @@ public class NamesTest implements Serializable {
})
.output(new DiscardingOutputFormat<String>());
Plan plan = env.createProgramPlan();
- testForName("Filter at testDefaultName(NamesTest.java:55)", plan);
+ testForName("Filter at testDefaultName(NamesTest.java:54)", plan);
}
@Test
@@ -117,7 +117,8 @@ public class NamesTest implements Serializable {
public boolean preVisit(Operator<?> visitable) {
if (visitable instanceof InnerJoinOperatorBase) {
Assert.assertEquals(
- "Join at testJoinWith(NamesTest.java:93)", visitable.getName());
+ "Join at testJoinWith(NamesTest.java:101)",
+ visitable.getName());
}
return true;
}
diff --git a/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarSubmissionITCase.java b/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarSubmissionITCase.java
index 810ad28..6fdd637 100644
--- a/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarSubmissionITCase.java
+++ b/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarSubmissionITCase.java
@@ -95,7 +95,7 @@ public class JarSubmissionITCase extends TestLogger {
final JobPlanInfo planResponse = showPlan(planHandler, storedJarName, restfulGateway);
// we're only interested in the core functionality so checking for a small detail is
// sufficient
- Assert.assertThat(planResponse.getJsonPlan(), containsString("TestProgram.java:30"));
+ Assert.assertThat(planResponse.getJsonPlan(), containsString("TestProgram.java:28"));
runJar(runHandler, storedJarName, restfulGateway);