[GitHub] [flink] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r804523534 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -370,7 +411,17 @@ public DataInputSt

[GitHub] [flink] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r804520295 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -438,6 +499,11 @@ public void snapsh

[GitHub] [flink] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r804437340 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -529,4 +625,43 @@ public void forceS

[GitHub] [flink] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r804434912 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -529,4 +625,43 @@ public void forceS

[GitHub] [flink] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r804429303 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/source/CollectingDataOutput.java ## @@ -47,11 +47,16 @@ public

[GitHub] [flink] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r803735949 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java ## @@ -0,0 +1,155 @@ +/* +Lic

[GitHub] [flink] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r803680107 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java ## @@ -0,0 +1,155 @@ +/* +Lic