subject:"\[GitHub\] \[flink\] JackWangCS commented on a change in pull request #17245\: \[FLINK\-23316\]\[Table SQL\/Ecosystem\] Add tests for custom PartitionCommitPolicy"

[GitHub] [flink] JackWangCS commented on a change in pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

2021-09-24 Thread GitBox

JackWangCS commented on a change in pull request #17245: URL: https://github.com/apache/flink/pull/17245#discussion_r715516784 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java ## @@ -441,6 +470,93 @@

[GitHub] [flink] JackWangCS commented on a change in pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

2021-09-21 Thread GitBox

JackWangCS commented on a change in pull request #17245: URL: https://github.com/apache/flink/pull/17245#discussion_r713104035 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/CustomCommitPolicy.java ## @@ -0,0 +1,41 @@ +/* +