THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The result would be a simple OK.
COMPLETE USAGE EXAMPLE
| Code Block | ||
|---|---|---|
| ||
Flink SQL> INSERT INTO tbl_a SELECT * FROM tbl_b;
[INFO] Submitting SQL update statement to the cluster...
[INFO] SQL update statement has been successfully submitted to the cluster:
Job ID: 6b1af540c0c0bb3fcfcad50ac037c862
Flink SQL> SHOW QUERIES;
+----------------------------------+--------------------+---------+---------------------+-------------+----------------------+
| query_id | query_name | status | start_time | duration | web_ur |
+----------------------------------+--------------------+---------|---------------------|-------------|----------------------|
| 6b1af540c0c0bb3fcfcad50ac037c862 | INSERT INTO tbl_a..| RUNNING | 2022-05-01 10:20:33 | 0h 0m 20s | http://127.0.0.1:8081|
+----------------------------------+--------------------+---------+---------------------+-------------+----------------------+
Flink SQL > SAVEPOINT '6b1af540c0c0bb3fcfcad50ac037c862';
+------------------------------------------------------------------|
| savepoint_path |
+------------------------------------------------------------------|
| hdfs://mycluster/flink-savepoints/savepoint-cca7bc-bb1e257f0dab |
+------------------------------------------------------------------|
Flink SQL > DROP QUERY '6b1af540c0c0bb3fcfcad50ac037c862' PURGE;
[INFO] The specified query is dropped without savepoint.
Flink SQL > RELEASE SAVEPOINT 'hdfs://mycluster/flink-savepoints/savepoint-cca7bc-bb1e257f0dab';
[INFO] The specified savepoint is removed. |
SQL Parser & Planner
To support the new statements, we need to introduce new SQL operators for SQL parser and new SQL operations for the planner.
...