Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Current state: "Under Discussion"

Discussion thread: TBD (<- link to https://mail-archiveslists.apache.org/thread/qkvh9p5w9b12s7ykh3l7lv7m9dbgnf1gmod_mbox/flink-dev/)

JIRA: TBD

Released: <Flink Version>

...

To support the new statements, we need to introduce new SQL operators for SQL parser and new SQL operations for the planner.

SQL operator

SQL operation

SqlShowQueries

ShowQueriesOperation

SqlStopQuery

StopQueryOperation

SqlCancelQuery

CancelQueryOperation

SqlTriggerSavepoint

TriggerSavepointOperation

SqlDisposeSavepoint

DisposeSavepointOperation

Executor

Executor would need to convert the query lifecycle operations into ClusterClient commands.

SQL operation

Cluster Client Command

ShowQueriesOperation

ClusterClient#listJobs

StopQueryOperation

ClusterClient#stoplWithSavepoint

CancelQueryOperation

ClusterClient#cancel

TriggerSavepointOperation

ClusterClient#triggerSavepoint

DisposeSavepointOperation

ClusterClient#disposeSavepoint

Implementation Plan

The implementation plan would be simple:

...