Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -73,18 +73,6 @@ private[hive] object SparkSQLCLIDriver {
System.exit(1)
}

// NOTE: It is critical to do this here so that log4j is reinitialized
// before any of the other core hive classes are loaded
var logInitFailed = false
var logInitDetailMessage: String = null
try {
logInitDetailMessage = LogUtils.initHiveLog4j()
} catch {
case e: LogInitializationException =>
logInitFailed = true
logInitDetailMessage = e.getMessage
}

val sessionState = new CliSessionState(new HiveConf(classOf[SessionState]))

sessionState.in = System.in
Expand All @@ -100,11 +88,6 @@ private[hive] object SparkSQLCLIDriver {
System.exit(2)
}

if (!sessionState.getIsSilent) {
if (logInitFailed) System.err.println(logInitDetailMessage)
else SessionState.getConsole.printInfo(logInitDetailMessage)
}

// Set all properties specified via command line.
val conf: HiveConf = sessionState.getConf
sessionState.cmdProperties.entrySet().foreach { item: java.util.Map.Entry[Object, Object] =>
Expand Down