Skip to content

Commit 50af7ab

Browse files
committed
fix
1 parent 687a2cb commit 50af7ab

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1927,7 +1927,9 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
19271927
obTableQuery.setIndexName("PRIMARY");
19281928
obTableQuery.sethTableFilter(filter);
19291929
obTableQuery.addKeyRange(obNewRange);
1930-
obTableQuery.setScanRangeColumns("K", "Q", "T");
1930+
if (obTableClient.isOdpMode()) {
1931+
obTableQuery.setScanRangeColumns("K", "Q", "T");
1932+
}
19311933
return obTableQuery;
19321934
}
19331935

@@ -1954,7 +1956,9 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, final Scan scan) {
19541956
: configuration.getLong(HConstants.HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE_KEY,
19551957
HConstants.DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE));
19561958
obTableQuery.setObKVParams(buildOBKVParams(scan));
1957-
obTableQuery.setScanRangeColumns("K", "Q", "T");
1959+
if (obTableClient.isOdpMode()) {
1960+
obTableQuery.setScanRangeColumns("K", "Q", "T");
1961+
}
19581962
return obTableQuery;
19591963
}
19601964

@@ -1980,7 +1984,9 @@ private ObTableQuery buildObTableQuery(final Get get, Collection<byte[]> columnQ
19801984
get.getTimeRange());
19811985
}
19821986
obTableQuery.setObKVParams(buildOBKVParams(get));
1983-
obTableQuery.setScanRangeColumns("K", "Q", "T");
1987+
if (obTableClient.isOdpMode()) {
1988+
obTableQuery.setScanRangeColumns("K", "Q", "T");
1989+
}
19841990
return obTableQuery;
19851991
}
19861992

0 commit comments

Comments
 (0)