File tree 2 files changed +4
-3
lines changed
flink-java/src/test/java/org/apache/flink/api/java/operators
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers
2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -62,7 +62,7 @@ public boolean filter(String value) throws Exception {
62
62
})
63
63
.output (new DiscardingOutputFormat <String >());
64
64
Plan plan = env .createProgramPlan ();
65
- testForName ("Filter at testDefaultName(NamesTest.java:55 )" , plan );
65
+ testForName ("Filter at testDefaultName(NamesTest.java:54 )" , plan );
66
66
}
67
67
68
68
@ Test
@@ -117,7 +117,8 @@ public void join(
117
117
public boolean preVisit (Operator <?> visitable ) {
118
118
if (visitable instanceof InnerJoinOperatorBase ) {
119
119
Assert .assertEquals (
120
- "Join at testJoinWith(NamesTest.java:93)" , visitable .getName ());
120
+ "Join at testJoinWith(NamesTest.java:101)" ,
121
+ visitable .getName ());
121
122
}
122
123
return true ;
123
124
}
Original file line number Diff line number Diff line change @@ -95,7 +95,7 @@ public void testJarSubmission() throws Exception {
95
95
final JobPlanInfo planResponse = showPlan (planHandler , storedJarName , restfulGateway );
96
96
// we're only interested in the core functionality so checking for a small detail is
97
97
// sufficient
98
- Assert .assertThat (planResponse .getJsonPlan (), containsString ("TestProgram.java:30 " ));
98
+ Assert .assertThat (planResponse .getJsonPlan (), containsString ("TestProgram.java:28 " ));
99
99
100
100
runJar (runHandler , storedJarName , restfulGateway );
101
101
You can’t perform that action at this time.
0 commit comments