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 <[email protected]> Authored: Thu Apr 9 22:30:15 2015 +0000 Committer: Pengcheng Xiong <[email protected]> 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
