Github user BruceXu1991 commented on a diff in the pull request:
https://github.com/apache/spark/pull/16099#discussion_r165876866
--- Diff:
sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala
---
@@ -241,6 +241,8 @@ private[hive] class SparkExecuteStatementOperation(
dataTypes =
result.queryExecution.analyzed.output.map(_.dataType).toArray
} catch {
case e: HiveSQLException =>
+ HiveThriftServer2.listener.onStatementError(
+ statementId, e.getMessage, SparkUtils.exceptionString(e))
--- End diff --
This PR still occurs in Spark 2.2.1. A workaround is to use
"String.valueOf(e.getMessage)" instead of "e.getMessage" to avoid of NPE
problem.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
