Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Not A Bug
-
1.18.0
-
None
-
None
-
Flink 1.18.0
Apache Hive beeline 3.2.3
-
This is an issue of beeline 3.2.3, not Flink JDBC Driver's
Description
put flink-sql-jdbc-driver-bundle-1.18.0.jar in $HIVE_HOME/lib
start beeline -u xxxx
create table
CREATE TABLE table_a ( a int ) WITH ( 'connector' = 'print' );
output
0: jdbc:flink://xxxx:8085> CREATE TABLE table_a ( . . . . . . . . . . . . . . . . . . . > a int . . . . . . . . . . . . . . . . . . . > ) WITH ( . . . . . . . . . . . . . . . . . . . > 'connector' = 'print' . . . . . . . . . . . . . . . . . . . > ); No rows affected (1.119 seconds)
execute statement "EXECUTE STATEMENT SET BEGIN" and get failure output
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;
execute statement "BEGIN STATEMENT SET;" and get success output
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://xxxxx:8085> end; +-----------------------------------+ | job id | +-----------------------------------+ | 1f34ba20cee6a35f2f8b69636ea55d29 | +-----------------------------------+