From f8ab9ac8abb80bccd70ad44719838da08e0dd9eb Mon Sep 17 00:00:00 2001 From: JackShi148 Date: Thu, 25 Dec 2025 14:54:36 +0800 Subject: [PATCH] fix distributed execution version control --- .../rpc/bolt/transport/ObTableConnection.java | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java b/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java index eecb9f9d..3ee7d28b 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java +++ b/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java @@ -406,11 +406,20 @@ private String logMessage(String traceId, String methodName, String endpoint, lo return stringBuilder.toString(); } + // for server version, only ObServer 441 and above can support distributed execution + // for ODP version, only ODP 436 and above can support distributed execution + // so here we have to check both ObServer and ODP version to ensure the capability of distributed execution is supported or not private boolean isAllowDistributeCapability() { if (isOdpMode) { - return ObGlobal.OB_PROXY_VERSION >= ObGlobal.OB_PROXY_VERSION_4_3_6_0; - } else { + if (ObGlobal.OB_VERSION >= ObGlobal.OB_VERSION_4_4_1_0) { + return ObGlobal.OB_PROXY_VERSION >= ObGlobal.OB_PROXY_VERSION_4_3_6_0; + } else { + return false; + } + } else if (ObGlobal.OB_VERSION >= ObGlobal.OB_VERSION_4_4_1_0) { return true; + } else { + return false; } } }