danny0405 commented on code in PR #7412:
URL: https://github.com/apache/hudi/pull/7412#discussion_r1043976402
##
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java:
##
@@ -312,8 +321,8 @@ private Iterator
readRecordsForGroupWi
danny0405 commented on code in PR #7412:
URL: https://github.com/apache/hudi/pull/7412#discussion_r1043975952
##
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseMergeHelper.java:
##
@@ -54,12 +55,15 @@ public abstract class BaseMergeHelper {