Skip to content

Commit e833330

Browse files
add spark version to driver log
1 parent 81112e4 commit e833330

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

core/src/main/scala/org/apache/spark/SparkConf.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -240,6 +240,8 @@ class SparkConf(loadDefaults: Boolean) extends Cloneable with Logging {
240240
/** Checks for illegal or deprecated config settings. Throws an exception for the former. Not
241241
* idempotent - may mutate this conf object to convert deprecated settings to supported ones. */
242242
private[spark] def validateSettings() {
243+
logInfo(s"Spark Version: ${SPARK_VERSION}")
244+
243245
if (settings.contains("spark.local.dir")) {
244246
val msg = "In Spark 1.0 and later spark.local.dir will be overridden by the value set by " +
245247
"the cluster manager (via SPARK_LOCAL_DIRS in mesos/standalone and LOCAL_DIRS in YARN)."

0 commit comments

Comments
 (0)