tim yu created FLINK-36774:
------------------------------
Summary: SQL gateway should support executing multiple SQL
statements once
Key: FLINK-36774
URL: https://issues.apache.org/jira/browse/FLINK-36774
Project: Flink
Issue Type: New Feature
Components: Table SQL / Gateway
Reporter: tim yu
I have a flink SQL file example.sql that contain the following SQL statements:
{code:java}
set 'state.checkpoints.dir' = 'hdfs:///tmp/flink-checkpoints/datagen_blackhole';
set 'execution.checkpointing.interval' = '3min';
set 'execution.checkpointing.timeout' = '20min';
set 'parallelism.default' = '1';
CREATE TABLE t1 (id BIGINT, info STRING) with ('connector' = 'datagen',
'rows-per-second' = '1', 'fields.id.min' = '1', 'fields.id.max' = '10');
CREATE TABLE black_hole_1 WITH ('connector' = 'blackhole') LIKE t1 (EXCLUDING
ALL);
insert into black_hole_1 select * from t1;{code}
I hope that submit this file to SQL gateway by using the following command:
{code:java}
curl -d '@example.sql' -H 'Content-Type: application/json'
http://gateway:8083/v1/sessions/{session_id}/statements {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)