diff options
| author | wangfei <wangfei1@huawei.com> | 2015-01-10 17:04:56 -0800 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2015-01-10 17:04:56 -0800 |
| commit | 92d9a704ce1232bddc570bca13758b11ff9ddb1f (patch) | |
| tree | 73623b19f755504f9df631ea08103f401f842136 /sql/hive-thriftserver/src | |
| parent | 8a29dc716e3452fdf546852ddc18238018b73891 (diff) | |
| download | spark-92d9a704ce1232bddc570bca13758b11ff9ddb1f.tar.gz spark-92d9a704ce1232bddc570bca13758b11ff9ddb1f.tar.bz2 spark-92d9a704ce1232bddc570bca13758b11ff9ddb1f.zip | |
[SPARK-4871][SQL] Show sql statement in spark ui when run sql with spark-sql
Author: wangfei <wangfei1@huawei.com>
Closes #3718 from scwf/sparksqlui and squashes the following commits:
e0d6b5d [wangfei] format fix
383b505 [wangfei] fix conflicts
4d2038a [wangfei] using setJobDescription
df79837 [wangfei] fix compile error
92ce834 [wangfei] show sql statement in spark ui when run sql use spark-sql
Diffstat (limited to 'sql/hive-thriftserver/src')
| -rw-r--r-- | sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/AbstractSparkSQLDriver.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/AbstractSparkSQLDriver.scala b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/AbstractSparkSQLDriver.scala index 7a3d76c61c..59f3a75768 100644 --- a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/AbstractSparkSQLDriver.scala +++ b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/AbstractSparkSQLDriver.scala @@ -53,6 +53,7 @@ private[hive] abstract class AbstractSparkSQLDriver( override def run(command: String): CommandProcessorResponse = { // TODO unify the error code try { + context.sparkContext.setJobDescription(command) val execution = context.executePlan(context.sql(command).logicalPlan) hiveResponse = execution.stringResult() tableSchema = getResultSetSchema(execution) |