diff --git a/sessionctx/binloginfo/binloginfo_test.go b/sessionctx/binloginfo/binloginfo_test.go
index 78cb30ada9..ca01fe0fc9 100644
--- a/sessionctx/binloginfo/binloginfo_test.go
+++ b/sessionctx/binloginfo/binloginfo_test.go
@@ -540,6 +540,19 @@ func (s *testBinlogSuite) TestPartitionedTable(c *C) {
 	}
 }
 
+func (s *testBinlogSuite) TestPessimisticLockThenCommit(c *C) {
+	tk := testkit.NewTestKit(c, s.store)
+	tk.MustExec("use test")
+	tk.Se.GetSessionVars().BinlogClient = s.client
+	tk.MustExec("drop table if exists t")
+	tk.MustExec("create table t(a int, b int)")
+	tk.MustExec("begin pessimistic")
+	tk.MustExec("insert into t select 1, 1")
+	tk.MustExec("commit")
+	prewriteVal := getLatestBinlogPrewriteValue(c, s.pump)
+	c.Assert(len(prewriteVal.Mutations), Equals, 1)
+}
+
 func (s *testBinlogSuite) TestDeleteSchema(c *C) {
 	tk := testkit.NewTestKit(c, s.store)
 	tk.MustExec("use test")
diff --git a/store/tikv/txn.go b/store/tikv/txn.go
index fb3e4d17b2..9f3698abf1 100644
--- a/store/tikv/txn.go
+++ b/store/tikv/txn.go
@@ -654,6 +654,9 @@ func (txn *KVTxn) GetSnapshot() *KVSnapshot {
 // SetBinlogExecutor sets the method to perform binlong synchronization.
 func (txn *KVTxn) SetBinlogExecutor(binlog BinlogExecutor) {
 	txn.binlog = binlog
+	if txn.committer != nil {
+		txn.committer.binlog = binlog
+	}
 }
 
 // GetClusterID returns store's cluster id.