You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by br...@apache.org on 2014/08/25 22:39:29 UTC
svn commit: r1620427 -
/hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java
Author: brock
Date: Mon Aug 25 20:39:28 2014
New Revision: 1620427
URL: http://svn.apache.org/r1620427
Log:
HIVE-7799 - TRANSFORM failed in transform_ppr1.q [Spark Branch] (Chengxiang Li via Brock)
Modified:
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java
Modified: hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java?rev=1620427&r1=1620426&r2=1620427&view=diff
==============================================================================
--- hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java (original)
+++ hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java Mon Aug 25 20:39:28 2014
@@ -97,9 +97,11 @@ public abstract class HiveBaseFunctionRe
while (inputIterator.hasNext() && !processingDone()) {
try {
processNextRecord(inputIterator.next());
- if (lastRecordOutput.hasNext()) {
- return true;
- }
+ // TODO Current HiveKVResultCache does not support read-then-write,
+ // should not enable lazy execution here. See HIVE-7873
+ // if (lastRecordOutput.hasNext()) {
+ // return true;
+ // }
} catch (IOException ex) {
// TODO: better handling of exception.
throw new RuntimeException("Error while processing input.", ex);