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)

Reply via email to