[fix][dingo-executor] fix issue pessimistic txn hanging when updating…

… table.
zhaoyuan2024 · Sep 26, 2024 · 185b6b1 · 185b6b1
1 parent 2767ee6
commit 185b6b1
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/dingo-exec/src/main/java/io/dingodb/exec/transaction/impl/PessimisticTransaction.java b/dingo-exec/src/main/java/io/dingodb/exec/transaction/impl/PessimisticTransaction.java
@@ -390,6 +390,7 @@ public boolean onePcStage() {
         //get primary key.
         cacheToObject = primaryLockTo();
         primaryKey = cacheToObject.getMutation().getKey();
+        mutations.add(cacheToObject.getMutation());
 	    partIdSet.add(cacheToObject.getPartId());
 
         while (transform.hasNext()) {
@@ -403,7 +404,9 @@ public boolean onePcStage() {
                 break;
             } else {
                 //build Mutaions.
-                mutations.add(TransactionCacheToMutation.localDatatoMutation(txnLocalData, TransactionType.PESSIMISTIC));
+                if(!Arrays.equals(txnLocalData.getKey(), primaryKey)) {
+                    mutations.add(TransactionCacheToMutation.localDatatoMutation(txnLocalData, TransactionType.PESSIMISTIC));
+                }
             }
         }