[GitHub] [hudi] JerryYue-M commented on a diff in pull request #6100: [HUDI-4392]Flink MOR table compaction plan execution sequence should …

2022-07-14 Thread GitBox
JerryYue-M commented on code in PR #6100: URL: https://github.com/apache/hudi/pull/6100#discussion_r921787885 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java: ## @@ -502,6 +503,14 @@ private FlinkOptions() { .defaultValue(

[GitHub] [hudi] JerryYue-M commented on a diff in pull request #6100: [HUDI-4392]Flink MOR table compaction plan execution sequence should …

2022-07-13 Thread GitBox
JerryYue-M commented on code in PR #6100: URL: https://github.com/apache/hudi/pull/6100#discussion_r920723914 ## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java: ## @@ -502,6 +503,14 @@ private FlinkOptions() { .defaultValue(

[GitHub] [hudi] JerryYue-M commented on a diff in pull request #6100: [HUDI-4392]Flink MOR table compaction plan execution sequence should …

2022-07-13 Thread GitBox
JerryYue-M commented on code in PR #6100: URL: https://github.com/apache/hudi/pull/6100#discussion_r920713665 ## hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestCompactionUtil.java: ## @@ -149,6 +150,36 @@ void testScheduleCompaction() throws Exception {