aljoscha closed pull request #7215: [hotfix][test][streaming] Fix invalid
testNotSideOutputXXX in WindowOperatorTest
URL: https://github.com/apache/flink/pull/7215
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
index 7a0cbaa1af6..5bc17782d9c 100644
---
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
+++
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
@@ -1944,7 +1944,7 @@ public void
testNotSideOutputDueToLatenessSessionWithLateness() throws Exception
new InternalSingleValueWindowFunction<>(new
ReducedSessionWindowFunction()),
EventTimeTrigger.create(),
lateness,
- null /* late data output tag */);
+ lateOutputTag /* late data output tag */);
OneInputStreamOperatorTestHarness<Tuple2<String, Integer>,
Tuple3<String, Long, Long>> testHarness =
createTestHarness(operator);
@@ -2043,7 +2043,7 @@ public void
testNotSideOutputDueToLatenessSessionWithHugeLatenessPurgingTrigger(
new InternalSingleValueWindowFunction<>(new
ReducedSessionWindowFunction()),
PurgingTrigger.of(EventTimeTrigger.create()),
lateness,
- null /* late data output tag */);
+ lateOutputTag /* late data output tag */);
OneInputStreamOperatorTestHarness<Tuple2<String, Integer>,
Tuple3<String, Long, Long>> testHarness =
createTestHarness(operator);
@@ -2132,7 +2132,7 @@ public void
testNotSideOutputDueToLatenessSessionWithHugeLateness() throws Excep
new InternalSingleValueWindowFunction<>(new
ReducedSessionWindowFunction()),
EventTimeTrigger.create(),
lateness,
- null /* late data output tag */);
+ lateOutputTag /* late data output tag */);
OneInputStreamOperatorTestHarness<Tuple2<String, Integer>,
Tuple3<String, Long, Long>> testHarness =
createTestHarness(operator);
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
