You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by li...@apache.org on 2017/03/29 22:23:30 UTC
spark git commit: [SPARK-20120][SQL] spark-sql support silent mode
Repository: spark
Updated Branches:
refs/heads/master 5c8ef376e -> fe1d6b05d
[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 <wg...@gmail.com>
Closes #17449 from wangyum/SPARK-20120.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fe1d6b05
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fe1d6b05
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fe1d6b05
Branch: refs/heads/master
Commit: fe1d6b05d47e384e3710ae428db499e89697267f
Parents: 5c8ef37
Author: Yuming Wang <wg...@gmail.com>
Authored: Wed Mar 29 15:23:24 2017 -0700
Committer: Xiao Li <ga...@gmail.com>
Committed: Wed Mar 29 15:23:24 2017 -0700
----------------------------------------------------------------------
.../apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/fe1d6b05/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
----------------------------------------------------------------------
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 390b9b6..1bc5c3c 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)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org