diff options
| author | Yuming Wang <wgyumg@gmail.com> | 2017-03-29 15:23:24 -0700 |
|---|---|---|
| committer | Xiao Li <gatorsmile@gmail.com> | 2017-03-29 15:23:24 -0700 |
| commit | fe1d6b05d47e384e3710ae428db499e89697267f (patch) | |
| tree | 6a211b4c53f4611689ac81146361ff8a713724bf /sql/hive-thriftserver | |
| parent | 5c8ef376e874497766ba0cc4d97429e33a3d9c61 (diff) | |
| download | spark-fe1d6b05d47e384e3710ae428db499e89697267f.tar.gz spark-fe1d6b05d47e384e3710ae428db499e89697267f.tar.bz2 spark-fe1d6b05d47e384e3710ae428db499e89697267f.zip | |
[SPARK-20120][SQL] spark-sql support silent mode
## What changes were proposed in this pull request?
It is similar to Hive silent mode, just show the query result. see: [Hive LanguageManual+Cli](https://cwiki.apache.org/confluence/display/Hive/LanguageManual+Cli) and [the implementation of Hive silent mode](https://github.com/apache/hive/blob/release-1.2.1/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java#L948-L950).
This PR set the Logger level to `WARN` to get similar result.
## How was this patch tested?
manual tests
Author: Yuming Wang <wgyumg@gmail.com>
Closes #17449 from wangyum/SPARK-20120.
Diffstat (limited to 'sql/hive-thriftserver')
| -rw-r--r-- | sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala index 390b9b6d68..1bc5c3c62f 100644 --- a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala +++ b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala @@ -34,6 +34,7 @@ import org.apache.hadoop.hive.ql.Driver import org.apache.hadoop.hive.ql.exec.Utilities import org.apache.hadoop.hive.ql.processors._ import org.apache.hadoop.hive.ql.session.SessionState +import org.apache.log4j.{Level, Logger} import org.apache.thrift.transport.TSocket import org.apache.spark.internal.Logging @@ -275,6 +276,10 @@ private[hive] class SparkSQLCLIDriver extends CliDriver with Logging { private val console = new SessionState.LogHelper(LOG) + if (sessionState.getIsSilent) { + Logger.getRootLogger.setLevel(Level.WARN) + } + private val isRemoteMode = { SparkSQLCLIDriver.isRemoteMode(sessionState) } |