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:
us...@infra.apache.org


With regards,
Apache Git Services

Reply via email to