diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java index 6568a76..f7b5fd4 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveBaseFunctionResultList.java @@ -96,9 +96,11 @@ public boolean hasNext(){ while (inputIterator.hasNext() && !processingDone()) { try { processNextRecord(inputIterator.next()); - if (lastRecordOutput.hasNext()) { - return true; - } + // Current HiveKVResultCache does not support read-then-write, + // should not enable lazy execution here. + // if (lastRecordOutput.hasNext()) { + // return true; + // } } catch (IOException ex) { // TODO: better handling of exception. throw new RuntimeException("Error while processing input.", ex);