Skip to content

Commit e05e1e3

Browse files
add spark version infomation in log for standalone mode
1 parent 7e2deb7 commit e05e1e3

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

core/src/main/scala/org/apache/spark/deploy/master/Master.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -123,6 +123,7 @@ private[spark] class Master(
123123

124124
override def preStart() {
125125
logInfo("Starting Spark master at " + masterUrl)
126+
logInfo(s"Master Spark Version is ${org.apache.spark.SPARK_VERSION}")
126127
// Listen for remote client disconnection events, since they don't go through Akka's watch()
127128
context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
128129
webUi.bind()

core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,7 @@ private[spark] class Worker(
155155
assert(!registered)
156156
logInfo("Starting Spark worker %s:%d with %d cores, %s RAM".format(
157157
host, port, cores, Utils.megabytesToString(memory)))
158+
logInfo(s"Worker Spark Version is ${org.apache.spark.SPARK_VERSION}")
158159
logInfo("Spark home: " + sparkHome)
159160
createWorkDir()
160161
context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])

0 commit comments

Comments
 (0)