Remove unnecessary null checking
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/765ebca0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/765ebca0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/765ebca0 Branch: refs/heads/master Commit: 765ebca04f3dce1685c64022425bd281993be90e Parents: 2539c06 Author: Lian, Cheng <[email protected]> Authored: Sat Nov 9 21:13:03 2013 +0800 Committer: Lian, Cheng <[email protected]> Committed: Sat Nov 9 21:13:03 2013 +0800 ---------------------------------------------------------------------- .../src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/765ebca0/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala ---------------------------------------------------------------------- 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 cb19969..a73a6e1 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
