[Bug] statement sets is error #3937
Labels
bug
Something isn't working
Comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Search before asking
Java Version
1.8.0_191-b12
Scala Version
2.12.x
StreamPark Version
2.1.4
Flink Version
1.17.1
deploy mode
yarn-session
What happened
I want execute statement set,bug it happened error.this is my sql statements
`CREATE TABLE order_info (
order_id INT,
order_time TIMESTAMP(0),
shipment_time TIMESTAMP(0),
time_diff DECIMAL(10, 5),
create_time TIMESTAMP(0),
update_time TIMESTAMP(0),
PRIMARY KEY(order_id) NOT ENFORCED
) WITH (
'connector' = 'mysql-cdc',
'hostname' = 'localhost',
'port' = '3306',
'username' = 'root',
'password' = 'password',
'database-name' = 'test',
'table-name' = 'order_info'
);
CREATE TABLE kafka_table (
order_id INT,
order_time TIMESTAMP(0),
shipment_time TIMESTAMP(0),
time_diff DECIMAL(10, 5),
create_time TIMESTAMP(0),
update_time TIMESTAMP(0),
PRIMARY KEY(order_id) NOT ENFORCED) WITH (
'connector' = 'upsert-kafka',
'topic' = 'binlog_test',
'properties.bootstrap.servers' = 'kafka1:9092,kafka2:9092,kafka3:9092',
'key.format' = 'json',
'value.format' = 'json',
'value.json.fail-on-missing-field' = 'false',
'value.fields-include' = 'all'
);
CREATE TABLE doris_table (
order_id INT,
order_time TIMESTAMP(0),
shipment_time TIMESTAMP(0),
time_diff DECIMAL(10, 5),
create_time TIMESTAMP(0),
update_time TIMESTAMP(0),
PRIMARY KEY(order_id) NOT ENFORCED) WITH (
'connector' = 'doris',
'fenodes' = 'localhost:8080',
'table.identifier' = 'feature_test.order_info',
'username' = 'root',
'password' = 'password',
'sink.properties.format' = 'json',
'sink.properties.read_json_by_line' = 'true'
);
BEGIN STATEMENT SET;
insert into kafka_table select * from order_info;
insert into doris_table select * from order_info;
END;`
Error Exception
Screenshots
No response
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: