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(
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(
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 {