Fixed a typo in previous commit.

amplab · Oct 18, 2012 · 04d95f3 · 04d95f3
1 parent 5594f89
commit 04d95f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/shark/SharkEnv.scala b/src/main/scala/shark/SharkEnv.scala
@@ -11,7 +11,7 @@ import spark.SparkContext
 object SharkEnv extends LogHelper {
 
   def init() {
-    if (sc != null) {
+    if (sc == null) {
       sc = new SparkContext(
           if (System.getenv("MASTER") == null) "local" else System.getenv("MASTER"),
           "Shark::" + java.net.InetAddress.getLocalHost.getHostName,