diff options
| author | Mingfei <mingfei.shi@intel.com> | 2013-06-21 17:38:23 +0800 |
|---|---|---|
| committer | Mingfei <mingfei.shi@intel.com> | 2013-06-21 17:38:23 +0800 |
| commit | 52407951541399e60a5292394b3a443a5e7ff281 (patch) | |
| tree | a2c01a9ddc72dec6217bd17d94eab250ef800796 /core/src/test/scala | |
| parent | 967a6a699da7da007f51e59d085a357da5ec14da (diff) | |
| download | spark-52407951541399e60a5292394b3a443a5e7ff281.tar.gz spark-52407951541399e60a5292394b3a443a5e7ff281.tar.bz2 spark-52407951541399e60a5292394b3a443a5e7ff281.zip | |
edit according to comments
Diffstat (limited to 'core/src/test/scala')
| -rw-r--r-- | core/src/test/scala/spark/scheduler/JobLoggerSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/test/scala/spark/scheduler/JobLoggerSuite.scala b/core/src/test/scala/spark/scheduler/JobLoggerSuite.scala index a654bf3ffd..4000c4d520 100644 --- a/core/src/test/scala/spark/scheduler/JobLoggerSuite.scala +++ b/core/src/test/scala/spark/scheduler/JobLoggerSuite.scala @@ -87,7 +87,7 @@ class JobLoggerSuite extends FunSuite with LocalSparkContext with ShouldMatchers var onStageCompletedCount = 0 var onStageSubmittedCount = 0 override def onTaskEnd(taskEnd: SparkListenerTaskEnd) = onTaskEndCount += 1 - override def onJobEnd(jobEnd: SparkListenerEvents) = onJobEndCount += 1 + override def onJobEnd(jobEnd: SparkListenerJobEnd) = onJobEndCount += 1 override def onJobStart(jobStart: SparkListenerJobStart) = onJobStartCount += 1 override def onStageCompleted(stageCompleted: StageCompleted) = onStageCompletedCount += 1 override def onStageSubmitted(stageSubmitted: SparkListenerStageSubmitted) = onStageSubmittedCount += 1 |