trushev commented on code in PR #7626:
URL: https://github.com/apache/hudi/pull/7626#discussion_r1072027683
##
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/BucketHandles.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
trushev commented on code in PR #7626:
URL: https://github.com/apache/hudi/pull/7626#discussion_r1071735088
##
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java:
##
@@ -94,7 +94,7 @@
* FileID to write handle mapping in order to re
trushev commented on code in PR #7626:
URL: https://github.com/apache/hudi/pull/7626#discussion_r1071735088
##
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java:
##
@@ -94,7 +94,7 @@
* FileID to write handle mapping in order to re
trushev commented on code in PR #7626:
URL: https://github.com/apache/hudi/pull/7626#discussion_r1067712881
##
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java:
##
@@ -94,7 +94,7 @@
* FileID to write handle mapping in order to re
trushev commented on code in PR #7626:
URL: https://github.com/apache/hudi/pull/7626#discussion_r1065499424
##
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java:
##
@@ -94,7 +94,7 @@
* FileID to write handle mapping in order to re
trushev commented on code in PR #7626:
URL: https://github.com/apache/hudi/pull/7626#discussion_r1065293780
##
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java:
##
@@ -449,6 +450,7 @@ private boolean flushBucket(DataBucket bucket) {
trushev commented on code in PR #7626:
URL: https://github.com/apache/hudi/pull/7626#discussion_r1065294170
##
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java:
##
@@ -94,7 +94,7 @@
* FileID to write handle mapping in order to re