[
https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204440#comment-17204440
]
Jark Wu commented on FLINK-19456:
---------------------------------
+1 for this.
> sql client execute insert sql with comment ahead
> ------------------------------------------------
>
> Key: FLINK-19456
> URL: https://issues.apache.org/jira/browse/FLINK-19456
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Client
> Affects Versions: 1.11.2
> Environment: flink-1.11.2-bin-scala_2.11
> standalone cluster
> bin/sql-client.sh embedded
> Reporter: ledong Lin
> Priority: Major
>
> *Environment*: standalone cluster
> *Step in sql client*:
> {code:java}
> Flink SQL> create table a( a string) with ( 'connector'='print');
> [INFO] Table has been created.
> Flink SQL> –- test
> > insert into a
> > select date_format(current_timestamp, 'yyyyMMdd');
> [INFO] Submitting SQL update statement to the cluster...
> Exception in thread "main" org.apache.flink.table.client.SqlClientException:
> Unexpected exception. This is a bug. Please consider filing an
> issue.Exception in thread "main"
> org.apache.flink.table.client.SqlClientException: Unexpected exception. This
> is a bug. Please consider filing an issue. at
> org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)Caused by:
> java.lang.NullPointerException at
> org.apache.flink.table.client.cli.CliClient.callInsert(CliClient.java:598) at
> org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:315)
> at java.util.Optional.ifPresent(Optional.java:159) at
> org.apache.flink.table.client.cli.CliClient.open(CliClient.java:212) at
> org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:142) at
> org.apache.flink.table.client.SqlClient.start(SqlClient.java:114) at
> org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
> Shutting down the session...done.
> {code}
> And the `_-- test_` is the cause of the problem.
> *error info in _flink-llin-sql-client-bigdata00.log_*
> {code:java}
> 2020-09-29 22:10:54,325 ERROR org.apache.flink.table.client.SqlClient
> [] - SQL Client must stop. Unexpected exception. This is a bug.
> Please consider filing an issue.java.lang.NullPointerException: null
> at
> org.apache.flink.table.client.cli.CliClient.callInsert(CliClient.java:598)
> ~[flink-sql-client_2.11-1.11.2.jar:1.11.2]
> at
> org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:315)
> ~[flink-sql-client_2.11-1.11.2.jar:1.11.2]
> at java.util.Optional.ifPresent(Optional.java:159) ~[?:1.8.0_202] at
> org.apache.flink.table.client.cli.CliClient.open(CliClient.java:212)
> ~[flink-sql-client_2.11-1.11.2.jar:1.11.2]
> at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:142)
> ~[flink-sql-client_2.11-1.11.2.jar:1.11.2]
> at org.apache.flink.table.client.SqlClient.start(SqlClient.java:114)
> ~[flink-sql-client_2.11-1.11.2.jar:1.11.2]
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
> [flink-sql-client_2.11-1.11.2.jar:1.11.2]
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
