|
28 | 28 |
|
29 | 29 | public class ObDirectLoadProtocolV0 implements ObDirectLoadProtocol { |
30 | 30 |
|
31 | | - public static final long OB_VERSION_4_2_5_4 = ObGlobal.calcVersion(4, (short) 2, |
32 | | - (byte) 5, (byte) 4); |
| 31 | + public static final long OB_VERSION_4_2_5_3 = ObGlobal.calcVersion(4, (short) 2, |
| 32 | + (byte) 5, (byte) 3); |
33 | 33 | public static final long OB_VERSION_4_3_0_0 = ObGlobal.calcVersion(4, (short) 3, |
34 | 34 | (byte) 0, (byte) 0); |
35 | 35 |
|
@@ -115,14 +115,14 @@ public ObDirectLoadHeartBeatRpc getHeartBeatRpc(ObDirectLoadTraceId traceId) { |
115 | 115 | public ObDirectLoadDetachRpc getDetachRpc(ObDirectLoadTraceId traceId) |
116 | 116 | throws ObDirectLoadException { |
117 | 117 | if (obVersion < OB_VERSION_4_3_0_0) { |
118 | | - if (obVersion < OB_VERSION_4_2_5_4) { |
| 118 | + if (obVersion < OB_VERSION_4_2_5_3) { |
119 | 119 | logger.warn("detach in ob version " + ObGlobal.getObVsnString(obVersion) |
120 | 120 | + "is not supported, minimum version required is " |
121 | | - + ObGlobal.getObVsnString(OB_VERSION_4_2_5_4)); |
| 121 | + + ObGlobal.getObVsnString(OB_VERSION_4_2_5_3)); |
122 | 122 | throw new ObDirectLoadNotSupportedException( |
123 | 123 | "detach in ob version " + ObGlobal.getObVsnString(obVersion) |
124 | 124 | + " is not supported, minimum version required is " |
125 | | - + ObGlobal.getObVsnString(OB_VERSION_4_2_5_4)); |
| 125 | + + ObGlobal.getObVsnString(OB_VERSION_4_2_5_3)); |
126 | 126 | } |
127 | 127 | } else { |
128 | 128 | logger.warn("detach in ob version " + ObGlobal.getObVsnString(obVersion) |
|
0 commit comments