Flink 1.13 Burndown (blockers and critical bugs): https://issues.apache.org/jira/secure/RapidBoard.jspa?rapidView=445
Features
List of features announced by contributors and committers that are likely to be ready for the feature freeze:
Distributed Coordination
Note | Reactive mode | | FLIP is currently being prepared | NoteF |
---|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-10407 |
---|
|
| |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-15626 |
---|
|
| |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-20589 |
---|
|
| |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-6042 |
---|
|
| |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-20341 |
---|
|
| |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-10052 |
---|
|
| |
Table/SQL: FLIP-145: Support SQL windowing table-valued function | | Table/SQL: Solve all the time-zone related problems | | FLIP is currently being prepared |
Table/SQL: Improve the usability around SQL Client | | FLIP is currently being prepared |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20976Tzu-Li Tai Kostas Kloudas Dawid Wysakowicz | |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20491Aljoscha Krettek147: Support Checkpoints After Tasks FinishedYun Gao Guowei Ma156: Runtime Interfaces for Fine-Grained Resource Requirements | |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20479HuangXingbo | |
|
Support ship local/remote files for yarn/k8s integrations. Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
19185 | API/Python: FLIP-153: Support state access in Python DataStream API | | FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements | | Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
14187Yangze Guo Xintong Song | Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20988 | |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20663 | Support ship local/remote files for yarn/k8s integrations.
|
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20681 | |
|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20811 | |
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-21110 |
---|
|
| |
|
Table API/SQL
Feature Name | Proposed by | Note |
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-19604 |
---|
|
| |
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-21617 |
---|
|
| | FLIP is currently being prepared |
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-21454 |
---|
|
| Shengkai Fang | FLIP is currently being prepared |
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-21529 |
---|
|
| |
|
FLIP-136: Improve interoperability between DataStream and Table API | Timo Walther |
|
WebUI
Feature Name | Proposed by | Note |
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-14712 |
---|
|
| |
|
DataStream API
Feature Name | Proposed by | Note |
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-20491 |
---|
|
| |
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-19463 |
---|
|
| Seth Wiesman |
|
Savepoints/Checkpoints
Feature Name | Proposed by | Note |
---|
Jira |
---|
server | ASF JIRA |
---|
columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-20976 |
---|
|
| |
|
FLIP-147: Support Checkpoints After Tasks Finished | |
|
FLIP-158: Generalized incremental checkpoints | |
|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-19462 |
---|
|
| |
|
FLIP-151: Incremental snapshots for heap-based state backend | |
|
FLIP-76: Unaligned Checkpoints (rescaling and time outing aligned to unaligned checkpoints) | |
|
State Backends
Feature Name | Proposed by | Note |
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-20496 |
---|
|
| Yu Li | Proposed by YuFei Liu and reviewed by Yu Li |
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK- |
---|
|
|
20867Python API
Connectors
Feature Name | Proposed by | Note |
---|
Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | FLINK-15578 |
---|
|
| | Usability sprint (2019) |
Xintong Song