[
https://issues.apache.org/jira/browse/FLINK-36929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-36929:
----------------------------------
Release Note:
SQL Connector for Reading Keyed Savepoint State
As part of this release, Flink introduces a new SQL connector for keyed
savepoints (FLIP-496). This connector allows users to query keyed state
directly from savepoints using SQL, making it easier to inspect, debug, and
validate the state of Flink jobs without custom tooling.
With simple DDL, you can expose ValueState as a table and run SQL queries over
the snapshot:
```
CREATE TABLE keyed_state (
k INTEGER,
user_id STRING,
balance DOUBLE
) WITH (
'connector' = 'savepoint',
'path' = 'file:///savepoint/path',
'uid' = 'my-operator'
);
```
This feature is especially useful for analyzing long-running jobs and
validating state migrations.
> SQL connector for keyed savepoint data
> --------------------------------------
>
> Key: FLINK-36929
> URL: https://issues.apache.org/jira/browse/FLINK-36929
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
> Affects Versions: 2.0-preview
> Reporter: Gabor Somogyi
> Assignee: Gabor Somogyi
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.1.0
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
