You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by px...@apache.org on 2015/09/25 05:39:41 UTC
[2/2] 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/2801d2c4
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/2801d2c4
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/2801d2c4
Branch: refs/heads/branch-1.0
Commit: 2801d2c4b1a61315ae7f28c0ea825580e30f411b
Parents: a7618df
Author: Sun Chao <su...@apache.org>
Authored: Thu Apr 9 22:30:15 2015 +0000
Committer: Pengcheng Xiong <px...@apache.org>
Committed: Thu Sep 24 20:35:14 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/2801d2c4/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 c4f04cb..3e2187d 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