svn commit: r1567730 - /pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java

[mw...@apache.org]

Author: mwagner
Date: Wed Feb 12 19:28:23 2014
New Revision: 1567730

URL: http://svn.apache.org/r1567730
Log:
PIG-3762: Propagate user properties to edge and vertex configurations

Modified:
    pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java

Modified: pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java?rev=1567730&r1=1567729&r2=1567730&view=diff
==============================================================================
--- pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java (original)
+++ pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java Wed Feb 12 19:28:23 2014
@@ -182,7 +182,7 @@ public class TezDagBuilder extends TezOp
         InputDescriptor in = new InputDescriptor(edge.inputClassName);
         OutputDescriptor out = new OutputDescriptor(edge.outputClassName);
 
-        Configuration conf = new Configuration(false);
+        Configuration conf = ConfigurationUtil.toConfiguration(pc.getProperties(), false);
         if (!combinePlan.isEmpty()) {
             addCombiner(combinePlan, to, conf);
         }
@@ -293,7 +293,7 @@ public class TezDagBuilder extends TezOp
 
         // We won't actually use this job, but we need it to talk with the Load Store funcs
         @SuppressWarnings("deprecation")
-        Job job = new Job();
+        Job job = new Job(ConfigurationUtil.toConfiguration(pc.getProperties(), false));
 
         // Pass physical plans to vertex as user payload.
         Configuration payloadConf = job.getConfiguration();