From 04d95f3601af6e5f25fe413a4f8dfa94561922c3 Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Thu, 18 Oct 2012 01:01:16 -0700 Subject: [PATCH] Fixed a typo in previous commit. --- src/main/scala/shark/SharkEnv.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/shark/SharkEnv.scala b/src/main/scala/shark/SharkEnv.scala index 98002446..06d078e5 100755 --- 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,