[jira] [Created] (ZEPPELIN-5194) SET statements always fail with flink.ssql interpreter

["Q Kang (Jira)" <ji...@apache.org>]

Q Kang created ZEPPELIN-5194:
--------------------------------

             Summary: SET statements always fail with flink.ssql interpreter
                 Key: ZEPPELIN-5194
                 URL: https://issues.apache.org/jira/browse/ZEPPELIN-5194
             Project: Zeppelin
          Issue Type: Bug
          Components: flink, Interpreters
    Affects Versions: 0.9.0
            Reporter: Q Kang


When executing SET statements in a flink.ssql paragraph, for example:
{code:java}
SET 'table.dynamic-table-options.enabled' = 'true';
SET 'table.sql-dialect' = 'hive';
SET 'table.exec.async-lookup.buffer-capacity' = '200';
SET 'table.optimizer.agg-phase-strategy' = 'TWO_PHASE';
{code}
All of them will eventually fail with following exception, regardless of the Flink version we use:
{code:java}
Fail to run sql command: SET 'xxx' = 'yyy'
java.io.IOException: 'xxx' is not a valid table/sql config, please check link: https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html
	at org.apache.zeppelin.flink.FlinkSqlInterrpeter.callSet(FlinkSqlInterrpeter.java:506)
	at org.apache.zeppelin.flink.FlinkSqlInterrpeter.callCommand(FlinkSqlInterrpeter.java:260)
	at org.apache.zeppelin.flink.FlinkSqlInterrpeter.runSqlList(FlinkSqlInterrpeter.java:151)
	at org.apache.zeppelin.flink.FlinkSqlInterrpeter.internalInterpret(FlinkSqlInterrpeter.java:111)
	at org.apache.zeppelin.interpreter.AbstractInterpreter.interpret(AbstractInterpreter.java:47)
	at org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:110)
	at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:852)
	at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:744)
	at org.apache.zeppelin.scheduler.Job.run(Job.java:172)
	at org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:132)
	at org.apache.zeppelin.scheduler.ParallelScheduler.lambda$runJobInScheduler$0(ParallelScheduler.java:46)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
{code}
However, the `FlinkShim`s are properly loaded according to interpreter logs.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)