Skip to content

Commit cb7df0a

Browse files
authored
add version check for distributed execute (#311)
1 parent 424a703 commit cb7df0a

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObGlobal.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -105,6 +105,10 @@ public static boolean isHBaseBatchSupport() {
105105
|| OB_VERSION >= OB_VERSION_4_3_5_0;
106106
}
107107

108+
public static boolean isDistributedExecSupport() {
109+
return OB_VERSION >= OB_VERSION_4_3_5_2;
110+
}
111+
108112
public static boolean isCellTTLSupport() {
109113
return OB_VERSION >= OB_VERSION_4_3_5_1;
110114
}
@@ -121,5 +125,7 @@ public static boolean isCellTTLSupport() {
121125

122126
public static final long OB_VERSION_4_3_5_1 = calcVersion(4, (short) 3, (byte) 5, (byte) 1);
123127

128+
public static final long OB_VERSION_4_3_5_2 = calcVersion(4, (short) 3, (byte) 5, (byte) 2);
129+
124130
public static long OB_VERSION = calcVersion(0, (short) 0, (byte) 0, (byte) 0);
125131
}

src/main/java/com/alipay/oceanbase/rpc/table/ObTableServerCapacity.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,8 @@
1717

1818
package com.alipay.oceanbase.rpc.table;
1919

20+
import com.alipay.oceanbase.rpc.ObGlobal;
21+
2022
public class ObTableServerCapacity {
2123
private static final int DISTRIBUTED_EXECUTE = 1 << 0;
2224
private static final int CAPACITY_MAX = 1 << 31;
@@ -31,6 +33,6 @@ public void setFlags(int flags) {
3133
}
3234

3335
public boolean isSupportDistributedExecute() {
34-
return (flags & DISTRIBUTED_EXECUTE) != 0;
36+
return (flags & DISTRIBUTED_EXECUTE) != 0 && ObGlobal.isDistributedExecSupport();
3537
}
3638
}

0 commit comments

Comments
 (0)