address comments

pingcap · Jul 1, 2022 · bc03cb1 · bc03cb1
1 parent eaaa7ab
commit bc03cb1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/sink/flowcontrol/flow_control.go b/cdc/sink/flowcontrol/flow_control.go
@@ -101,7 +101,7 @@ func (c *TableFlowController) Consume(
 	commitTs := msg.CRTs
 	lastCommitTs := atomic.LoadUint64(&c.lastCommitTs)
 	blockingCallBack := func() (err error) {
-		if commitTs != lastCommitTs || c.splitTxn {
+		if commitTs > lastCommitTs || c.splitTxn {
 			// Call `callback` in two condition:
 			// 1. commitTs > lastCommitTs, handle new txn and send a normal resolved ts
 			// 2. commitTs == lastCommitTs && splitTxn = true, split the same txn and