yuzhaojing commented on a change in pull request #4463:
URL: https://github.com/apache/hudi/pull/4463#discussion_r776921074
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitSink.java
##
@@ -108,8 +124,15 @@ public void
yuzhaojing commented on a change in pull request #4463:
URL: https://github.com/apache/hudi/pull/4463#discussion_r776565278
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitSink.java
##
@@ -108,8 +124,15 @@ public void