macdoor615 created FLINK-33366:
----------------------------------
Summary: can not accept statement "EXECUTE STATEMENT SET BEGIN"
Key: FLINK-33366
URL: https://issues.apache.org/jira/browse/FLINK-33366
Project: Flink
Issue Type: Bug
Components: Table SQL / JDBC
Affects Versions: 1.18.0
Environment: Flink 1.18.0
Apache Hive beeline 3.2.3
Reporter: macdoor615
put flink-sql-jdbc-driver-bundle-1.18.0.jar in $HIVE_HOME/lib
start beeline -u xxxx
create table
{code:java}
CREATE TABLE table_a (
a int
) WITH (
'connector' = 'print'
); {code}
output
{code:java}
0: jdbc:flink://xxxx:8085> CREATE TABLE table_a (
. . . . . . . . . . . . . . . . . . . > a int
. . . . . . . . . . . . . . . . . . . > ) WITH (
. . . . . . . . . . . . . . . . . . . > 'connector' = 'print'
. . . . . . . . . . . . . . . . . . . > );
No rows affected (1.119 seconds) {code}
execute statement "EXECUTE STATEMENT SET BEGIN" and get failure output
{code:java}
0: jdbc:flink://xxx:8085>
0: jdbc:flink://xxx:8085> EXECUTE STATEMENT SET
. . . . . . . . . . . . . . . . . . . > BEGIN
. . . . . . . . . . . . . . . . . . . > insert into table_a values (1);
The SQL statement is incomplete.
0: jdbc:flink://hb3-dev-euler-001:8085> end;
{code}
execute statement "BEGIN STATEMENT SET;" and get success output
{code:java}
0: jdbc:flink://xxxx:8085> BEGIN STATEMENT SET;
No rows affected (0.118 seconds)
0: jdbc:flink://xxxx:8085> insert into table_a values (1);
No rows affected (0.114 seconds)
0: jdbc:flink://hb3-dev-euler-001:8085> end;
+-----------------------------------+
| job id |
+-----------------------------------+
| 1f34ba20cee6a35f2f8b69636ea55d29 |
+-----------------------------------+ {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
