[
https://issues.apache.org/jira/browse/FLINK-33366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
macdoor615 updated FLINK-33366:
-------------------------------
Description:
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}
was:
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}
> 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
> Priority: Major
>
> 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)
