[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-05 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551950784 ## File path: flink-tests/src/test/java/org/apache/flink/api/datastream/DataStreamBatchExecutionITCase.java ## @@ -180,6 +207,350 @@ public void batchSu

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-05 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551790684 ## File path: docs/dev/datastream_execution_mode.md ## @@ -1,8 +1,6 @@ --- title: "Execution Mode (Batch/Streaming)" -nav-id: datastream_execution_mode

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551441044 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/TwoInputTransformationTranslator.java ## @@ -46,7 +47,11

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551391876 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/TwoInputTransformationTranslator.java ## @@ -46,7 +47,11

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551357902 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java ## @@ -142,6 +148,7 @@ p

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551355062 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java ## @@ -142,6 +148,7 @@ p

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551300493 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java ## @@ -142,6 +148,7 @@ p

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551352025 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/AbstractBroadcastStateTransformation.java ## @@ -0,0 +1,

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551350742 ## File path: docs/dev/datastream_execution_mode.md ## @@ -237,6 +237,35 @@ next key. See [FLIP-140](https://cwiki.apache.org/confluence/x/kDh4CQ) for b

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551308750 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/TwoInputTransformationTranslator.java ## @@ -46,7 +47,11

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2021-01-04 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551228929 ## File path: docs/dev/datastream_execution_mode.md ## @@ -237,6 +237,35 @@ next key. See [FLIP-140](https://cwiki.apache.org/confluence/x/kDh4CQ) for b

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-10 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r540228829 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/TwoInputTransformationTranslator.java ## @@ -45,7 +46,11

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-10 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r540209912 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/TwoInputTransformationTranslator.java ## @@ -45,7 +46,11

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-10 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r540208666 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/MultiInputTransformationTranslator.java ## @@ -54,7 +55,

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-10 Thread GitBox
dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r539998701 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/MultiInputSortingDataInput.java ## @@ -315,23 +342,40 @@