You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sz...@apache.org on 2015/04/23 04:34:48 UTC
[39/44] hive git commit: HIVE-10209 - FetchTask with VC may fail
because ExecMapper.done is true (Chao)
HIVE-10209 - FetchTask with VC may fail because ExecMapper.done is true (Chao)
git-svn-id: https://svn.apache.org/repos/asf/hive/branches/spark@1672509 13f79535-47bb-0310-9956-ffa450edef68
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/1ac630c2
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/1ac630c2
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/1ac630c2
Branch: refs/heads/master
Commit: 1ac630c27bce036e3ce43fca8ee8507e9d8ed720
Parents: 457935a
Author: Sun Chao <su...@apache.org>
Authored: Thu Apr 9 22:30:15 2015 +0000
Committer: Szehon Ho <sz...@cloudera.com>
Committed: Wed Apr 22 19:33:53 2015 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/1ac630c2/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java
index c735be1..31aa3dc 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java
@@ -28,6 +28,7 @@ import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.ql.CommandNeedRetryException;
import org.apache.hadoop.hive.ql.DriverContext;
import org.apache.hadoop.hive.ql.QueryPlan;
+import org.apache.hadoop.hive.ql.exec.mr.ExecMapper;
import org.apache.hadoop.hive.ql.io.HiveInputFormat;
import org.apache.hadoop.hive.ql.metadata.HiveException;
import org.apache.hadoop.hive.ql.metadata.VirtualColumn;
@@ -79,6 +80,7 @@ public class FetchTask extends Task<FetchWork> implements Serializable {
fetch = new FetchOperator(work, job, source, getVirtualColumns(source));
source.initialize(conf, new ObjectInspector[]{fetch.getOutputObjectInspector()});
totalRows = 0;
+ ExecMapper.setDone(false);
} catch (Exception e) {
// Bail out ungracefully - we should never hit