Skip to content

Commit d524ae3

Browse files
authored
modify version control for direct-load partition (#236)
1 parent 684a44e commit d524ae3

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

src/main/java/com/alipay/oceanbase/rpc/direct_load/protocol/v0/ObDirectLoadProtocolV0.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,8 @@ public class ObDirectLoadProtocolV0 implements ObDirectLoadProtocol {
3030

3131
public static final long OB_VERSION_4_3_2_0 = ObGlobal.calcVersion(4, (short) 3,
3232
(byte) 2, (byte) 0);
33+
public static final long OB_VERSION_4_3_5_0 = ObGlobal.calcVersion(4, (short) 3,
34+
(byte) 5, (byte) 0);
3335

3436
private static final int PROTOCOL_VERSION = 0;
3537
private final ObDirectLoadLogger logger;
@@ -63,12 +65,14 @@ public void checkIsSupported(ObDirectLoadStatement statement) throws ObDirectLoa
6365
+ " is not supported, minimum version required is "
6466
+ ObGlobal.getObVsnString(OB_VERSION_4_3_2_0));
6567
}
66-
} else if (statement.getPartitionNames().length > 0) {
68+
} else if (obVersion < OB_VERSION_4_3_5_0 && statement.getPartitionNames().length > 0) {
6769
logger.warn("partition names in ob version " + ObGlobal.getObVsnString(obVersion)
68-
+ "is not supported");
70+
+ "is not supported, minimum version required is "
71+
+ ObGlobal.getObVsnString(OB_VERSION_4_3_5_0));
6972
throw new ObDirectLoadNotSupportedException("partition names in ob version "
70-
+ ObGlobal.getObVsnString(obVersion)
71-
+ " is not supported");
73+
+ ObGlobal.getObVsnString(obVersion)
74+
+ " is not supported, minimum version required is "
75+
+ ObGlobal.getObVsnString(OB_VERSION_4_3_5_0));
7276
}
7377
}
7478

0 commit comments

Comments
 (0)