[GitHub] [incubator-iceberg] openinx commented on a change in pull request #856: [WIP] Flink Iceberg sink

openinx commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396939914 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/sink/IcebergWriter.java ## @@ -0,0 +1,480 @@

[GitHub] [incubator-iceberg] openinx commented on a change in pull request #856: [WIP] Flink Iceberg sink

openinx commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r395991053 ## File path: build.gradle ## @@ -406,7 +407,91 @@ project(':iceberg-spark-runtime') { relocate

[GitHub] [incubator-iceberg] openinx commented on a change in pull request #856: [WIP] Flink Iceberg sink

openinx commented on a change in pull request #856: [WIP] Flink Iceberg sink URL: https://github.com/apache/incubator-iceberg/pull/856#discussion_r396927858 ## File path: flink/src/main/java/org/apache/iceberg/flink/connector/sink/IcebergCommitter.java ## @@ -0,0 +1,693