diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-07-06 15:23:26 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-07-06 15:23:26 -0700 |
| commit | e72afdb817bcc8388aeb8b8d31628fd5fd67acf1 (patch) | |
| tree | f2c3b1b2560de4de9c9942d93cbbbd218a8f2c37 /repl | |
| parent | 5d1a887bed8423bd6c25660910d18d91880e01fe (diff) | |
| download | spark-e72afdb817bcc8388aeb8b8d31628fd5fd67acf1.tar.gz spark-e72afdb817bcc8388aeb8b8d31628fd5fd67acf1.tar.bz2 spark-e72afdb817bcc8388aeb8b8d31628fd5fd67acf1.zip | |
Some refactoring to make cluster scheduler pluggable.
Diffstat (limited to 'repl')
| -rw-r--r-- | repl/src/main/scala/spark/repl/SparkILoop.scala | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/repl/src/main/scala/spark/repl/SparkILoop.scala b/repl/src/main/scala/spark/repl/SparkILoop.scala index 935790a091..faece8baa4 100644 --- a/repl/src/main/scala/spark/repl/SparkILoop.scala +++ b/repl/src/main/scala/spark/repl/SparkILoop.scala @@ -819,7 +819,6 @@ class SparkILoop(in0: Option[BufferedReader], val out: PrintWriter, val master: spark.repl.Main.interp.out.println("Creating SparkContext..."); spark.repl.Main.interp.out.flush(); @transient val sc = spark.repl.Main.interp.createSparkContext(); - sc.waitForRegister(); spark.repl.Main.interp.out.println("Spark context available as sc."); spark.repl.Main.interp.out.flush(); """) |