This is an automated email from the ASF dual-hosted git repository.
virajjasani pushed a commit to branch 5.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/5.3 by this push:
new 2794bbb3e7 PHOENIX-8016 Use index timestamp for uncovered stale-entry
cleanup (ADDENDUM)
2794bbb3e7 is described below
commit 2794bbb3e7ab4029eda8b9a0715b2fea847fde68
Author: Viraj Jasani <[email protected]>
AuthorDate: Fri Oct 16 10:59:57 2026 -0700
PHOENIX-8016 Use index timestamp for uncovered stale-entry cleanup
(ADDENDUM)
---
.../end2end/index/UncoveredGlobalIndexRegionScannerIT.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/UncoveredGlobalIndexRegionScannerIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/UncoveredGlobalIndexRegionScannerIT.java
index fb8f6f9de5..f3c8503457 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/UncoveredGlobalIndexRegionScannerIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/UncoveredGlobalIndexRegionScannerIT.java
@@ -53,10 +53,12 @@ import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.coprocessor.ObserverContext;
import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;
import org.apache.hadoop.hbase.coprocessor.SimpleRegionObserver;
+import org.apache.phoenix.compile.ExplainPlanAttributes;
import org.apache.phoenix.end2end.NeedsOwnMiniClusterTest;
import org.apache.phoenix.exception.PhoenixParserException;
import org.apache.phoenix.filter.SkipScanFilter;
import org.apache.phoenix.hbase.index.IndexRegionObserver;
+import org.apache.phoenix.jdbc.PhoenixPreparedStatement;
import org.apache.phoenix.query.BaseTest;
import org.apache.phoenix.query.KeyRange;
import org.apache.phoenix.query.QueryServices;
@@ -947,7 +949,11 @@ public class UncoveredGlobalIndexRegionScannerIT extends
BaseTest {
Fixture fixture = createFixture(conn, clock, oldEntries ?
AGE_THRESHOLD_MS * 2 : 1000);
// No LIMIT: isolate cleanup from premature scan termination in
PHOENIX-8015.
String query = fixture.indexQuery("");
- assertPlan(conn, query).table(fixture.indexTable).scanType("FULL
SCAN");
+ ExplainPlanAttributes plan =
+
conn.prepareStatement(query).unwrap(PhoenixPreparedStatement.class).optimizeQuery()
+ .getExplainPlan().getPlanStepsAsAttributes();
+ assertEquals(fixture.indexTable, plan.getTableName());
+ assertEquals("FULL SCAN ", plan.getExplainScanType());
assertRows(conn, query, ROW_COUNT);
if (oldEntries) {
try (Table index =