flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pnowojski <...@git.apache.org>
Subject [GitHub] flink pull request #4649: [FLINK-6116] Watermarks don't work when unioning w...
Date Tue, 16 Jan 2018 15:54:55 GMT
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


---

Mime
View raw message