Skip to content

fix(sink): fix sink_decouple = false and commit_checkpoint_interval defalut = 1; #33846

fix(sink): fix sink_decouple = false and commit_checkpoint_interval defalut = 1;

fix(sink): fix sink_decouple = false and commit_checkpoint_interval defalut = 1; #33846