syncer: address comments

pingcap · Mar 9, 2020 · 1ddb439 · 1ddb439
1 parent 642050c
commit 1ddb439
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/syncer/syncer.go b/syncer/syncer.go
@@ -1770,7 +1770,7 @@ func (s *Syncer) handleQueryEvent(ev *replication.QueryEvent, ec eventContext) e
 		shardLockResolving.WithLabelValues(s.cfg.Name).Set(1) // block and wait DDL lock to be synced
 		s.tctx.L().Info("putted shard DDL info", zap.Stringer("info", shardInfo))
 
-		shardOp, err2 := s.pessimist.GetOperation(ec.tctx.Ctx, shardInfo, rev)
+		shardOp, err2 := s.pessimist.GetOperation(ec.tctx.Ctx, shardInfo, rev+1)
 		shardLockResolving.WithLabelValues(s.cfg.Name).Set(0)
 		if err2 != nil {
 			return err2