diff options
| author | Imran Rashid <imran@quantifind.com> | 2013-02-21 15:21:45 -0800 |
|---|---|---|
| committer | Imran Rashid <imran@quantifind.com> | 2013-02-21 15:21:45 -0800 |
| commit | 81bd07da265a9fdaad366d8fd46a70df6d5c9806 (patch) | |
| tree | 08fb9790d2572827821bf0e52e335a518f7a2b49 /core | |
| parent | 796e934d316750aa39c7fbb6b99cbb25d3aa2236 (diff) | |
| download | spark-81bd07da265a9fdaad366d8fd46a70df6d5c9806.tar.gz spark-81bd07da265a9fdaad366d8fd46a70df6d5c9806.tar.bz2 spark-81bd07da265a9fdaad366d8fd46a70df6d5c9806.zip | |
sparkListeners should be a val
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/DAGScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala index ce3b62cc4d..1bf5054f4d 100644 --- a/core/src/main/scala/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/spark/scheduler/DAGScheduler.scala @@ -76,7 +76,7 @@ class DAGScheduler( private[spark] val stageToInfos = new TimeStampedHashMap[Stage, StageInfo] - private[spark] var sparkListeners = ArrayBuffer[SparkListener]() + private[spark] val sparkListeners = ArrayBuffer[SparkListener]() var cacheLocs = new HashMap[Int, Array[List[String]]] |