[GitHub] [flink] kl0u commented on a change in pull request #13576: [FLINK-19512] Introduce the new sink API

2020-10-12 Thread GitBox
kl0u commented on a change in pull request #13576: URL: https://github.com/apache/flink/pull/13576#discussion_r503149402 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/Committer.java ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] kl0u commented on a change in pull request #13576: [FLINK-19512] Introduce the new sink API

2020-10-13 Thread GitBox
kl0u commented on a change in pull request #13576: URL: https://github.com/apache/flink/pull/13576#discussion_r503729631 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/Committer.java ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] kl0u commented on a change in pull request #13576: [FLINK-19512] Introduce the new sink API

2020-10-13 Thread GitBox
kl0u commented on a change in pull request #13576: URL: https://github.com/apache/flink/pull/13576#discussion_r503729631 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/Committer.java ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software Founda