[
https://issues.apache.org/jira/browse/TOREE-419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Zhong updated TOREE-419:
-----------------------------
Description:
In Toree Sql notebook,
when I typed a sql of wrong syntax, the notebook becomes unresponsive.
For example:
{{create tablddfa}}
In the jupyter log, there is logs like this:
{quote}
Executing: 'create tablddfa'
17/06/22 14:06:53 WARN layer.StandardComponentInitialization$$anon$1: Locked to
Scala interpreter with SparkIMain until decoupled!
17/06/22 14:06:53 WARN layer.StandardComponentInitialization$$anon$1: Unable to
control initialization of REPL class server!
17/06/22 14:06:54 WARN util.NativeCodeLoader: Unable to load native-hadoop
library for your platform... using builtin-java classes where applicable
17/06/22 14:06:57 ERROR actor.OneForOneStrategy:
no viable alternative at input 'create tablddfa'(line 1, pos 7)
== SQL ==
create tablddfa
-------^^^
org.apache.spark.sql.catalyst.parser.ParseException:
no viable alternative at input 'create tablddfa'(line 1, pos 7)
== SQL ==
create tablddfa
-------^^^
at
org.apache.spark.sql.catalyst.parser.ParseException.withCommand(ParseDriver.scala:197)
at
org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parse(ParseDriver.scala:99)
at
org.apache.spark.sql.execution.SparkSqlParser.parse(SparkSqlParser.scala:45)
at
org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parsePlan(ParseDriver.scala:53)
at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:592)
at
org.apache.toree.kernel.interpreter.sql.SqlService$$anonfun$submitCode$1.apply(SqlService.scala:50)
at
org.apache.toree.kernel.interpreter.sql.SqlService$$anonfun$submitCode$1.apply(SqlService.scala:48)
at
scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at
scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at
scala.concurrent.impl.ExecutionContextImpl$AdaptedForkJoinTask.exec(ExecutionContextImpl.scala:121)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
{quote}
was:
In Toree Sql notebook,
when I typed a sql of wrong syntax, the notebook becomes in-responsive.
For example:
{{create tablddfa}}
In the jupyter log, there is logs like this:
{quote}
Executing: 'create tablddfa'
17/06/22 14:06:53 WARN layer.StandardComponentInitialization$$anon$1: Locked to
Scala interpreter with SparkIMain until decoupled!
17/06/22 14:06:53 WARN layer.StandardComponentInitialization$$anon$1: Unable to
control initialization of REPL class server!
17/06/22 14:06:54 WARN util.NativeCodeLoader: Unable to load native-hadoop
library for your platform... using builtin-java classes where applicable
17/06/22 14:06:57 ERROR actor.OneForOneStrategy:
no viable alternative at input 'create tablddfa'(line 1, pos 7)
== SQL ==
create tablddfa
-------^^^
org.apache.spark.sql.catalyst.parser.ParseException:
no viable alternative at input 'create tablddfa'(line 1, pos 7)
== SQL ==
create tablddfa
-------^^^
at
org.apache.spark.sql.catalyst.parser.ParseException.withCommand(ParseDriver.scala:197)
at
org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parse(ParseDriver.scala:99)
at
org.apache.spark.sql.execution.SparkSqlParser.parse(SparkSqlParser.scala:45)
at
org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parsePlan(ParseDriver.scala:53)
at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:592)
at
org.apache.toree.kernel.interpreter.sql.SqlService$$anonfun$submitCode$1.apply(SqlService.scala:50)
at
org.apache.toree.kernel.interpreter.sql.SqlService$$anonfun$submitCode$1.apply(SqlService.scala:48)
at
scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at
scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at
scala.concurrent.impl.ExecutionContextImpl$AdaptedForkJoinTask.exec(ExecutionContextImpl.scala:121)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
{quote}
> SQL kernel hangs when executing a SQL with wrong syntax
> --------------------------------------------------------
>
> Key: TOREE-419
> URL: https://issues.apache.org/jira/browse/TOREE-419
> Project: TOREE
> Issue Type: Bug
> Components: Kernel
> Affects Versions: 0.2.0
> Reporter: Sean Zhong
>
> In Toree Sql notebook,
> when I typed a sql of wrong syntax, the notebook becomes unresponsive.
> For example:
> {{create tablddfa}}
> In the jupyter log, there is logs like this:
> {quote}
> Executing: 'create tablddfa'
> 17/06/22 14:06:53 WARN layer.StandardComponentInitialization$$anon$1: Locked
> to Scala interpreter with SparkIMain until decoupled!
> 17/06/22 14:06:53 WARN layer.StandardComponentInitialization$$anon$1: Unable
> to control initialization of REPL class server!
> 17/06/22 14:06:54 WARN util.NativeCodeLoader: Unable to load native-hadoop
> library for your platform... using builtin-java classes where applicable
> 17/06/22 14:06:57 ERROR actor.OneForOneStrategy:
> no viable alternative at input 'create tablddfa'(line 1, pos 7)
> == SQL ==
> create tablddfa
> -------^^^
> org.apache.spark.sql.catalyst.parser.ParseException:
> no viable alternative at input 'create tablddfa'(line 1, pos 7)
> == SQL ==
> create tablddfa
> -------^^^
> at
> org.apache.spark.sql.catalyst.parser.ParseException.withCommand(ParseDriver.scala:197)
> at
> org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parse(ParseDriver.scala:99)
> at
> org.apache.spark.sql.execution.SparkSqlParser.parse(SparkSqlParser.scala:45)
> at
> org.apache.spark.sql.catalyst.parser.AbstractSqlParser.parsePlan(ParseDriver.scala:53)
> at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:592)
> at
> org.apache.toree.kernel.interpreter.sql.SqlService$$anonfun$submitCode$1.apply(SqlService.scala:50)
> at
> org.apache.toree.kernel.interpreter.sql.SqlService$$anonfun$submitCode$1.apply(SqlService.scala:48)
> at
> scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
> at
> scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
> at
> scala.concurrent.impl.ExecutionContextImpl$AdaptedForkJoinTask.exec(ExecutionContextImpl.scala:121)
> at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> {quote}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
