(shardingsphere) branch master updated: Add todo on cluster lock (#34133)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new d1872566832 Add todo on cluster lock (#34133)
d1872566832 is described below

commit d187256683203faea21028b6e74813267601fa3d
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Tue Dec 24 11:54:48 2024 +0800

    Add todo on cluster lock (#34133)
---
 .../proxy/backend/handler/distsql/ral/updatable/LockClusterExecutor.java | 1 +
 .../backend/handler/distsql/ral/updatable/UnlockClusterExecutor.java     | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterExecutor.java
 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterExecutor.java
index 73d2bb59f26..f490b58143a 100644
--- 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterExecutor.java
+++ 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/LockClusterExecutor.java
@@ -44,6 +44,7 @@ public final class LockClusterExecutor implements 
DistSQLUpdateExecutor<LockClus
         checkAlgorithm(sqlStatement);
         LockContext lockContext = 
contextManager.getComputeNodeInstanceContext().getLockContext();
         GlobalLockDefinition lockDefinition = new GlobalLockDefinition(new 
ClusterLock());
+        // TODO should configured in SQL Statement
         if (lockContext.tryLock(lockDefinition, 3000L)) {
             try {
                 checkState(contextManager);
diff --git 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterExecutor.java
 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterExecutor.java
index d9d28b883f8..9b744e64956 100644
--- 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterExecutor.java
+++ 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/UnlockClusterExecutor.java
@@ -39,6 +39,7 @@ public final class UnlockClusterExecutor implements 
DistSQLUpdateExecutor<Unlock
         checkState(contextManager);
         LockContext lockContext = 
contextManager.getComputeNodeInstanceContext().getLockContext();
         GlobalLockDefinition lockDefinition = new GlobalLockDefinition(new 
ClusterLock());
+        // TODO should configured in SQL Statement
         if (lockContext.tryLock(lockDefinition, 3000L)) {
             try {
                 checkState(contextManager);