[phoenix] branch 5.1 updated: PHOENIX-6351 PhoenixMRJobUtil getActiveResourceManagerAddress logic fails on pseudodistributed cluster

[richardantal]

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

richardantal pushed a commit to branch 5.1
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/5.1 by this push:
     new efd7efc  PHOENIX-6351 PhoenixMRJobUtil getActiveResourceManagerAddress 
logic fails on pseudodistributed cluster
efd7efc is described below

commit efd7efc40a9c1c45f7c1de4e77d6ae7d759415a7
Author: Richard Antal <antal97rich...@gmail.com>
AuthorDate: Wed Apr 28 15:28:49 2021 +0200

    PHOENIX-6351 PhoenixMRJobUtil getActiveResourceManagerAddress logic fails 
on pseudodistributed cluster
    
    Change-Id: Id6c2382a6bac888c65900e8f0327d07c8a9e6fd0
---
 .../main/java/org/apache/phoenix/util/PhoenixMRJobUtil.java  | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/PhoenixMRJobUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/PhoenixMRJobUtil.java
index dc6a15a..1f15603 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/PhoenixMRJobUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/PhoenixMRJobUtil.java
@@ -91,13 +91,6 @@ public class PhoenixMRJobUtil {
     public static String getActiveResourceManagerAddress(Configuration config, 
String zkQuorum)
             throws IOException, InterruptedException, KeeperException,
             InvalidProtocolBufferException, ZooKeeperConnectionException {
-        // In case of yarn HA is NOT enabled
-        String resourceManager = PhoenixMRJobUtil.getRMWebAddress(config);
-
-        LOGGER.info("ResourceManagerAddress from config = " + resourceManager);
-        
if(!resourceManager.equals(YarnConfiguration.DEFAULT_RM_WEBAPP_ADDRESS)){
-            return resourceManager;
-        }
         // In case of yarn HA is enabled
         ZKWatcher zkw = null;
         ZooKeeper zk = null;
@@ -130,6 +123,11 @@ public class PhoenixMRJobUtil {
             if (zkw != null) zkw.close();
             if (zk != null) zk.close();
         }
+        // In case of yarn HA is NOT enabled
+        if (activeRMHost == null) {
+            activeRMHost = PhoenixMRJobUtil.getRMWebAddress(config);
+            LOGGER.info("ResourceManagerAddress from config = " + 
activeRMHost);
+        }
 
         return activeRMHost;
     }