Skip to content

Commit abcc7cb

Browse files
committed
Remove the REPL forked code.
1 parent c13da20 commit abcc7cb

File tree

9 files changed

+35
-3147
lines changed

9 files changed

+35
-3147
lines changed

repl/scala-2.11/src/main/scala/org/apache/spark/repl/Main.scala

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,6 @@ object Main extends Logging {
4848
Option(sparkContext).map(_.stop)
4949
}
5050

51-
5251
def getAddedJars: Array[String] = {
5352
val envJars = sys.env.get("ADD_JARS")
5453
if (envJars.isDefined) {
@@ -84,10 +83,9 @@ object Main extends Logging {
8483
val loader = Utils.getContextOrSparkClassLoader
8584
try {
8685
sqlContext = loader.loadClass(name).getConstructor(classOf[SparkContext])
87-
.newInstance(sparkContext).asInstanceOf[SQLContext]
86+
.newInstance(sparkContext).asInstanceOf[SQLContext]
8887
logInfo("Created sql context (with Hive support)..")
89-
}
90-
catch {
88+
} catch {
9189
case _: java.lang.ClassNotFoundException | _: java.lang.NoClassDefFoundError =>
9290
sqlContext = new SQLContext(sparkContext)
9391
logInfo("Created sql context..")

repl/scala-2.11/src/main/scala/org/apache/spark/repl/SparkExprTyper.scala

Lines changed: 0 additions & 86 deletions
This file was deleted.

0 commit comments

Comments
 (0)