File tree Expand file tree Collapse file tree 3 files changed +7
-8
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 3 files changed +7
-8
lines changed Original file line number Diff line number Diff line change @@ -2538,12 +2538,13 @@ class SparkContext(config: SparkConf) extends Logging {
25382538 */
25392539 private def setupAndStartListenerBus (): Unit = {
25402540 try {
2541- val listeners = Utils .loadExtensions( classOf [ SparkListenerInterface ],
2542- Seq ( SPARK_CALL_HOME_LISTENER_CLASS ) , conf)
2543- listeners.foreach { listener =>
2544- listenerBus.addToQueue (listener, SPARK_CALL_HOME_QUEUE_NAME )
2541+ conf.get( EXTRA_LISTENERS ).foreach { classNames =>
2542+ val listeners = Utils .loadExtensions( classOf [ SparkListenerInterface ], classNames , conf)
2543+ listeners.foreach { listener =>
2544+ listenerBus.addToSharedQueue (listener)
25452545 logInfo(s " Registered listener ${listener.getClass().getName()}" )
25462546 }
2547+ }
25472548 } catch {
25482549 case e : Exception =>
25492550 try {
Original file line number Diff line number Diff line change @@ -38,9 +38,7 @@ package object config {
3838 private [spark] val SPARK_TASK_PREFIX = " spark.task"
3939 private [spark] val LISTENER_BUS_EVENT_QUEUE_PREFIX = " spark.scheduler.listenerbus.eventqueue"
4040 private [spark] val SPARK_CALL_HOME_LISTENER_CLASS =
41- " com.apple.spark.callhome.listener.SparkCallHomeListenerV2"
42- private [spark] val SPARK_CALL_HOME_QUEUE_NAME =
43- " SparkCallHome"
41+ " com.apple.aci.data.spark.callhome.listener.v1.SparkCallHomeListenerV1"
4442
4543 private [spark] val RESOURCES_DISCOVERY_PLUGIN =
4644 ConfigBuilder (" spark.resources.discoveryPlugin" )
Original file line number Diff line number Diff line change 193193 <jpam .version>1.1</jpam .version>
194194 <selenium .version>3.141.59</selenium .version>
195195 <htmlunit .version>2.40.0</htmlunit .version>
196- <acispark .callhome.version>0.2.8 </acispark .callhome.version>
196+ <acispark .callhome.version>0.2.0 </acispark .callhome.version>
197197 <iceberg .version>0.12.0-apple-preview-7</iceberg .version>
198198 <!--
199199 Managed up from older version from Avro; sync with jackson-module-paranamer dependency version
You can’t perform that action at this time.
0 commit comments