diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java index c074545..608c1ed 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java @@ -480,7 +480,7 @@ public PreWarmContext createPreWarmContext(TezSessionConfiguration sessionConfig prewarmProcDescriptor.setUserPayload(MRHelpers.createUserPayloadFromConf(conf)); PreWarmContext context = new PreWarmContext(prewarmProcDescriptor, MRHelpers.getMapResource(conf), - new VertexLocationHint(numContainers, null)); + numContainers, new VertexLocationHint(null)); Map combinedResources = new HashMap(); diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HivePreWarmProcessor.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HivePreWarmProcessor.java index 9785415..c756e72 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HivePreWarmProcessor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HivePreWarmProcessor.java @@ -70,6 +70,12 @@ public void run(Map inputs, /* container reuse */ return; } + for (LogicalInput input : inputs.values()) { + input.start(); + } + for (LogicalOutput output : outputs.values()) { + output.start(); + } /* these are things that goes through singleton initialization on most queries */ FileSystem fs = FileSystem.get(conf); Mac mac = Mac.getInstance("HmacSHA1"); diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java index 9c3284b..9be2aa2 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java @@ -124,6 +124,12 @@ public void run(Map inputs, Map out // (possibly asynchronously) LOG.info("Running map: " + processorContext.getUniqueIdentifier()); + for (LogicalInput input : inputs.values()) { + input.start(); + } + for (LogicalOutput output : outputs.values()) { + output.start(); + } Map outMap = new HashMap();