[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425628267 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java ## @@ -0,0 +1,388 @@ +/* +

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425160259 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java ## @@ -0,0 +1,381 @@ +/* +

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425106208 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectCoordinationRequest.java ## @@ -0,0 +1,65 @@

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r424884103 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java ## @@ -0,0

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r424883424 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java ## @@ -0,0

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r424883039 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java ## @@ -0,0

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r424882491 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java ## @@ -162,9 +174,28 @@ public

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r424882572 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java ## @@ -0,0

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r424837349 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java ## @@ -162,9 +174,28 @@ public