Repository: hive Updated Branches: refs/heads/llap d6739a6b6 -> f820d6591
HIVE-11805. LLAP: TaskCommunicator should not register MultiMRInput Inputs for state updates. (Siddharth Seth) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f820d659 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f820d659 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f820d659 Branch: refs/heads/llap Commit: f820d6591b75fb32a39cfa75375d6bfa762e9119 Parents: d6739a6 Author: Siddharth Seth <ss...@apache.org> Authored: Fri Sep 11 15:09:12 2015 -0700 Committer: Siddharth Seth <ss...@apache.org> Committed: Fri Sep 11 15:09:12 2015 -0700 ---------------------------------------------------------------------- .../hadoop/hive/llap/tezplugins/helpers/SourceStateTracker.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/f820d659/llap-server/src/java/org/apache/hadoop/hive/llap/tezplugins/helpers/SourceStateTracker.java ---------------------------------------------------------------------- diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/tezplugins/helpers/SourceStateTracker.java b/llap-server/src/java/org/apache/hadoop/hive/llap/tezplugins/helpers/SourceStateTracker.java index 40b317d..5428305 100644 --- a/llap-server/src/java/org/apache/hadoop/hive/llap/tezplugins/helpers/SourceStateTracker.java +++ b/llap-server/src/java/org/apache/hadoop/hive/llap/tezplugins/helpers/SourceStateTracker.java @@ -33,7 +33,9 @@ import org.apache.hadoop.hive.llap.tezplugins.Converters; import org.apache.hadoop.hive.llap.tezplugins.LlapTaskCommunicator; import org.apache.tez.dag.api.TaskCommunicatorContext; import org.apache.tez.dag.api.event.VertexState; +import org.apache.tez.mapreduce.input.MRInput; import org.apache.tez.mapreduce.input.MRInputLegacy; +import org.apache.tez.mapreduce.input.MultiMRInput; import org.apache.tez.runtime.api.impl.InputSpec; public class SourceStateTracker { @@ -274,7 +276,8 @@ public class SourceStateTracker { private boolean isSourceOfInterest(InputSpec inputSpec) { String inputClassName = inputSpec.getInputDescriptor().getClassName(); // MRInput is not of interest since it'll always be ready. - return !inputClassName.equals(MRInputLegacy.class.getName()); + return !(inputClassName.equals(MRInputLegacy.class.getName()) || inputClassName.equals( + MultiMRInput.class.getName()) || inputClassName.equals(MRInput.class.getName())); } void sendStateUpdateToNode(LlapNodeId nodeId, String sourceName, VertexState state) {