[fix][dingo-executor] Fix resolve lock issue

githubgxll · guojn1 · commit 27d904ec7a00 · 2025-12-01T14:40:35.000+08:00
diff --git a/dingo-store-proxy/src/main/java/io/dingodb/store/utils/ResolveLockUtil.java b/dingo-store-proxy/src/main/java/io/dingodb/store/utils/ResolveLockUtil.java
@@ -222,6 +222,7 @@ public static TxnStatus getTxnStatus(long txnID, byte[] primaryKey, long current
                 LogUtils.warn(log, "startTs:{}, {} txnResult primaryLock is null ",
                     opts.getCallerStartTS(), opts.getFunName());
             } else if (primaryLock.isUseAsyncCommit() && !opts.isForceSyncCommit()) {
+                lockTtl = primaryLock.getLockTtl();
                 if (!TsoService.INSTANCE.IsExpired(lockTtl)) {
                     status.setTtl(lockTtl);
                 }

Original file line number	Diff line number	Diff line change
`@@ -222,6 +222,7 @@ public static TxnStatus getTxnStatus(long txnID, byte[] primaryKey, long current`
`222`	`222`	`LogUtils.warn(log, "startTs:{}, {} txnResult primaryLock is null ",`
`223`	`223`	`opts.getCallerStartTS(), opts.getFunName());`
`224`	`224`	`} else if (primaryLock.isUseAsyncCommit() && !opts.isForceSyncCommit()) {`
	`225`	`+ lockTtl = primaryLock.getLockTtl();`
`225`	`226`	`if (!TsoService.INSTANCE.IsExpired(lockTtl)) {`
`226`	`227`	`status.setTtl(lockTtl);`
`227`	`228`	`}`