Skip to content
Snippets Groups Projects
Commit 69fd42ae authored by Prashant Sharma's avatar Prashant Sharma
Browse files

ported repl improvements from master

parent a90e0eff
No related branches found
No related tags found
No related merge requests found
...@@ -915,6 +915,10 @@ class SparkILoop(in0: Option[BufferedReader], protected val out: JPrintWriter, ...@@ -915,6 +915,10 @@ class SparkILoop(in0: Option[BufferedReader], protected val out: JPrintWriter,
} }
def createSparkContext(): SparkContext = { def createSparkContext(): SparkContext = {
val uri = System.getenv("SPARK_EXECUTOR_URI")
if (uri != null) {
System.setProperty("spark.executor.uri", uri)
}
val master = this.master match { val master = this.master match {
case Some(m) => m case Some(m) => m
case None => { case None => {
......
...@@ -185,8 +185,13 @@ trait SparkImports { ...@@ -185,8 +185,13 @@ trait SparkImports {
if (currentImps contains imv) addWrapper() if (currentImps contains imv) addWrapper()
val objName = req.lineRep.readPath val objName = req.lineRep.readPath
val valName = "$VAL" + newValId(); val valName = "$VAL" + newValId();
code.append("val " + valName + " = " + objName + ".INSTANCE;\n")
code.append("import " + valName + req.accessPath + ".`" + imv + "`;\n") if(!code.toString.endsWith(".`" + imv + "`;\n")) { // Which means already imported
code.append("val " + valName + " = " + objName + ".INSTANCE;\n")
code.append("import " + valName + req.accessPath + ".`" + imv + "`;\n")
}
// code.append("val " + valName + " = " + objName + ".INSTANCE;\n")
// code.append("import " + valName + req.accessPath + ".`" + imv + "`;\n")
// code append ("import " + (req fullPath imv) + "\n") // code append ("import " + (req fullPath imv) + "\n")
currentImps += imv currentImps += imv
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment