Skip to content

Commit fe1d6b0

Browse files
wangyumgatorsmile
authored andcommitted
[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 ![manual test spark sql silent mode](https://cloud.githubusercontent.com/assets/5399861/24390165/989b7780-13b9-11e7-8496-6e68f55757e3.gif) Author: Yuming Wang <[email protected]> Closes #17449 from wangyum/SPARK-20120.
1 parent 5c8ef37 commit fe1d6b0

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ import org.apache.hadoop.hive.ql.Driver
3434
import org.apache.hadoop.hive.ql.exec.Utilities
3535
import org.apache.hadoop.hive.ql.processors._
3636
import org.apache.hadoop.hive.ql.session.SessionState
37+
import org.apache.log4j.{Level, Logger}
3738
import org.apache.thrift.transport.TSocket
3839

3940
import org.apache.spark.internal.Logging
@@ -275,6 +276,10 @@ private[hive] class SparkSQLCLIDriver extends CliDriver with Logging {
275276

276277
private val console = new SessionState.LogHelper(LOG)
277278

279+
if (sessionState.getIsSilent) {
280+
Logger.getRootLogger.setLevel(Level.WARN)
281+
}
282+
278283
private val isRemoteMode = {
279284
SparkSQLCLIDriver.isRemoteMode(sessionState)
280285
}

0 commit comments

Comments
 (0)