From c5921e5c6184ddc99c12c0b1f2646b6bd74a9e98 Mon Sep 17 00:00:00 2001
From: Tathagata Das <tathagata.das1565@gmail.com>
Date: Sun, 12 Jan 2014 01:12:08 -0800
Subject: Fixed bugs.

---
 .../main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'streaming/src')

diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala
index b28ff5d9d8..24d57548c3 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala
@@ -63,7 +63,7 @@ class JobScheduler(val ssc: StreamingContext) extends Logging {
   }
 
   def stop() = synchronized {
-    if (eventActor != null) {
+    if (networkInputTracker != null) {
       jobGenerator.stop()
       networkInputTracker.stop()
       executor.shutdown()
-- 
cgit v1.2.3