You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by zs...@apache.org on 2009/04/08 01:44:37 UTC
svn commit: r763041 - in /hadoop/hive/trunk: CHANGES.txt
ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
Author: zshao
Date: Tue Apr 7 23:44:37 2009
New Revision: 763041
URL: http://svn.apache.org/viewvc?rev=763041&view=rev
Log:
HIVE-394. Break plans in Cluster Mode. (Namit Jain via zshao)
Modified:
hadoop/hive/trunk/CHANGES.txt
hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
Modified: hadoop/hive/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/CHANGES.txt?rev=763041&r1=763040&r2=763041&view=diff
==============================================================================
--- hadoop/hive/trunk/CHANGES.txt (original)
+++ hadoop/hive/trunk/CHANGES.txt Tue Apr 7 23:44:37 2009
@@ -132,6 +132,8 @@
HIVE-384. Fixing UNION ALL when the first job is a map-only job.
(Namit Jain via zshao)
+ HIVE-394. Break plans in Cluster Mode. (Namit Jain via zshao)
+
Release 0.2.0 - Unreleased
INCOMPATIBLE CHANGES
Modified: hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java?rev=763041&r1=763040&r2=763041&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java (original)
+++ hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java Tue Apr 7 23:44:37 2009
@@ -80,6 +80,8 @@
import org.apache.hadoop.hive.ql.optimizer.GenMRRedSink3;
import org.apache.hadoop.hive.ql.plan.*;
import org.apache.hadoop.hive.ql.udf.UDFOPPositive;
+import org.apache.hadoop.hive.ql.exec.MapRedTask;
+import org.apache.hadoop.hive.ql.exec.ExecDriver;
import org.apache.hadoop.hive.ql.exec.*;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.ql.plan.PlanUtils;
@@ -3473,8 +3475,9 @@
// loop over all the tasks recursviely
private void breakTaskTree(Task<? extends Serializable> task) {
- if (task instanceof MapRedTask) {
- HashMap<String, Operator<? extends Serializable>> opMap = ((MapRedTask)task).getWork().getAliasToWork();
+
+ if ((task instanceof MapRedTask) || (task instanceof ExecDriver)) {
+ HashMap<String, Operator<? extends Serializable>> opMap = ((mapredWork)task.getWork()).getAliasToWork();
if (!opMap.isEmpty())
for (Operator<? extends Serializable> op: opMap.values())
breakOperatorTree(op);