THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!

Page History

Versions Compared

Key

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

...

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

2024-01-23

Jira

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

Rui Fan Yangze Guo Zhu Zhu

Accepted

2024-01-22

Jira

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

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

Done

2024-01-18

FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

Done

2024-01-24

FLIP-386: Support adding custom metrics in Recovery Spans

Done

2024-01-24

FLIP-383: Support Job Recovery for Batch Jobs

Accepted

2024-01-22

State & Checkpoint

Jira

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

2024-1-15

Jira

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

2024-1-24

REST

Configuration

FLIP-366: Support standard YAML for FLINK configuration

2024-01-26

FLINK-33712 - FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2024-01-16

FLINK-33581 - FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

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

2024-01-30

Jira

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

@Yangze Guo

FLIP-376: Add DISTRIBUTED BY clause

2024-01-30

~~FLIP-392: Deprecate the Legacy Group Window Aggregation~~

FLINK-24024 & FLINK-20281

no new flip needed, continue the work on FLINK-24024 & FLINK-20281

2024-01-26

FLINK-20281: N/A

FLIP-393: Make QueryOperations SQL serializable

Dawid Wysakowicz

Done

2024-01-18

N/A

FLIP-387: Support named parameters for functions and call procedures

@Feng Jin

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

Under discussion

2024-01-18

FLIP-415: Introduce a new join operator to support minibatch

need documentation

2024-01-30

FLIP-400: AsyncScalarFunction for asynchronous scalar function support

Needs documentation

2024-02-05

Connectors

Jira

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

2024-01-22

Jira

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

Pulsar connector has formal release already

2024-01-23

Jira

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

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

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

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

Resource Management

Runtime

Jira

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

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

Piotr Nowojski Weihua Hu RocMarshal

2023-11-23

Misc

Jira

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

DONE, only docs left

2024-01-23

Jira

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

(will create a FLIP)

2024-01-23

...