[GitHub] flink pull request #4649: [FLINK-6116] Watermarks don't work when unioning w...

[pnowojski]

Github user pnowojski commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4649#discussion_r161793648
  
    --- Diff: 
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java
 ---
    @@ -143,7 +144,8 @@ protected void initializeInputs() throws IOException, 
InterruptedException {
                                                        2,
                                                        new 
LinkedList<String>(),
                                                        new 
BroadcastPartitioner<Object>(),
    -                                                   null /* output tag */);
    +                                                   null /* output tag */,
    +                                           1);
    --- End diff --
    
    nit: formatting


---