Skip to content

Commit 0fad98a

Browse files
authored
PHOENIX-7580: ADDENDUM to fix compatibility with HBase 2.4 build
1 parent 8c26483 commit 0fad98a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

phoenix-core/src/it/java/org/apache/phoenix/end2end/salted/SaltedTableWithParallelStatsEnabledIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ private void assertRangeScanRowCntFromHBaseAndPhoenix(Connection conn, int expec
153153
for (int i = 0; i< saltBucketCount; i++) {
154154
rowKeyPrefix[0] = (byte) i;
155155
Scan scan = new Scan();
156-
scan.setStartStopRowForPrefixScan(rowKeyPrefix);
156+
scan.setRowPrefixFilter(rowKeyPrefix);
157157
try (ResultScanner scanner = hTable.getScanner(scan)) {
158158
while(scanner.next() != null) {
159159
rowCountFromHBase++;
@@ -266,7 +266,7 @@ private void triggerPhoenix7580(Connection conn, String tableName, int saltBucke
266266
Table hTable = conn.unwrap(PhoenixConnection.class)
267267
.getQueryServices().getTable(tableName.getBytes());
268268
Scan scan = new Scan();
269-
scan.setStartStopRowForPrefixScan(rowKeyPrefix);
269+
scan.setRowPrefixFilter(rowKeyPrefix);
270270
boolean pastFirstRow = false;
271271
try (ResultScanner scanner = hTable.getScanner(scan)) {
272272
Result r;

0 commit comments

Comments
 (0)