| commit | c894999b03f2c4b96ba9d6581424dbf3c5e4b64a | [log] [tgz] |
|---|---|---|
| author | Luciano Resende <lresende@apache.org> | Fri Jun 15 00:25:49 2018 -0700 |
| committer | Luciano Resende <lresende@apache.org> | Fri Jun 15 00:25:49 2018 -0700 |
| tree | 4d2f98bda0f3d94966d921b71d3ebd3260972ef0 | |
| parent | 64d2ee8c4531ec8386ff0668bb1d8c2a1b697446 [diff] |
[MINOR] Fix typo on variable name
diff --git a/scala-interpreter/src/test/scala-2.11/scala/ScalaInterpreterSpec.scala b/scala-interpreter/src/test/scala-2.11/scala/ScalaInterpreterSpec.scala index dfe3da6..19eb78f 100644 --- a/scala-interpreter/src/test/scala-2.11/scala/ScalaInterpreterSpec.scala +++ b/scala-interpreter/src/test/scala-2.11/scala/ScalaInterpreterSpec.scala
@@ -455,6 +455,7 @@ interpreter.stop() } + } } }
diff --git a/sql-interpreter/src/main/scala/org/apache/toree/magic/builtin/Sql.scala b/sql-interpreter/src/main/scala/org/apache/toree/magic/builtin/Sql.scala index 35f033f..3dcf7e7 100644 --- a/sql-interpreter/src/main/scala/org/apache/toree/magic/builtin/Sql.scala +++ b/sql-interpreter/src/main/scala/org/apache/toree/magic/builtin/Sql.scala
@@ -29,14 +29,14 @@ @Event(name = "sql") override def execute(code: String): MagicOutput = { - val sparkR = kernel.interpreter("SQL") + val sparkSQL = kernel.interpreter("SQL") - if (sparkR.isEmpty || sparkR.get == null) + if (sparkSQL.isEmpty || sparkSQL.get == null) throw new SqlException("SQL is not available!") - sparkR.get match { - case sparkRInterpreter: SqlInterpreter => - val (_, output) = sparkRInterpreter.interpret(code) + sparkSQL.get match { + case sparkSQLInterpreter: SqlInterpreter => + val (_, output) = sparkSQLInterpreter.interpret(code) output match { case Left(executeOutput) => MagicOutput(executeOutput.toSeq:_*)