pnowojski commented on a change in pull request #11467:
[FLINK-16317][operators] Provide support for watermarks, key selector and
latency marker in MultipleInputStreamOperator
URL: https://github.com/apache/flink/pull/11467#discussion_r397129466
##########
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTaskTest.java
##########
@@ -385,12 +386,12 @@ public void testInputFairness() throws Exception {
@Test
public void testWatermarkAndStreamStatusForwarding() throws Exception {
try (StreamTaskMailboxTestHarness<String> testHarness =
- new
MultipleInputStreamTaskTestHarnessBuilder<>(MultipleInputStreamTask::new,
BasicTypeInfo.STRING_TYPE_INFO)
Review comment:
Ops, you are right. It should have been squashed with something else. It can
not be in the master, as the check style would fail the build.
Fixed, previous commit in this PR was introducing this change.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to 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
