This is an automated email from the ASF dual-hosted git repository. kunni pushed a change to branch FLINK-38206 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
from 22d96aebd Fix exception when job restarted from state.
add 90020ad21 Fix test failure in batch mode.
No new revisions were added by this update.
Summary of changes:
.../sink/v2/bucket/BucketAssignOperator.java | 23 ++++++++++++++++------
1 file changed, 17 insertions(+), 6 deletions(-)
