diff options
| author | Mingfei <mingfei.shi@intel.com> | 2013-06-08 16:26:45 +0800 |
|---|---|---|
| committer | Mingfei <mingfei.shi@intel.com> | 2013-06-08 16:26:45 +0800 |
| commit | ade822011d44bd43e9ac78c1d29ec924a1f6e8e7 (patch) | |
| tree | 171b6343a2f720bc8ad4751ac1f3299bfe82cff5 /core/src | |
| parent | 4fd86e0e10149ad1803831a308a056c7105cbe67 (diff) | |
| download | spark-ade822011d44bd43e9ac78c1d29ec924a1f6e8e7.tar.gz spark-ade822011d44bd43e9ac78c1d29ec924a1f6e8e7.tar.bz2 spark-ade822011d44bd43e9ac78c1d29ec924a1f6e8e7.zip | |
not check return value of eventQueue.take
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/JobLogger.scala | 28 |
1 files changed, 13 insertions, 15 deletions
diff --git a/core/src/main/scala/spark/scheduler/JobLogger.scala b/core/src/main/scala/spark/scheduler/JobLogger.scala index f87acfd0b6..46b9fa974b 100644 --- a/core/src/main/scala/spark/scheduler/JobLogger.scala +++ b/core/src/main/scala/spark/scheduler/JobLogger.scala @@ -48,21 +48,19 @@ class JobLogger(val logDirName: String) extends SparkListener with Logging { override def run() {
while (true) {
val event = eventQueue.take
- if (event != null) {
- logDebug("Got event of type " + event.getClass.getName)
- event match {
- case JobLoggerOnJobStart(job, info) =>
- processJobStartEvent(job, info)
- case JobLoggerOnStageSubmitted(stage, info) =>
- processStageSubmittedEvent(stage, info)
- case JobLoggerOnStageCompleted(stageCompleted) =>
- processStageCompletedEvent(stageCompleted)
- case JobLoggerOnJobEnd(job, event) =>
- processJobEndEvent(job, event)
- case JobLoggerOnTaskEnd(event) =>
- processTaskEndEvent(event)
- case _ =>
- }
+ logDebug("Got event of type " + event.getClass.getName)
+ event match {
+ case JobLoggerOnJobStart(job, info) =>
+ processJobStartEvent(job, info)
+ case JobLoggerOnStageSubmitted(stage, info) =>
+ processStageSubmittedEvent(stage, info)
+ case JobLoggerOnStageCompleted(stageCompleted) =>
+ processStageCompletedEvent(stageCompleted)
+ case JobLoggerOnJobEnd(job, event) =>
+ processJobEndEvent(job, event)
+ case JobLoggerOnTaskEnd(event) =>
+ processTaskEndEvent(event)
+ case _ =>
}
}
}
|