From dac29ddea82b01838d91a74dcac290c88309c33d Mon Sep 17 00:00:00 2001 From: cyh438514 Date: Wed, 20 Nov 2024 16:22:24 +0800 Subject: [PATCH] modify version control for direct-load partition --- .../protocol/v0/ObDirectLoadProtocolV0.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) 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 6bc9e0f4..ebaddfe7 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 @@ -30,6 +30,8 @@ public class ObDirectLoadProtocolV0 implements ObDirectLoadProtocol { public static final long OB_VERSION_4_3_2_0 = ObGlobal.calcVersion(4, (short) 3, (byte) 2, (byte) 0); + public static final long OB_VERSION_4_3_5_0 = ObGlobal.calcVersion(4, (short) 3, + (byte) 5, (byte) 0); private static final int PROTOCOL_VERSION = 0; private final ObDirectLoadLogger logger; @@ -63,12 +65,14 @@ public void checkIsSupported(ObDirectLoadStatement statement) throws ObDirectLoa + " is not supported, minimum version required is " + ObGlobal.getObVsnString(OB_VERSION_4_3_2_0)); } - } else if (statement.getPartitionNames().length > 0) { + } else if (obVersion < OB_VERSION_4_3_5_0 && statement.getPartitionNames().length > 0) { logger.warn("partition names in ob version " + ObGlobal.getObVsnString(obVersion) - + "is not supported"); + + "is not supported, minimum version required is " + + ObGlobal.getObVsnString(OB_VERSION_4_3_5_0)); throw new ObDirectLoadNotSupportedException("partition names in ob version " - + ObGlobal.getObVsnString(obVersion) - + " is not supported"); + + ObGlobal.getObVsnString(obVersion) + + " is not supported, minimum version required is " + + ObGlobal.getObVsnString(OB_VERSION_4_3_5_0)); } }