You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@tez.apache.org by "Eric Wohlstadter (JIRA)" <ji...@apache.org> on 2017/12/05 18:49:00 UTC

[jira] [Created] (TEZ-3874) NPE in TezClientUtils when "yarn.resourcemanager.zk-address" is present in Configuration

Eric Wohlstadter created TEZ-3874:
-------------------------------------

             Summary: NPE in TezClientUtils when "yarn.resourcemanager.zk-address" is present in Configuration
                 Key: TEZ-3874
                 URL: https://issues.apache.org/jira/browse/TEZ-3874
             Project: Apache Tez
          Issue Type: Bug
    Affects Versions: 0.9.1
            Reporter: Eric Wohlstadter
            Priority: Blocker


"yarn.resourcemanager.zk-address" is deprecated in favor of "hadoop.zk.address" for Hadoop 2.9+.

Configuration base class does't auto-translate the deprecation. Only YarnConfiguration applies the translation.

In TezClientUtils.createFinalConfProtoForApp, a NPE is throw if "yarn.resourcemanager.zk-address" is present in the Configuration.

{code}
for (Entry<String, String> entry : amConf) {
      PlanKeyValuePair.Builder kvp = PlanKeyValuePair.newBuilder();
      kvp.setKey(entry.getKey());
      kvp.setValue(amConf.get(entry.getKey()));
      builder.addConfKeyValues(kvp);
    }
{code}

Even though Tez is not specifically looking for the deprecated property, {{amConf.get(entry.getKey())}} will find it during the iteration, if it is in any of the merged xml property resources. 

{{amConf.get(entry.getKey())}} will return null, and {{kvp.setValue(null)}} will trigger NPE.

Suggested solution is to change to: 
{code}
YarnConfiguration wrappedConf = new YarnConfiguration(amConf);
for (Entry<String, String> entry : wrappedConf) {
      PlanKeyValuePair.Builder kvp = PlanKeyValuePair.newBuilder();
      kvp.setKey(entry.getKey());
      kvp.setValue(wrappedConf.get(entry.getKey()));
      builder.addConfKeyValues(kvp);
    }
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)