You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ap...@apache.org on 2025/05/29 18:55:51 UTC
(phoenix) 03/30: PHOENIX-7580: ADDENDUM to fix compatibility with HBase 2.4 build
This is an automated email from the ASF dual-hosted git repository.
apurtell pushed a commit to branch PHOENIX-7562-feature
in repository https://gitbox.apache.org/repos/asf/phoenix.git
commit 45495ef877021ce17f74c768a24617d1cc91fc9a
Author: sanjeet006py <36...@users.noreply.github.com>
AuthorDate: Thu Apr 17 11:39:01 2025 +0530
PHOENIX-7580: ADDENDUM to fix compatibility with HBase 2.4 build
---
.../phoenix/end2end/salted/SaltedTableWithParallelStatsEnabledIT.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/salted/SaltedTableWithParallelStatsEnabledIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/salted/SaltedTableWithParallelStatsEnabledIT.java
index d3ec01b210..d5149554ad 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/salted/SaltedTableWithParallelStatsEnabledIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/salted/SaltedTableWithParallelStatsEnabledIT.java
@@ -153,7 +153,7 @@ public class SaltedTableWithParallelStatsEnabledIT extends ParallelStatsEnabledI
for (int i = 0; i< saltBucketCount; i++) {
rowKeyPrefix[0] = (byte) i;
Scan scan = new Scan();
- scan.setStartStopRowForPrefixScan(rowKeyPrefix);
+ scan.setRowPrefixFilter(rowKeyPrefix);
try (ResultScanner scanner = hTable.getScanner(scan)) {
while(scanner.next() != null) {
rowCountFromHBase++;
@@ -266,7 +266,7 @@ public class SaltedTableWithParallelStatsEnabledIT extends ParallelStatsEnabledI
Table hTable = conn.unwrap(PhoenixConnection.class)
.getQueryServices().getTable(tableName.getBytes());
Scan scan = new Scan();
- scan.setStartStopRowForPrefixScan(rowKeyPrefix);
+ scan.setRowPrefixFilter(rowKeyPrefix);
boolean pastFirstRow = false;
try (ResultScanner scanner = hTable.getScanner(scan)) {
Result r;