(phoenix) branch PHOENIX-7562-feature-new updated: PHOENIX-7920 addendum Fix compilation errors

[tkhurana]

This is an automated email from the ASF dual-hosted git repository.

tkhurana pushed a commit to branch PHOENIX-7562-feature-new
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/PHOENIX-7562-feature-new by 
this push:
     new 875046b066 PHOENIX-7920 addendum Fix compilation errors
875046b066 is described below

commit 875046b066ea958bf4272452c2f63259910f87b4
Author: tkhurana <khurana.ta...@gmail.com>
AuthorDate: Fri Aug 7 14:18:53 2026 -0700

    PHOENIX-7920 addendum Fix compilation errors
---
 .../src/it/java/org/apache/phoenix/jdbc/HAGroupStoreManagerIT.java     | 2 +-
 .../it/java/org/apache/phoenix/replication/ReplicationLogGroupIT.java  | 3 ++-
 .../apache/phoenix/replication/reader/StoreAndForwardFailoverIT.java   | 2 +-
 3 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/jdbc/HAGroupStoreManagerIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/jdbc/HAGroupStoreManagerIT.java
index 183d538e0f..18e83aa9d5 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/jdbc/HAGroupStoreManagerIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/jdbc/HAGroupStoreManagerIT.java
@@ -701,7 +701,7 @@ public class HAGroupStoreManagerIT extends HABaseIT {
 
       HRegionServer regionServer = 
CLUSTERS.getHBaseCluster1().getHBaseCluster().getRegionServer(0);
       replicationLogGroup = ReplicationLogGroup.get(cluster1Conf, 
regionServer.getServerName(),
-        haGroupName, cluster1HAManager);
+        haGroupName, cluster1HAManager).get();
       replicationLogReplay = ReplicationLogReplay.get(cluster2Conf, 
haGroupName);
       replicationLogReplay.startReplay();
 
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/replication/ReplicationLogGroupIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/replication/ReplicationLogGroupIT.java
index 525ebb400a..f926fd70c6 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/replication/ReplicationLogGroupIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/replication/ReplicationLogGroupIT.java
@@ -21,6 +21,7 @@ import static 
org.apache.phoenix.hbase.index.IndexRegionObserver.PHOENIX_INDEX_C
 import static 
org.apache.phoenix.jdbc.PhoenixDatabaseMetaData.SYSTEM_CATALOG_NAME;
 import static 
org.apache.phoenix.jdbc.PhoenixDatabaseMetaData.SYSTEM_CHILD_LINK_NAME;
 import static org.apache.phoenix.query.BaseTest.generateUniqueName;
+import static 
org.apache.phoenix.replication.CrossClusterReplicationTestUtil.findLogFiles;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotNull;
@@ -1021,7 +1022,7 @@ public class ReplicationLogGroupIT extends 
ReplicationLogGroupBaseIT {
 
     // Replay the replication log on cluster 2
     FileSystem fs = standByLogDir.getFileSystem(conf2);
-    List<Path> logFiles = 
CrossClusterReplicationTestUtil.findLogFiles(standByLogDir, fs);
+    List<Path> logFiles = findLogFiles(standByLogDir, fs);
     LOG.info("Found {} log files to replay", logFiles.size());
     assertTrue("Should have at least one log file", logFiles.size() > 0);
 
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/replication/reader/StoreAndForwardFailoverIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/replication/reader/StoreAndForwardFailoverIT.java
index b03a018f6d..1e45d29ae0 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/replication/reader/StoreAndForwardFailoverIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/replication/reader/StoreAndForwardFailoverIT.java
@@ -127,7 +127,7 @@ public class StoreAndForwardFailoverIT extends HABaseIT {
     // The live Cluster1 writer (RS0). Same singleton the RS write path uses, 
so flipping its mode
     // affects real writes. Cluster1 is ACTIVE_IN_SYNC => this starts in SYNC 
mode.
     HRegionServer rs = 
CLUSTERS.getHBaseCluster1().getHBaseCluster().getRegionServer(0);
-    logGroup = ReplicationLogGroup.get(conf1, rs.getServerName(), haGroupName);
+    logGroup = ReplicationLogGroup.get(conf1, rs.getServerName(), 
haGroupName).get();
 
     // Replicated table (REPLICATION_SCOPE=1 + LOCAL INDEX) on BOTH clusters.
     tableName = "T_" + generateUniqueName();