Github user cenyuhai commented on a diff in the pull request:
https://github.com/apache/spark/pull/16099#discussion_r165878592
--- 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 --
please catch the exception in ThriftServerPage.errorMessageCell. Without my
pr, that function still throw exception.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
