diff --git a/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartInsertOperator.java b/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartInsertOperator.java
index 3b8f4e4de8..4256bc51b1 100644
--- a/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartInsertOperator.java
+++ b/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartInsertOperator.java
@@ -280,7 +280,7 @@ protected boolean pushTuple(Context context, Object[] tuple, Vertex vertex) {
                     }
                     StoreInstance kvStore = Services.KV_STORE.getInstance(tableId, partId);
                     KeyValue kvKeyValue = kvStore.txnGet(
-                        TsoService.getDefault().tso(),
+                        txnId.seq,
                         originalKey,
                         param.getLockTimeOut()
                     );