From 5522ffcae4131f13d2610989c7611a0b6682ec51 Mon Sep 17 00:00:00 2001 From: sychen Date: Thu, 26 Jun 2025 21:08:19 +0800 Subject: [PATCH] -i --- repl/src/main/scala/org/apache/spark/repl/Main.scala | 4 +++- .../scala/org/apache/spark/repl/SparkILoop.scala | 12 +++++++++--- 2 files changed, 12 insertions(+), 4 deletions(-) diff --git a/repl/src/main/scala/org/apache/spark/repl/Main.scala b/repl/src/main/scala/org/apache/spark/repl/Main.scala index 8548801266b26..4ed3bd51d7521 100644 --- a/repl/src/main/scala/org/apache/spark/repl/Main.scala +++ b/repl/src/main/scala/org/apache/spark/repl/Main.scala @@ -57,7 +57,9 @@ object Main extends Logging { def main(args: Array[String]): Unit = { isShellSession = true - doMain(args, new SparkILoop) + val settings = new GenericRunnerSettings(scalaOptionError) + settings.processArguments(args.toList, true) + doMain(args, new SparkILoop(settings)) } // Visible for testing diff --git a/repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala b/repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala index f49e8adcc74af..01a09344343ab 100644 --- a/repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala +++ b/repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala @@ -31,9 +31,15 @@ import scala.util.Properties.{javaVersion, javaVmName, versionString} /** * A Spark-specific interactive shell. */ -class SparkILoop(in0: BufferedReader, out: PrintWriter) - extends ILoop(ShellConfig(new GenericRunnerSettings(_ => ())), in0, out) { - def this() = this(null, new PrintWriter(Console.out, true)) +class SparkILoop(config: ShellConfig, in0: BufferedReader, out: PrintWriter) + extends ILoop(config, in0, out) { + def this(in0: BufferedReader, out: PrintWriter) = this( + ShellConfig(new GenericRunnerSettings(_ => ())), in0, out) + + def this(settings: Settings) = this(ShellConfig(settings), null, + new PrintWriter(Console.out, true)) + + def this() = this(new GenericRunnerSettings(_ => ())) val initializationCommands: Seq[String] = Seq( """