From bea4d879e4cf84acbd688d2605761431cbb5f77a Mon Sep 17 00:00:00 2001 From: scwf Date: Sat, 22 Nov 2014 21:04:06 +0800 Subject: [PATCH] minor fix --- .../scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sql/hive-thriftserver/v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala b/sql/hive-thriftserver/v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala index 76a94e6dfb95d..2468c4e006afe 100644 --- a/sql/hive-thriftserver/v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala +++ b/sql/hive-thriftserver/v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala @@ -22,7 +22,6 @@ import java.sql.{Date, Timestamp} import java.util.concurrent.Future import java.util.{ArrayList => JArrayList, List => JList, Map => JMap} - import scala.collection.JavaConversions._ import scala.collection.mutable.{ArrayBuffer, Map => SMap} import scala.math._ @@ -107,7 +106,6 @@ private[hive] class SparkExecuteStatementOperation( } } dataTypes = result.queryExecution.analyzed.output.map(_.dataType).toArray - setHasResultSet(true) } catch { // Actually do need to catch Throwable as some failures don't inherit from Exception and // HiveServer will silently swallow them. @@ -215,6 +213,7 @@ private[hive] class SparkExecuteStatementOperation( logInfo(s"Running query '$statement'") val opConfig: HiveConf = getConfigForOperation setState(OperationState.RUNNING) + setHasResultSet(true) if (!shouldRunAsync) { runInternal(statement)