File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
src/main/java/com/alipay/oceanbase/hbase Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change 54
54
import org .apache .hadoop .hbase .ipc .CoprocessorRpcChannel ;
55
55
import org .apache .hadoop .hbase .util .Bytes ;
56
56
import org .apache .hadoop .hbase .util .Pair ;
57
+ import org .apache .hadoop .hbase .util .VersionInfo ;
57
58
import org .slf4j .Logger ;
58
59
59
60
import java .io .ByteArrayOutputStream ;
@@ -1089,6 +1090,7 @@ private ObKVParams buildOBKVParams(final Scan scan) {
1089
1090
obHBaseParams .setCallTimeout (scannerTimeout );
1090
1091
obHBaseParams .setCacheBlock (scan .isGetScan ());
1091
1092
obHBaseParams .setAllowPartialResults (scan .getAllowPartialResults ());
1093
+ obHBaseParams .setHbaseVersion (VersionInfo .getVersion ());
1092
1094
}
1093
1095
obKVParams .setObParamsBase (obHBaseParams );
1094
1096
return obKVParams ;
@@ -1099,6 +1101,7 @@ private ObKVParams buildOBKVParams(final Get get) {
1099
1101
ObHBaseParams obHBaseParams = new ObHBaseParams ();
1100
1102
obHBaseParams .setCheckExistenceOnly (get .isCheckExistenceOnly ());
1101
1103
obHBaseParams .setCacheBlock (get .getCacheBlocks ());
1104
+ obHBaseParams .setHbaseVersion (VersionInfo .getVersion ());
1102
1105
obKVParams .setObParamsBase (obHBaseParams );
1103
1106
return obKVParams ;
1104
1107
}
You can’t perform that action at this time.
0 commit comments