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)