Runtime |
|
---|
Name/JIRA Issue | Responsible Contributor | Reviewer / committer available | Feature Stage | Note | State | % | Updated | Implemented | Documented | X-team verified | Volunteers for testing |
---|
Shuffle |
|
|
|
|
|
|
|
|
|
|
|
---|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Coordination |
|
|
|
|
|
|
|
|
|
|
|
---|
FLIP-379: Dynamic source parallelism inference for batch jobs | | |
|
| Accepted![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) | ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
| 20232024-1201-1223 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-31757 |
---|
|
| | | Accepted |
| ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) ![(minus)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/forbidden.svg) |
| 20232024-1201-0422 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33735 |
---|
|
| | | Accepted | ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) | Done | All features are merge, it only left a little test and doc, so marking it done first. | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-222023-12-04 |
|
|
|
|
FLIP-384: Introduce TraceReporter and use it to create checkpointing and recovery traces | |
| AcceptedDone |
| ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 20232024-1201-2618 | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
|
|
|
FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter | Piotr Nowojski |
| AcceptedDone |
| ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 20232024-1201-2624 | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
|
|
|
FLIP-386: Support adding custom metrics in Recovery Spans | |
| Done |
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-24 | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
|
|
|
FLIP-383: Support Job 383: Support Job Recovery for Batch Jobs | | | Accepted |
| ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) ![(minus)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/forbidden.svg) |
| 20232024-1201-2622 |
|
|
|
|
State & Checkpoint |
|
|
|
|
|
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-30613 |
---|
|
| |
|
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-1-15 | REST
|
|
|
|
| Configuration | server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-34190 |
---|
|
| |
|
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-1-24 |
|
|
|
|
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Configuration |
|
|
|
|
|
|
|
|
|
|
|
FLIP-366: Support standard YAML for FLINK configuration | | FLIP-366: Support standard YAML for FLINK configuration
| | FLIP Accepted | ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-262023-12-12 |
|
|
|
|
FLINK-33712 - FLIP-391: Deprecate RuntimeContext#getExecutionConfig | | | FLIP Accepted | ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-162023-12-12 |
|
|
|
|
FLINK-33581 - FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects | | |
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 20232024-1201-1216 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-34079 |
---|
|
| | | FLIP AcceptedDone |
| ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-101-1522 |
|
|
|
|
SQL
|
|
---|
Name/JIRA Issue | Responsible Contributor | Reviewer / committer available | Feature Stage | Note | State | % | Updated | Implemented | Documented | X-team verified |
|
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33397 |
---|
|
| ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
|
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-30 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33203 |
---|
|
| |
|
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
|
|
|
|
|
|
FLIP-376: Add DISTRIBUTED BY clause | ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
|
|
| ![(minus)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/forbidden.svg) |
| 2024-01-30 |
|
|
|
|
FLIP-392: Deprecate the Legacy Group Window Aggregation
FLINK-24024 & FLINK-20281 | |
|
| no no new flip needed, continue the work on on FLINK-24024 & FLINK-20281 | ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-101-926 |
| FLINK-24024: ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) FLINK-20281: N/A |
|
|
FLIP-FLIP-393: Make QueryOperations SQL serializable | |
| Done |
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-18 | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) | N/A![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
|
|
FLIP-387: Support named parameters for functions and call procedures | | xuyang |
| Under discussionneed documentation | ![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 20232024-1201-2630 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
columnIds | issuekey,summary,issuetype,created,updated,duedate,assignee,reporter,customfield_12311032,customfield_12311037,customfield_12311022,customfield_12311027,priority,status,resolution |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,Priority,Priority,Priority,Priority,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-31830 |
---|
|
| |
|
| Under discussion | ![(minus)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/forbidden.svg) |
| 20242023-1201-2618 |
|
|
|
|
| | |
| need documentation | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-30 |
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
|
| | Timo Walther |
| Needs documentation | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-02-05 | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
|
|
|
Connectors |
|
|
|
|
|
|
|
|
|
|
|
---|
| Connectors | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-31275 |
---|
|
| | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-26203 |
---|
| Leonard Xu | |
|
|
| ![(minus)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/forbidden.svg) |
| 2024-01-22 |
|
|
|
|
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33261 |
---|
|
| | | | | |
| Pulsar connector has formal release already | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-23![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-2585733261 |
---|
|
| | |
| only left for changes in kafka connector | ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-22 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-25857 |
---|
|
FLIPFLIP-371: Provide initialization context for Committer creation in TwoPhaseCommittingSink | | | AcceptedDone |
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-18 |
|
|
|
|
Jira |
---|
| Jira |
---|
server | ASF JIRA |
---|
columnIds | issuekey,summary,issuetype,created,updated,duedate,assignee,reporter,customfield_12311032,customfield_12311037,customfield_12311022,customfield_12311027,priority,status,resolution |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,Priority,Priority,Priority,Priority,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33972 |
---|
|
FLIP-372: Enhance and synchronize Sink API to match the Source API | | | Mark it done since main part of the new api been merged (remaining tests and doc) |
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-23FLIP Accepted |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
columnIds | issuekey,summary,issuetype,created,updated,duedate,assignee,reporter,customfield_12311032,customfield_12311037,customfield_12311022,customfield_12311027,priority,status,resolution |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,Priority,Priority,Priority,Priority,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33528 |
---|
|
| | |
|
| ![(minus)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/forbidden.svg) |
|
|
|
|
|
|
Resource Management |
|
|
|
|
|
|
|
|
|
|
|
---|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33625 |
---|
|
| Rui Fan | RocMarshal | Done |
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2023-12-04 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33315 |
---|
|
A series of optimizations to reduce the memory and cpu usage for large StreamOperator | Rui Fan | |
|
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2023-11-23 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| | |
|
|
|
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33325 |
---|
|
| | | Accepted | DONE, only docs left |
| ![(tick)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/check.svg) |
| 2024-01-23![(green star)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/star_green.svg) |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33230 |
---|
|
(will create a FLIP) | | |
|
| ![(minus)](/confluence/s/34gb19/8804/10mvnxf/_/images/icons/emoticons/forbidden.svg) |
| 2024-01-23 |
|
|
|
|