pnowojski commented on a change in pull request #9426: [FLINK-12958] Integrate
AsyncWaitOperator with mailbox (preserving compatibility with legacy sources)
URL: https://github.com/apache/flink/pull/9426#discussion_r314198520
##########
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java
##########
@@ -111,8 +111,8 @@
protected StreamTestSingleInputGate[] inputGates;
public StreamTaskTestHarness(
- Function<Environment, ? extends StreamTask<OUT, ?>>
taskFactory,
- TypeInformation<OUT> outputType) {
+ Function<Environment, ? extends StreamTask<OUT, ?>> taskFactory,
Review comment:
Could you revert the whitespace changes? They are questionable for me and
even if we want them, they shouldn't be part of the same commit.
----------------------------------------------------------------
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
