From 0403c3059e901ac587e89abc2b412d244aa46c9c Mon Sep 17 00:00:00 2001 From: "suzhi.yt" Date: Wed, 10 Dec 2025 16:01:27 +0800 Subject: [PATCH] direct load detach task support 451 --- src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java | 2 ++ .../protocol/v0/ObDirectLoadProtocolV0.java | 12 +++++++----- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java b/src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java index f3773a31..a4d070a9 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java +++ b/src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java @@ -172,6 +172,8 @@ public static boolean isDistributeNeedTabletIdSupport() { public static final long OB_VERSION_4_5_0_0 = calcVersion(4, (short) 5, (byte) 0, (byte) 0); + public static final long OB_VERSION_4_5_1_0 = calcVersion(4, (short) 5, (byte) 1, (byte) 0); + public static long OB_VERSION = calcVersion(0, (short) 0, (byte) 0, (byte) 0); /*-------------------------------------------- OB_PROXY_VERSION --------------------------------------------*/ diff --git a/src/main/java/com/alipay/oceanbase/rpc/direct_load/protocol/v0/ObDirectLoadProtocolV0.java b/src/main/java/com/alipay/oceanbase/rpc/direct_load/protocol/v0/ObDirectLoadProtocolV0.java index 64fa33a6..2bd71458 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/direct_load/protocol/v0/ObDirectLoadProtocolV0.java +++ b/src/main/java/com/alipay/oceanbase/rpc/direct_load/protocol/v0/ObDirectLoadProtocolV0.java @@ -125,12 +125,14 @@ public ObDirectLoadDetachRpc getDetachRpc(ObDirectLoadTraceId traceId) + " is not supported, minimum version required is " + ObGlobal.getObVsnString(ObGlobal.OB_VERSION_4_4_2_0)); } - } else { + } else if (obVersion < ObGlobal.OB_VERSION_4_5_1_0) { logger.warn("detach in ob version " + ObGlobal.getObVsnString(obVersion) - + "is not supported"); - throw new ObDirectLoadNotSupportedException("detach in ob version " - + ObGlobal.getObVsnString(obVersion) - + " is not supported"); + + "is not supported, minimum version required is " + + ObGlobal.getObVsnString(ObGlobal.OB_VERSION_4_5_1_0)); + throw new ObDirectLoadNotSupportedException( + "detach in ob version " + ObGlobal.getObVsnString(obVersion) + + " is not supported, minimum version required is " + + ObGlobal.getObVsnString(ObGlobal.OB_VERSION_4_5_1_0)); } return new ObDirectLoadDetachRpcV0(traceId); }