[GitHub] [flink] curcur commented on a change in pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

curcur commented on a change in pull request #15636: URL: https://github.com/apache/flink/pull/15636#discussion_r615969104 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkFunction.java ## @@ -224,11 +224,11 @@

[GitHub] [flink] curcur commented on a change in pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

curcur commented on a change in pull request #15636: URL: https://github.com/apache/flink/pull/15636#discussion_r615913550 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaFacadeImpl.java ## @@ -115,10 +116,6 @@ public

[GitHub] [flink] curcur commented on a change in pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

curcur commented on a change in pull request #15636: URL: https://github.com/apache/flink/pull/15636#discussion_r615231118 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaFacadePoolingImpl.java ## @@ -0,0 +1,183 @@ +/* +