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)

Reply via email to