danny0405 commented on a change in pull request #3304:
URL: https://github.com/apache/hudi/pull/3304#discussion_r828713714
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java
##
@@ -194,9 +194,10 @@ private void
danny0405 commented on a change in pull request #3304:
URL: https://github.com/apache/hudi/pull/3304#discussion_r672946328
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java
##
@@ -534,6 +544,12 @@ private void bufferRecord(HoodieRecord
danny0405 commented on a change in pull request #3304:
URL: https://github.com/apache/hudi/pull/3304#discussion_r672946328
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java
##
@@ -534,6 +544,12 @@ private void bufferRecord(HoodieRecord
danny0405 commented on a change in pull request #3304:
URL: https://github.com/apache/hudi/pull/3304#discussion_r672946328
##
File path:
hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java
##
@@ -534,6 +544,12 @@ private void bufferRecord(HoodieRecord