Versions Compared

Old Version 2

changes.mady.by.user Till Rohrmann

Saved on

compared with

New Version 3

changes.mady.by.user Till Rohrmann

Saved on

Key

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

Important Information

Flink 1.13.0 has been released.

Features

List of features announced by contributors and committers that are likely to be ready for the feature freeze:
Runtime

Andrey Zagrebin, Zhu Zhu, Till Rohrmann18620Xintong Song,
Canbin Zheng,
17273
Feature NameProposed byNoteK8s: Support user-specified pod templatesCanbin ZhengK8s: Support built-in init-ContainerCanbin ZhengSupport accessing secured services via K8s secretsCanbin ZhengK8s: Support configuring replica of JobManager Deployment in ZooKeeper HACanbin ZhengK8s: Support to configure limit for CPU requirementCanbin Zheng

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-16430

Reactive -scaling mode

Till Rohrmann

FLIP -138: Declarative Resource managementChesnay Schepler, Till Rohrmannis currently being prepared

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-17075

Chesnay Schepler, Till Rohrmann

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-11127

Robert Metzger, Till Rohrmann

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-16866

Robert Metzger, Till Rohrmann

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-15679

Yangze Guo, Xintong Song, Till RohrmannFLIP-76: Unaligned Checkpoints (improvements and follow ups)Arvid Heise / Zhijiang Wang / Piotr Nowojski

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-18736

Piotr Nowojski
Sub-second end-to-end exactly-once latenciesPiotr Nowojski / Roman KhachatryanFLIP/Jira issue pending
FLIP-135 Approximate Task-Local RecoveryYuan MeiMilestone One

15626

Till Rohrmann


FLIP-141: Intra-Slot Managed Memory SharingXintong Song

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-

20589

Xintong Song

Runtime: various resource manager improvements.

Till Rohrmann


Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-

6042

Till Rohrmann
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-17372

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-

13554

20341

Till Rohrmann

JiraserverASF JIRAcolumnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolutionserverId5aa69414-a9e9-3523-82ec-879b028fb15bkeyFLINK-18229


Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-

18971Yangze Guo

k8s: Support native k8s for sql client, python client and scala shell

Yang Wang,
Canbin Zheng
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-17480
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-17225
Jira issue for sql client pending

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-12884

Yang Wang,
Shengyang Sha

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-15981

Zhijiang WangImprove the performance of batch shuffle

Stephan Ewen,

Zhijiang Wang,

Yingjie Cao

Core APIs (DataStream/DataSet)

...

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-19033

...

Connector APIs

...

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-18323
 

...

10052

Till Rohrmann

...

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-17688
 EFO for Kinesis Consumer

...

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-18858
 Table API support for Kinesis Connector

...

Table API/SQL

...

Table/SQL: 

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-13191

...

FLINK-17480
Feature NameProposed byNote
PyFlink: Improve the usabilities for PyFlinkJincheng SunFLIP-133

PyFlink: PyFlink Table API DSL

Jincheng Sun

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-19091

PyFlink:

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-18761

Jincheng SunFLIP-130
PyFlink: Support Pandas UDAF in batch GroupBy aggregationJincheng SunFLIP-137
PyFlink: PyFlink Table API UDAFJincheng SunFLIP-139: General Python User-Defined Aggregate Function Support on Table API
PyFlink: Support running pyflink jobs on kubernetesJincheng Sun
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
key