Page tree
Skip to end of metadata
Go to start of metadata

Important Information

Flink 1.12.0 has been released.

Features

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

Runtime

Feature NameProposed byNote
K8s: Support user-specified pod templatesCanbin Zheng
K8s: Support built-in init-ContainerCanbin Zheng
Support accessing secured services via K8s secretsCanbin Zheng
K8s: Support configuring replica of JobManager Deployment in ZooKeeper HACanbin Zheng
K8s: Support to configure limit for CPU requirementCanbin Zheng

FLINK-16430 - Getting issue details... STATUS

Andrey Zagrebin, Zhu Zhu, Till Rohrmann
Reactive-scaling modeTill Rohrmann
FLIP-138: Declarative Resource managementChesnay Schepler, Till Rohrmann

FLINK-17075 - Getting issue details... STATUS

Chesnay Schepler, Till Rohrmann

FLINK-11127 - Getting issue details... STATUS

Robert Metzger, Till Rohrmann

FLINK-16866 - Getting issue details... STATUS

Robert Metzger, Till Rohrmann

FLINK-15679 - Getting issue details... STATUS

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

FLINK-18736 - Getting issue details... STATUS

Piotr Nowojski
Sub-second end-to-end exactly-once latenciesPiotr Nowojski / Roman KhachatryanFLIP/Jira issue pending
FLIP-135 Approximate Task-Local RecoveryYuan MeiMilestone One
FLIP-141: Intra-Slot Managed Memory SharingXintong Song

FLINK-18620 - Getting issue details... STATUS

Xintong Song

Runtime: various resource manager improvements.

Xintong Song,
Canbin Zheng,
Till Rohrmann

FLINK-17273 - Getting issue details... STATUS
FLINK-17372 - Getting issue details... STATUS
FLINK-13554 - Getting issue details... STATUS
FLINK-18229 - Getting issue details... STATUS

FLINK-18971 - Getting issue details... STATUS

Yangze Guo

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

Yang Wang,
Canbin Zheng

FLINK-17480 - Getting issue details... STATUS
FLINK-17225 - Getting issue details... STATUS
Jira issue for sql client pending

FLINK-12884 - Getting issue details... STATUS

Yang Wang,
Shengyang Sha


FLINK-15981 - Getting issue details... STATUS

Zhijiang Wang
Improve the performance of batch shuffle

Stephan Ewen,

Zhijiang Wang,

Yingjie Cao


Core APIs (DataStream/DataSet)

Connector APIs

Feature NameProposed byNote
Unified Sink InterfaceGuowei / YunFLIP/Jira issue pending
Extend StreamingFileSink to handle the “small file problem”Jingsong / Yun GaoFLIP/Jira issue pending

FLINK-18323 - Getting issue details... STATUS  

Becket Qin
FLIP-33: Standardize Connector MetricsBecket Qin
Hybrid Source to support switch over between sources in the same job.Xiaofeng Jiang
Connector Testing FrameworkQingsheng Ren

FLINK-17688 - Getting issue details... STATUS  EFO for Kinesis Consumer

Tzu-Li (Gordon) Tai, Danny Cranmer, Roland

FLINK-18858 - Getting issue details... STATUS  Table API support for Kinesis Connector

Waldemar Hummer, Alexander Alexandrov, Danny Cranmer

Table API/SQL

Feature NameProposed byNote

Table/SQL:  FLINK-13191 - Getting issue details... STATUS

Timo Walther
Table/SQL: FLIP-129: Refactor Descriptor APIJark Wu
Table/SQL: FLIP-132 Temporal Table DDL and Temporal Table JoinLeonard Xu
Table/SQL: Compiling multi-input operator to reduce unnecessary shuffleGodfrey He
Table/SQL: FLIP-145: Support SQL windowing table-valued functionJark & Danny
Table/SQL: Hive query compatibilityRui LiFLIP/Jira issue pending
Table/SQL: CREATE FUNCTION USING JARJark WuFLIP/Jira issue pending
Table/SQL: FLIP-136: Improve interoperability between DataStream and Table API Timo Walther
Table/SQL: FLIP-107: Handling of metadata in SQL connectorsTimo Walther
FLIP-36: Support Interactive Programming in FlinkXuannan Su
Feature NameProposed byNote
PyFlink: Improve the usabilities for PyFlinkJincheng SunFLIP-133

PyFlink: PyFlink Table API DSL

Jincheng Sun

FLINK-19091 - Getting issue details... STATUS

PyFlink: FLINK-18761 - Getting issue details... STATUS

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

FLINK-17480 - Getting issue details... STATUS

  • No labels