Page History

...

SHOW RUNNING FLINK SQL JOBS

SHOW QUERIES statements list This statement lists the queries in the Flink cluster, which is similar to flink list in CLI. 

SHOW QUERIES

The result contains three four columns: query_id (namely Flink job id), query_name (namely job name), and status. Alternatively, we could add and a link to the job's web UI address.

...

CANCEL A RUNNING FLINK SQL JOB

This  statement statement cancels a non-terminated query, which is similar to `flink cancel` in CLI. 

...

Since CANCEL QUERY doesn’t trigger a savepoint, the result would be a simple OK, like the one returned by DDL.

CREATE A SAVEPOINT

This statement triggers savepoints for the specified query, which is similar to `flink savepoint` in CLI.

...

+------------------------------------------------------|
|            savepoint_path                            |
+------------------------------------------------------|
| /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab  |
+------------------------------------------------------|

DROP SAVEPOINT

DROP SAVEPOINT statements delete This statement deletes the specified savepoint, which is similar to `flink savepoint –dispose` in CLI.

...