Page History

...

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	Xia Sun	Zhu Zhu					2024-01-23
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-31757	RocMarshal	Rui Fan Yangze Guo Zhu Zhu	Accepted				2024-01-22
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-33735	Rui Fan	Zhu Zhu RocMarshal	Done	All features are merge, it only left a little test and doc, so marking it done first.			2024-01-22
FLIP-384: Introduce TraceReporter and use it to create checkpointing and recovery traces	Piotr Nowojski		Done				2024-01-18
FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter	Piotr Nowojski		Done				2024-01-24
FLIP-386: Support adding custom metrics in Recovery Spans	Piotr Nowojski		Done				2024-01-24
FLIP-383: Support Job Recovery for Batch Jobs	Lijie Wang  Junrui Lee	Zhu Zhu	Accepted				2024-01-22
State & Checkpoint
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-30613	Hangxiang Yu						2024-1-15
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34190	Zakelly Lan						2024-1-24
REST
Configuration
FLIP-366: Support standard YAML for FLINK configuration	Junrui Lee	Zhu Zhu					2024-01-26
FLINK-33712 - FLIP-391: Deprecate RuntimeContext#getExecutionConfig	Junrui Lee	Zhu Zhu					2024-01-16
FLINK-33581 - FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects	Junrui Lee	Zhu Zhu					2024-01-16
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34079	Xuannan Su Rui Fan		Done				2024-01-22
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	Jane Chan						2024-01-30
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-33203	@Yangze Guo
FLIP-376: Add DISTRIBUTED BY clause	Timo Walther						2024-01-30
FLIP-392: Deprecate the Legacy Group Window Aggregation FLINK-24024 & FLINK-20281	xuyang			no new flip needed, continue the work on FLINK-24024 & FLINK-20281			2024-01-26
FLIP-393: Make QueryOperations SQL serializable	Dawid Wysakowicz		Done				2024-01-18
FLIP-387: Support named parameters for functions and call procedures	@Feng Jin	xuyang		need documentation			2024-01-30
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	Jane Chan			Under discussion			2024-01-18
FLIP-415: Introduce a new join operator to support minibatch	xu_shuai_	lsy		need documentation			2024-01-30
Connectors
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-31275	Fang Yong Qingsheng Ren						2024-01-22
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-26203	Leonard Xu			Pulsar connector has formal release already			2024-01-23
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-33261	Zhanghao Chen  Dewei Su	Benchao Li		only left for changes in kafka connector			2024-01-22
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-25857 FLIP-371: Provide initialization context for Committer creation in TwoPhaseCommittingSink	Peter Vary	Márton Balassi	Done				2024-01-18
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	Peter Vary	Tzu-Li Tai	Mark it done since main part of the new api been merged (remaining tests and doc)				2024-01-23
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	Peter Vary	Marton Balázs			?
Resource Management
Runtime
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	Piotr Nowojski Weihua Hu RocMarshal					2023-11-23
Misc
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-33325	Yu Chen	Yun Tang	DONE, only docs left				2024-01-23
Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-33230 (will create a FLIP)	Yu Chen	Yun Tang					2024-01-23

...

• Current status of 1.19 Features lincoln lee
  • We extend the feature freeze day to Jan 30th, total 31, done 24;
  • FLIP-376: Add DISTRIBUTED BY clause could be done this week: do we want to wait, or do we want to cut the release branch? Martijn Visser → Will be postponed to 1.20 
• Existing blocker issues lincoln lee

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34148

    Sergey Nuyanzin Zakelly Lan 

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34007

    Matthias Pohl

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34225

    &

    Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34233

    @yunfengzhou

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34272

• When to cut release-1.19 branch?
• Cross-team release testing work

02/06/2024

• Blockers:

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34148

    closed

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34007

    reopened Matthias Pohl

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34225

    &

    Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34233

    closed

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34272

    closed

  • Jira
    server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key FLINK-34337

    pr reviewing jiabao.sun