diff options
| author | Lian, Cheng <rhythm.mail@gmail.com> | 2013-11-09 21:13:03 +0800 |
|---|---|---|
| committer | Lian, Cheng <rhythm.mail@gmail.com> | 2013-11-09 21:13:03 +0800 |
| commit | 765ebca04f3dce1685c64022425bd281993be90e (patch) | |
| tree | a0519a00a229da50ce8dd66801dc4863d13bd95b /core | |
| parent | 2539c0674501432fb62073577db6da52a26db850 (diff) | |
| download | spark-765ebca04f3dce1685c64022425bd281993be90e.tar.gz spark-765ebca04f3dce1685c64022425bd281993be90e.tar.bz2 spark-765ebca04f3dce1685c64022425bd281993be90e.zip | |
Remove unnecessary null checking
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index cb19969369..a73a6e19f4 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -117,9 +117,7 @@ class DAGScheduler( */ def receive = { case event: DAGSchedulerEvent => - if (event != null) { - logDebug("Got event of type " + event.getClass.getName) - } + logDebug("Got event of type " + event.getClass.getName) if (!processEvent(event)) { val time = System.currentTimeMillis() // TODO: use a pluggable clock for testability |