You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ss...@apache.org on 2015/09/12 00:09:46 UTC
hive git commit: HIVE-11805. LLAP: TaskCommunicator should not
register MultiMRInput Inputs for state updates. (Siddharth Seth)
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) {