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 |
| |
| 2023-12-12 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-31757 |
---|
|
| | | Accepted |
| |
| 2023-12-04 |
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33735 |
---|
|
| | | Accepted |
| |
| 2023-12-04 |
|
|
|
|
FLIP-384: Introduce TraceReporter and use it to create checkpointing and recovery traces | |
|
|
| |
|
|
|
|
|
|
FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter | Piotr Nowojski |
|
|
| |
|
|
|
|
|
|
FLIP-383: Support Job Recovery for Batch Jobs | | |
| under discussion |
|
| 2023-12-12 |
|
|
|
|
State & Checkpoint |
|
|
|
|
|
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-29844 |
---|
|
| |
|
|
|
|
|
|
|
|
|
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Configuration |
|
|
|
|
|
|
|
|
|
|
|
FLIP-366: Support standard YAML for FLINK configuration
| | | FLIP Accepted |
| |
| 2023-12-12 |
|
|
|
|
FLINK-33712 - FLIP-391: Deprecate RuntimeContext#getExecutionConfig | | | FLIP Accepted |
| |
| 2023-12-12 |
|
|
|
|
FLINK-33581 - FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects | | |
|
| |
| 2023-12-12 |
|
|
|
|
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 |
---|
|
| |
|
|
| |
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33203 |
---|
|
| |
|
|
| |
|
|
|
|
|
|
FLIP-376: Add DISTRIBUTED BY clause | |
|
|
| |
|
|
|
|
|
|
FLIP-392: Deprecate the Legacy Group Window Aggregation | |
|
|
| |
|
|
|
|
|
|
FLIP-393: Make QueryOperations SQL serializable | |
|
|
| |
|
|
|
|
|
|
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 |
---|
|
| |
|
|
|
|
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33261 |
---|
|
| | |
|
| |
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-25857 |
---|
|
FLIP-371: Provide initialization context for Committer creation in TwoPhaseCommittingSink | | |
| Accepted |
|
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33328 |
---|
|
FLIP-372: Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable | | |
| Under discussion |
|
|
|
|
|
|
|
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 |
---|
|
| | |
|
|
|
|
|
|
|
|
|
Resource Management |
|
|
|
|
|
|
|
|
|
|
|
---|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33625 |
---|
|
| Rui Fan | RocMarshal | Done |
| |
| 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 | |
|
| |
| 2023-11-23 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| | |
|
|
|
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33325 |
---|
|
| | |
| Accepted | |
|
|
|
|
|
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-33230 |
---|
|
(will create a FLIP) | | |
| Under discussion |
|
|
|
|
|
|
|