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 ;
@@ -749,6 +750,7 @@ private ObKVParams buildOBKVParams(final Scan scan) {
749
750
obHBaseParams .setCallTimeout (scannerTimeout );
750
751
obHBaseParams .setCacheBlock (scan .isGetScan ());
751
752
obHBaseParams .setAllowPartialResults (scan .getAllowPartialResults ());
753
+ obHBaseParams .setHbaseVersion (VersionInfo .getVersion ());
752
754
}
753
755
obKVParams .setObParamsBase (obHBaseParams );
754
756
return obKVParams ;
@@ -759,6 +761,7 @@ private ObKVParams buildOBKVParams(final Get get) {
759
761
ObHBaseParams obHBaseParams = new ObHBaseParams ();
760
762
obHBaseParams .setCheckExistenceOnly (get .isCheckExistenceOnly ());
761
763
obHBaseParams .setCacheBlock (get .getCacheBlocks ());
764
+ obHBaseParams .setHbaseVersion (VersionInfo .getVersion ());
762
765
obKVParams .setObParamsBase (obHBaseParams );
763
766
return obKVParams ;
764
767
}
You can’t perform that action at this time.
0 commit comments