| FLIP | Description | Component | Target Release | +1 | 0 | -1 | Created by | State | JIRA | More Info |
|---|---|---|---|---|---|---|---|---|---|---|
| 563 | FLIP-563 Support provided lib archives for YARN application mode | 0 | 0 | 0 | Archit Goyal | in progress | FLINK-38958 | info | ||
| 562 | FLIP-562: Topic integrity checks in Kafka Connector | 0 | 0 | 0 | Efrat Levitan | under discussion | info | |||
| 561 | FLIP-561: Restructure Flink documentation |
4
Zhu Zhu
David Anderson Leonard Xu Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Martijn Visser | in progress | FLINK-38945 | info | ||
| 560 | FLIP-560: Application Capability Enhancement |
5
Shengkai Fang
Zhu Zhu Yuepeng Pan Rui Fan <1996fanrui@gmail.com> gyula.fora@gmail.com |
0 | 0 | Yi Zhang | in progress | FLINK-38972 | info | ||
| 559 | FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause | 0 | 0 | 0 | Mika Naylor | under discussion | info | |||
| 558 | FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder |
3
Martijn Visser
Timo Walther Sergey Nuyanzin |
0 | 0 | Dawid Wysakowicz | in progress | FLINK-38926 | info | ||
| 557 | FLIP-557: Granular Control over Data Reprocessing and State Retention in Materialized Table Evolution | 0 | 0 | 0 | Ramin Gharib | under discussion | info | |||
| 556 | FLIP-556: Introduce BITMAP Data Type |
3
Ron Liu
Shengkai Fang Lincoln Lee |
0 | 0 | lincoln lee | unknown | info | |||
| 555 | FLIP-555: Flink Native S3 FileSystem | 0 | 0 | 0 | Samrat Deb | in progress | FLINK-38592 | info | ||
| 554 | FLIP-554 Pipeline Testing Framework for Flink |
4
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?=
Gyula Fora Gabor Somogyi Ferenc Csaky |
0 | 0 | Matyas Orhidi | unknown | info | |||
| 553 | FLIP-553: Robust OTel gRPC metric exporter |
3
Piotr Nowojski
Rui Fan <1996fanrui@gmail.com> Sergey Nuyanzin |
0 | 0 | Piotr Nowojski | in progress | FLINK-38603 | info | ||
| 552 | FLIP-552 Support ML_PREDICT for Python based model providers | 0 | 0 | 0 | Matyas Orhidi | unknown | info | |||
| 551 | FLIP-551: Make FRESHNESS Optional for Materialized Tables | Flink | 2.2 |
3
Arvid Heise
Dawid Wysakowicz Feng Jin |
0 | 0 | Ramin Gharib | unknown | info | |
| 550 | FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs |
5
Ron Liu
Arvid Heise Timo Walther Feng Jin Lincoln Lee |
0 | 0 | Sergey Nuyanzin | in progress | FLINK-38673 | info | ||
| 549 | FLIP-549: Support Application Management |
3
Zhu Zhu
Shengkai Fang Junrui Lee |
0 | 0 | Yi Zhang | in progress | FLINK-38755 | info | ||
| 548 | FLIP-548: Introduce Tool and Agent in Flink SQL | 0 | 0 | 0 | Hao Li | under discussion | info | |||
| 547 | FLIP-547: Support checkpoint during recovery |
4
Roman Khachatryan
Zakelly Lan Gabor Somogyi Piotr Nowojski |
0 | 0 | Rui Fan | in progress | FLINK-35761 | info | ||
| 546 | FLIP-546: Introduce CREATE OR ALTER for Materialized Tables |
5
Arvid Heise
Ron Liu Sergey Nuyanzin Timo Walther Lincoln Lee |
0 | 0 | Ramin Gharib | completed | FLINK-38355 | info | ||
| 545 | FLIP-545: Hardening the Event Reporter with an Asynchronous Core | 0 | 0 | 0 | Piotr Nowojski | under discussion | info | |||
| 544 | FLIP-544: SinkUpsertMaterializer V2 |
6
Zakelly Lan
Ferenc Csaky Lincoln Lee Piotr Nowojski Rui Fan <1996fanrui@gmail.com> Martijn Visser |
0 | 0 | Roman Khachatryan | in progress | FLINK-38459 | info | ||
| 543 | FLIP-543: Support Customized Autoscale Algorithm | 0 | 0 | 0 | Zhenqiu Huang | in progress | FLINK-38283 | info | ||
| 542 | FLIP-542: Make materialized table DDL consistent with regular tables |
3
Ron Liu
Timo Walther Feng Jin |
0 | 0 | Sergey Nuyanzin | completed | FLINK-38311 | info | ||
| 541 | FLIP-541: Making PyFlink more Pythonic (Phase-1) |
5
Shengkai Fang
Zakelly Lan Xingbo Huang Dian Fu Martijn Visser |
0 | 0 | Dian Fu | unknown | info | |||
| 540 | FLIP-540: Support VECTOR_SEARCH in Flink SQL |
3
Shengkai Fang
Timo Walther Lincoln Lee |
0 | 0 | Shengkai Fang | in progress | FLINK-38422 | info | ||
| 539 | FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL |
2
Timo Walther
Sergey Nuyanzin |
0 | 0 | Dawid Wysakowicz | completed | FLINK-38198 | info | ||
| 538 | FLIP-538: Support Custom Generic Type Serializer | 0 | 0 | 0 | Zhanghao Chen | under discussion | info | |||
| 537 | FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. | Flink | 2.2 |
2
Hang Ruan
Leonard Xu |
0 | 0 | Hongshun Wang | completed | FLINK-38564 | info |
| 536 | FLIP-536: Add latest checkpoint details endpoint to Rest API | Flink | 2.1 | 0 | 0 | 0 | Ahmed Hamdy | in progress | FLINK-38120 | info |
| 535 | FLIP-535: Introduce RateLimiter to Source |
3
Leonard Xu
Shengkai Fang Yanquan Lv |
0 | 0 | Yanquan | unknown | info | |||
| 534 | FLIP-534 Reduce OLAP Query Latency In Flink Session Cluster. | 0 | 0 | 0 | wangwj | in progress | FLINK-37754 | info | ||
| 533 | FLIP-533: Cassandra Sink V2 |
4
Danny Cranmer
=?UTF-8?Q?Gyula_F=C3=B3ra?= Etienne Chauchot Ferenc Csaky |
0 | 0 | Etienne Chauchot | unknown | info | |||
| 532 | FLIP-532: Donate GetInData HTTP Connector to Flink |
3
Leonard Xu
=?UTF-8?Q?Gyula_F=C3=B3ra?= Ferenc Csaky |
0 | 0 | David Radley | in progress | FLINK-38245 | info | ||
| 531 | FLIP-531: Initiate Flink Agents as a new Sub-Project |
20
Ron Liu
weijie guo Robert Metzger Jark Wu Becket Qin Feng Jin Xingbo Huang Leonard Xu Dian Fu Lincoln Lee Yuan Mei Hangxiang Yu Martijn Visser Jing Ge Zhu Zhu Rui Fan <1996fanrui@gmail.com> Guowei Ma Qingsheng Ren Zakelly Lan Ferenc Csaky |
0 | 0 | Xintong Song | under discussion | info | |||
| 530 | FLIP-530: Dynamic job configuration | Flink | 2.0 |
4
Hangxiang Yu
Piotr Nowojski Rui Fan <1996fanrui@gmail.com> Junrui Lee |
0 | 0 | Roman Khachatryan | in progress | FLINK-37853 | info |
| 529 | FLIP-529: Connections in Flink SQL and TableAPI |
5
Shengkai Fang
Ferenc Csaky Timo Walther Lincoln Lee Leonard Xu |
0 | 0 | Mayank Juneja | in progress | FLINK-38259 | info | ||
| 528 | FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL |
3
Dawid Wysakowicz
Piotr Nowojski Sergey Nuyanzin |
0 | 0 | Ramin Gharib | completed | FLINK-38081 | info | ||
| 527 | FLIP-527: State Schema Evolution for RowData | 0 | 0 | 0 | Weiqing Yang | under discussion | info | |||
| 526 | FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API |
4
Shengkai Fang
Piotr Nowojski Timo Walther Robert Metzger |
0 | 0 | Hao Li | completed | FLINK-38104 | info | ||
| 525 | FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design |
5
Ron Liu
Shengkai Fang Sergey Nuyanzin Piotr Nowojski Martijn Visser |
0 | 0 | Hao Li | in progress | FLINK-37777 | info | ||
| 524 | FLIP-524: CloudWatch Metric Sink Connector |
4
Danny Cranmer
Hong Liang Ferenc Csaky Robert Metzger |
0 | 0 | Hong Liang Teoh | under discussion | info | |||
| 523 | FLIP-523: Handle TLS Certificate Renewal |
3
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?=
=?UTF-8?Q?Gyula_F=C3=B3ra?= Gabor Somogyi |
0 | 0 | Oleksandr Nitavskyi | in progress | FLINK-37504 | info | ||
| 522 | FLIP-522: Add generalized type information to SQL state connector | Flink | 2.1.0 |
3
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?=
Zakelly Lan =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Gabor Somogyi | completed | FLINK-37674 | info |
| 521 | FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing | Flink | 2.1 |
6
Ron Liu
Timo Walther Lincoln Lee Leonard Xu =?UTF-8?Q?Gyula_F=C3=B3ra?= Xintong Song |
0 | 0 | Xuannan Su | in progress | FLINK-37922 | info |
| 520 | FLIP-520: Simplify StructuredType handling |
3
Ron Liu
Ferenc Csaky Sergey Nuyanzin |
0 | 0 | Timo Walther | in progress | FLINK-37861 | info | ||
| 519 | FLIP-519: Introduce async lookup key ordered mode |
3
Ron Liu
Zakelly Lan Lincoln Lee |
0 | 0 | xu_shuai_ | in progress | FLINK-37874 | info | ||
| 518 | FLIP-518: Introduce a community review process |
3
Hong Liang
Ferenc Csaky Robert Metzger |
0 | 0 | David Radley | not accepted | FLINK-37770 | info | ||
| 517 | FLIP-517: Better Handling of Dynamic Table Primitives with PTFs | 0 | 0 | 0 | Timo Walther | under discussion | info | |||
| 516 | FLIP-516: Multi-Way Join Operator |
5
Arvid Heise
Ron Liu Zakelly Lan Timo Walther Dawid Wysakowicz |
0 | 0 | Gustavo de Morais | not accepted | FLINK-37481 | info | ||
| 515 | FLIP-515: Dynamic Kafka Sink |
5
Thomas Weise
Maximilian Michels Alexander Fedulov gyula.fora@gmail.com Gabor Somogyi |
0 | 0 | Matyas Orhidi | unknown | info | |||
| 514 | FLIP-514: Custom Evaluator plugin for Flink Autoscaler |
4
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?=
=?UTF-8?Q?Gyula_F=C3=B3ra?= Maximilian Michels Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Gyula Fora | unknown | info | |||
| 513 | FLIP-513: Split-level Watermark Metrics |
3
Roman Khachatryan
Stefan Richter Piotr Nowojski |
0 | 0 | Efrat Levitan | unknown | info | |||
| 512 | FLIP-512: Add meta information to SQL state connector | Flink | 2.1 |
6
Shengkai Fang
Zakelly Lan Ferenc Csaky Lincoln Lee Rui Fan <1996fanrui@gmail.com> =?UTF-8?Q?Gyula_F=C3=B3ra?= |
0 | 0 | Gabor Somogyi | completed | FLINK-37407 | info |
| 511 | FLIP-511: Support transaction id pooling in Kafka connector |
4
Roman Khachatryan
Martijn Visser =?UTF-8?Q?Gyula_F=C3=B3ra?= Piotr Nowojski |
0 | 0 | Arvid Heise | completed | FLINK-34554 | info | ||
| 510 | FLIP-510: Drop ChangelogNormalize for operations which don't need it | Flink | 2.1.0 |
5
Sergey Nuyanzin
Timo Walther Jiabao Sun Leonard Xu Martijn Visser |
0 | 0 | Dawid Wysakowicz | completed | FLINK-37474 | info |
| 509 | FLIP-509 Add pluggable Batching for Async Sink | Flink | 2.1 |
3
Danny Cranmer
Hong Liang Arvid Heise |
0 | 0 | Ahmed Hamdy | completed | FLINK-37298 | info |
| 508 | FLIP-508: Add support for Smile format for Compiled plans | Flink | 2.1.0 |
3
Martijn Visser
=?UTF-8?Q?Fabian_H=C3=BCske?= Timo Walther |
0 | 0 | Sergey Nuyanzin | completed | FLINK-37341 | info |
| 507 | FLIP-507: Add Model DDL methods in TABLE API |
4
Dawid Wysakowicz
Mingge Deng Leonard Xu Timo Walther |
0 | 0 | Yash Anand | completed | FLINK-37548 | info | ||
| 506 | FLIP-506: Support Reuse Multiple Table Sinks in Planner |
5
Ron Liu
weijie guo Lincoln Lee Leonard Xu Rui Fan <1996fanrui@gmail.com> |
0 | 0 | xiangyu feng | in progress | FLINK-37227 | info | ||
| 504 | FLIP-504: Blue/Green Deployments for Flink on Kubernetes: Phase 2 (coordination) | 0 | 0 | 0 | Gyula Fora | under discussion | info | |||
| 503 | FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) |
6
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?=
Thomas Weise =?UTF-8?Q?Gyula_F=C3=B3ra?= Ferenc Csaky Alexander Fedulov =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Gyula Fora | in progress | FLINK-37515 | info | ||
| 502 | FLIP-502: QueryOperation SQL Serialization customization | Flink | 2.1.0 |
4
Martijn Visser
Timo Walther =?UTF-8?Q?Fabian_H=C3=BCske?= Sergey Nuyanzin |
0 | 0 | Dawid Wysakowicz | completed | FLINK-37603 | info |
| 501 | FLIP-501: Support Window Extension in DataStream V2 API | Flink | 2.0.0 |
3
Zakelly Lan
weijie guo Junrui Lee |
0 | 0 | Xu Huang | completed | FLINK-37136 | info |
| 500 | FLIP-500: Support Join Extension in DataStream V2 API | Flink | 2.0.0 |
3
weijie guo
Xintong Song Junrui Lee |
0 | 0 | Xu Huang | completed | FLINK-37135 | info |
| 499 | FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 | Flink | 2.0.0 |
3
weijie guo
Xintong Song Junrui Lee |
0 | 0 | Weijie Guo | completed | FLINK-37112 | info |
| 498 | FLIP-498: AsyncTableFunction for async table function support |
3
Martijn Visser
=?UTF-8?Q?Fabian_H=C3=BCske?= Timo Walther |
0 | 0 | Alan Sheinberg | in progress | FLINK-37723 | info | ||
| 497 | FLIP-497: Early Fire Support for Flink SQL Interval Join |
2
Xingcan Cui
Becket Qin |
0 | 0 | Weiqing Yang | under discussion | info | |||
| 496 | FLIP-496: SQL connector for keyed savepoint data | Flink | 2.1.0 |
3
Ferenc Csaky
Zakelly Lan =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Gabor Somogyi | completed | FLINK-36929 | info |
| 495 | FLIP-495: Support AdaptiveScheduler record and query the rescale history |
3
Wei Zhong
Matthias Pohl Feng Jin |
0 | 0 | RocMarshal | in progress | FLINK-38333 | info | ||
| 494 | FLIP-494: Add missing createTable/createView methods to TableEnvironment |
3
Ron Liu
Dawid Wysakowicz Sergey Nuyanzin |
0 | 0 | Sergey Nuyanzin | completed | FLINK-37007 | info | ||
| 493 | FLIP-493: Add K8S conditions to CRD's Status |
3
gyula.fora@gmail.com
Alexander Fedulov Rui Fan <1996fanrui@gmail.com> |
0 | 0 | David Radley | in progress | FLINK-33634 | info | ||
| 492 | FLIP-492: Support Query Modifications for Materialized Tables |
3
Ron Liu
Shengkai Fang Lincoln Lee |
0 | 0 | Feng Jin | in progress | FLINK-36993 | info | ||
| 491 | FLIP-491: BundledAggregateFunction for batched aggregation |
4
Martijn Visser
=?UTF-8?Q?Fabian_H=C3=BCske?= Timo Walther Stefan Richter |
0 | 0 | Alan Sheinberg | under discussion | info | |||
| 490 | FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ | Flink | 2.2 |
3
Wei Zhong
Becket Qin Rui Fan <1996fanrui@gmail.com> |
0 | 0 | RocMarshal | completed | FLINK-38229 | info |
| 489 | FLIP-489: Add missing dropTable/dropView methods to TableEnvironment |
4
Ron Liu
Leonard Xu Timo Walther Sergey Nuyanzin |
0 | 0 | Sergey Nuyanzin | completed | FLINK-36919 | info | ||
| 488 | FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs | Flink | 2.0 |
3
Hangxiang Yu
Gabor Somogyi Yanfei Lei |
0 | 0 | Zakelly Lan | in progress | FLINK-36943 | info |
| 487 | FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler |
4
Martijn Visser
Yuepeng Pan Sergey Nuyanzin Matthias Pohl |
0 | 0 | RocMarshal | in progress | FLINK-22258 | info | ||
| 486 | FLIP-486: Introduce A New DeltaJoin |
4
Ron Liu
weijie guo Jark Wu Lincoln Lee |
0 | 0 | lincoln lee | unknown | info | |||
| 485 | FLIP-485: Add UDF Metrics |
1
Shengkai Fang
|
0 | 0 | Weiqing Yang | in progress | FLINK-38071 | info | ||
| 484 | FLIP-484: Add custom metric variables to operators | Flink | 2.2.0 |
2
Roman Khachatryan
Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Piotr Nowojski | completed | FLINK-38158 | info |
| 483 | FLIP-483: Add support for children Spans |
2
Roman Khachatryan
Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Piotr Nowojski | not accepted | FLINK-38353 | info | ||
| 482 | FLIP-482: Add OpenTelemetryEventReporter |
2
Roman Khachatryan
Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Piotr Nowojski | under discussion | info | |||
| 481 | FLIP-481: Introduce Event Reporting |
2
Roman Khachatryan
Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Piotr Nowojski | not accepted | FLINK-37426 | info | ||
| 480 | FLIP-480: Support to deploy SQL script in application mode |
5
Ron Liu
Shengkai Fang Ferenc Csaky Lincoln Lee Zhu Zhu |
0 | 0 | Shengkai Fang | unknown | info | |||
| 479 | FLIP-479: Support Persisting ClusterID for both application and session mode. | 0 | 0 | 0 | Feng Jin | unknown | info | |||
| 478 | FLIP-478 Introduce Config Option Scope |
3
Zhu Zhu
Shengkai Fang Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Junrui Lee | unknown | info | |||
| 477 | FLIP-477 Amazon SQS Source Connector | Flink | 4.4 |
3
Arvid Heise
Danny Cranmer Robert Metzger |
0 | 0 | Ahmed Hamdy | unknown | info | |
| 476 | FLIP-476: Introduce CLI API compatibility guarantees | Flink | 2.0 | 0 | 0 | 0 | Ferenc Csaky | unknown | info | |
| 475 | FLIP-475: Support Adaptive Skewed Join Optimization |
3
Zhu Zhu
Rui Fan <1996fanrui@gmail.com> Lincoln Lee |
0 | 0 | Lei Yang | not accepted | FLINK-36333 | info | ||
| 474 | FLIP-474: Store operator name and UID in state metadata | Flink | 2.0 |
4
Ferenc Csaky
Zakelly Lan =?UTF-8?Q?M=C3=A1rton_Balassi?= Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Gabor Somogyi | completed | FLINK-36001 | info |
| 473 | FLIP-473 Introduce New SQL Operators Based on Asynchronous State APIs |
3
Ron Liu
Zakelly Lan Lincoln Lee |
0 | 0 | lincoln lee | unknown | info | |||
| 472 | FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states | Flink | 2.0 |
3
=?UTF-8?Q?David_Mor=C3=A1vek?=
Rui Fan <1996fanrui@gmail.com> Matthias Pohl |
0 | 0 | Matthias Pohl | completed | FLINK-35035 | info |
| 471 | FLIP-471: Fixing watermark idleness timeout accounting |
5
Roman Khachatryan
Zakelly Lan Stefan Richter Timo Walther Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Piotr Nowojski | not accepted | FLINK-35886 | info | ||
| 470 | FLIP-470: Support Adaptive Broadcast Join |
2
Zhu Zhu
Ron Liu |
0 | 0 | Xia Sun | not accepted | FLINK-36159 | info | ||
| 469 | FLIP-469: Supports Adaptive Optimization of StreamGraph |
3
Ron Liu
Zhu Zhu weijie guo |
0 | 0 | Junrui Lee | not accepted | FLINK-36033 | info | ||
| 468 | FLIP-468: Introducing StreamGraph-Based Job Submission |
3
Ron Liu
Zhu Zhu Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Junrui Lee | unknown | info | |||
| 467 | FLIP-467: Introduce Generalized Watermarks | Flink | 2.0.0 |
3
weijie guo
Xintong Song Junrui Lee |
0 | 0 | Jeyhun Karimov | unknown | info | |
| 466 | FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2 |
3
weijie guo
Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Wencong Liu | under discussion | info | |||
| 465 | FLIP-465: Introduce DESCRIBE FUNCTION |
3
Martijn Visser
Timo Walther Sergey Nuyanzin |
0 | 0 | Martijn Visser | unknown | info | |||
| 464 | FLIP-464: Merge "flink run" and "flink run-application" |
5
weijie guo
Zakelly Lan Xintong Song =?UTF-8?Q?M=C3=A1rton_Balassi?= Gabor Somogyi |
0 | 0 | Gabor Somogyi | unknown | info | |||
| 463 | FLIP-463: Schema Definition in CREATE TABLE AS Statement | Flink | 2.0 |
3
Martijn Visser
Timo Walther Sergey Nuyanzin |
0 | 0 | Sergio Peña | completed | FLINK-35706 | info |
| 462 | FLIP-462 Support Custom Data Distribution for Input Stream of Lookup Join | Flink | 2.0.0 |
2
Xintong Song
Lincoln Lee |
0 | 0 | Weijie Guo | completed | FLINK-35652 | info |
| 461 | FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler | Flink | 2.0 |
7
Thomas Weise
weijie guo Zakelly Lan Rui Fan <1996fanrui@gmail.com> =?UTF-8?Q?Gyula_F=C3=B3ra?= Gabor Somogyi =?UTF-8?Q?David_Mor=C3=A1vek?= |
0 | 0 | Matthias Pohl | completed | FLINK-35549 | info |
| 460 | FLIP-460: Display source/sink I/O metrics on Flink Web UI | Flink | 2.0 |
8
Robert Metzger
Yong Fang Zakelly Lan Becket Qin Hang Ruan Leonard Xu Rui Fan <1996fanrui@gmail.com> Xintong Song |
0 | 0 | Zhanghao Chen | completed | FLINK-33681 | info |
| 459 | FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn | Flink | 1.20 |
3
Zhu Zhu
weijie guo Xintong Song |
0 | 0 | Yuxin Tan | completed | FLINK-35533 | info |
| 458 | FLIP-458: Long-Term Support for the Final Release of Apache Flink 1.x Line | 0 | 0 | 0 | Alexander Fedulov | under discussion | info | |||
| 457 | FLIP-457: Improve Table/SQL Configuration for Flink 2.0 |
5
weijie guo
Jark Wu Lincoln Lee Rui Fan <1996fanrui@gmail.com> Benchao Li |
0 | 0 | Jane Chen | unknown | info | |||
| 456 | FLIP-456: CompiledPlan support for Batch Execution Mode |
3
Martijn Visser
Timo Walther Sergey Nuyanzin |
0 | 0 | Alexey Leonov-Vendrovskiy | under discussion | info | |||
| 455 | FLIP-455: Declare async state processing and checkpoint the in-flight requests | Flink | 2.0 |
2
Hangxiang Yu
Zakelly Lan |
0 | 0 | Zakelly Lan | in progress | FLINK-36118 | info |
| 454 | FLIP-454: New Apicurio Avro format |
2
Danny Cranmer
Leonard Xu |
0 | 0 | Martijn Visser | unknown | info | |||
| 453 | FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction |
4
Leonard Xu
weijie guo Jing Ge Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Martijn Visser | unknown | info | |||
| 452 | FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding | Flink | 1.20 |
4
Benchao Li
Stefan Richter Timo Walther Lincoln Lee |
0 | 0 | Alan Sheinberg | completed | FLINK-35403 | info |
| 451 | FLIP-451: Introduce timeout configuration to AsyncSink API | Flink | 1.20 |
4
Danny Cranmer
Hong Liang Leonard Xu weijie guo |
0 | 0 | Ahmed Hamdy | completed | FLINK-35435 | info |
| 450 | FLIP-450: Improve Runtime Configuration for Flink 2.0 |
3
weijie guo
Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Xuannan Su | not accepted | FLINK-35461 | info | ||
| 449 | FLIP-449: Reorganization of flink-connector-jdbc |
3
Jiabao Sun
Leonard Xu Rui Fan <1996fanrui@gmail.com> |
0 | 0 | João Boto | under discussion | info | |||
| 448 | FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table |
4
Jark Wu
Ron Liu Shengkai Fang Lincoln Lee |
0 | 0 | ron liu | completed | FLINK-35345 | info | ||
| 447 | FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0 | Flink | 2.0 |
8
Zakelly Lan
Roman Khachatryan Stefan Richter Gabor Somogyi Piotr Nowojski Rui Fan <1996fanrui@gmail.com> Yanfei Lei Yun Tang |
0 | 0 | yue ma | in progress | FLINK-35573 | info |
| 446 | FLIP-446: Kubernetes Operator State Snapshot CRD |
4
=?UTF-8?Q?Gyula_F=C3=B3ra?=
Thomas Weise Rui Fan <1996fanrui@gmail.com> Robert Metzger |
0 | 0 | Gyula Fora | unknown | info | |||
| 445 | FLIP-445: Support dynamic parallelism inference for HiveSource | Flink | 1.20 |
5
Ron Liu
Lijie Wang Zhu Zhu Rui Fan <1996fanrui@gmail.com> yuxia |
0 | 0 | Xia Sun | completed | FLINK-35293 | info |
| 444 | FLIP-444: Native file copy support |
6
Roman Khachatryan
Zakelly Lan Stefan Richter Hong Rui Fan <1996fanrui@gmail.com> Martijn Visser |
0 | 0 | Piotr Nowojski | under discussion | info | |||
| 443 | FLIP-443: Interruptible timers firing |
7
weijie guo
Zakelly Lan Stefan Richter Piotr Nowojski Rui Fan <1996fanrui@gmail.com> Yanfei Lei Martijn Visser |
0 | 0 | Piotr Nowojski | not accepted | FLINK-20217 | info | ||
| 442 | FLIP-442: General Improvement to Configuration for Flink 2.0 |
3
Zhu Zhu
Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Xuannan Su | not accepted | FLINK-35359 | info | ||
| 441 | FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI |
4
Hangxiang Yu
Lijie Wang Rui Fan <1996fanrui@gmail.com> Yanfei Lei |
0 | 0 | Rui Fan | completed | FLINK-29481 | info | ||
| 440 | FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) |
8
=?UTF-8?Q?Fabian_H=C3=BCske?=
Shengkai Fang Stefan Richter Timo Walther Dawid Wysakowicz Martijn Visser Konstantin Knauf Sergey Nuyanzin |
0 | 0 | Timo Walther | in progress | FLINK-36703 | info | ||
| 439 | FLIP-439: Externalize Kudu Connector from Bahir |
6
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?=
Leonard Xu =?UTF-8?Q?M=C3=A1rton_Balassi?= =?UTF-8?Q?Gyula_F=C3=B3ra?= Martijn Visser Gabor Somogyi |
0 | 0 | Gyula Fora | unknown | info | |||
| 438 | FLIP-438: Amazon SQS Sink Connector | 0 | 0 | 0 | Priya Dhingra | completed | FLINK-35305 | info | ||
| 437 | FLIP-437: Support ML Models in Flink SQL |
6
Jark Wu
=?UTF-8?Q?David_Mor=C3=A1vek?= Timo Walther Piotr Nowojski Leonard Xu Martijn Visser |
0 | 0 | Martijn Visser | not accepted | FLINK-34992 | info | ||
| 436 | FLIP-436: Introduce Catalog-related Syntax | Flink | 1.20 |
6
Jark Wu
Benchao Li Lincoln Lee Leonard Xu yuxia Jane Chan |
0 | 0 | Yubin Li | completed | FLINK-34914 | info |
| 435 | FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines |
7
Jark Wu
Ron liu Lincoln Lee Leonard Xu Rui Fan <1996fanrui@gmail.com> Martijn Visser Yun Tang |
0 | 0 | lincoln lee | in progress | FLINK-35187 | info | ||
| 434 | FLIP-434: Support optimizations for pre-partitioned data sources | 0 | 0 | 0 | Jeyhun Karimov | in progress | FLINK-34442 | info | ||
| 433 | FLIP-433: State Access on DataStream API V2 | Flink | 1.20 |
5
Yuan Mei
Rui Fan <1996fanrui@gmail.com> Hangxiang Yu =?UTF-8?Q?Gyula_F=C3=B3ra?= Xintong Song |
0 | 0 | Weijie Guo | completed | FLINK-34977 | info |
| 432 | FLIP-432: Faster Checkpoint & Recovery for Disaggregated State |
3
Hangxiang Yu
Zakelly Lan Yanfei Lei |
0 | 0 | Zakelly Lan | under discussion | info | |||
| 431 | [WIP]FLIP-431: Metrics For Disaggregated State | 0 | 0 | 0 | Zakelly Lan | unknown | info | |||
| 430 | FLIP-430: Remote Compaction For Disaggregated State | 0 | 0 | 0 | Zakelly Lan | under discussion | info | |||
| 429 | [WIP]FLIP-429: Local Disk as a Secondary Cache for Disaggregated State | 0 | 0 | 0 | Zakelly Lan | unknown | info | |||
| 428 | FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State | Flink | 2.0 |
4
Hangxiang Yu
Yanfei Lei Rui Fan <1996fanrui@gmail.com> Yuan Mei |
0 | 0 | Zakelly Lan | in progress | FLINK-34982 | info |
| 427 | FLIP-427: ForSt - Disaggregated state Store | Flink | 2.0 |
3
Piotr Nowojski
Rui Fan <1996fanrui@gmail.com> Yuan Mei |
0 | 0 | Zakelly Lan | in progress | FLINK-34975 | info |
| 426 | FLIP-426: Grouping Remote State Access | Flink | 2.0 |
4
Hangxiang Yu
Yanfei Lei Rui Fan <1996fanrui@gmail.com> Yuan Mei |
0 | 0 | Zakelly Lan | in progress | FLINK-34981 | info |
| 425 | FLIP-425: Asynchronous Execution Model | Flink | 2.0 |
6
Roman Khachatryan
Yuan Mei Piotr Nowojski Rui Fan <1996fanrui@gmail.com> Jing Ge Xintong Song |
0 | 0 | Zakelly Lan | in progress | FLINK-34973 | info |
| 424 | FLIP-424: Asynchronous State APIs | Flink | 2.0 |
6
Roman Khachatryan
Yuan Mei Piotr Nowojski Rui Fan <1996fanrui@gmail.com> Jing Ge Xintong Song |
0 | 0 | Zakelly Lan | in progress | FLINK-34974 | info |
| 423 | FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP) | Flink | 2.0, 2.1 |
4
Xintong Song
Jing Ge Piotr Nowojski Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Zakelly Lan | in progress | FLINK-34984 | info |
| 422 | [WIP] FLIP-422: Add option to control the default partitioner when the parallelism of upstream and downstream operator does not match | 0 | 0 | 0 | Zhanghao Chen | in progress | FLINK-32872 | info | ||
| 421 | FLIP-421: Support Custom Conversion for LogicalTypes | 0 | 0 | 0 | Jiangjie Qin | unknown | info | |||
| 420 | FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes | Flink | 1.20 |
3
Hangxiang Yu
Jing Ge Yanfei Lei |
0 | 0 | Jinzhong Li | unknown | info | |
| 419 | FLIP-419: Optimize multi-sink query plan generation | 0 | 0 | 0 | Jeyhun Karimov | under discussion | info | |||
| 418 | FLIP-418: Show data skew score on Flink Dashboard | Flink | 1.20 |
3
Danny Cranmer
Hong Liang Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Emre Kartoglu | completed | FLINK-34025 | info |
| 417 | FLIP-417: Expose JobManagerOperatorMetrics via REST API |
3
Thomas Weise
Maximilian Michels Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Mason Chen | in progress | FLINK-34064 | info | ||
| 416 | FLIP-416: Deprecate and remove the RestoreMode#LEGACY | Flink | 1.19, 2.0 |
3
Hangxiang Yu
Rui Fan <1996fanrui@gmail.com> Yanfei Lei |
0 | 0 | Zakelly Lan | in progress | FLINK-34189 | info |
| 415 | FLIP-415: Introduce a new join operator to support minibatch | Flink | 1.19 |
4
Jane Chan
Benchao Li liu ron Lincoln Lee |
0 | 0 | xu_shuai_ | unknown | info | |
| 414 | FLIP-414: Support Retry Mechanism in RocksDBStateDataTransfer | 0 | 0 | 0 | xiangyu feng | in progress | FLINK-33932 | info | ||
| 413 | FLIP-413: Enable unaligned checkpoints by default | 0 | 0 | 0 | Piotr Nowojski | under discussion | info | |||
| 412 | FLIP-412: Add the time-consuming span of each stage when starting the Flink job to TraceReporter | Flink | 1.20 | 0 | 0 | 0 | Rui Fan | in progress | FLINK-33999 | info |
| 411 | FLIP-411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change | 0 | 0 | 0 | Zhanghao Chen | in progress | FLINK-33962 | info | ||
| 410 | FLIP-410: Config, Context and Processing Timer Service of DataStream API V2 | Flink | 1.20 |
4
Guowei Ma
weijie guo Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Weijie Guo | completed | FLINK-34549 | info |
| 409 | FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction | Flink | 1.20 |
4
Guowei Ma
weijie guo Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Weijie Guo | completed | FLINK-34548 | info |
| 408 | FLIP-408: [Umbrella] Introduce DataStream API V2 |
4
Guowei Ma
weijie guo Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Weijie Guo | completed | FLINK-34547 | info | ||
| 407 | FLIP-407: Improve Flink Client performance in interactive scenarios | 0 | 0 | 0 | xiangyu feng | in progress | FLINK-33683 | info | ||
| 406 | FLIP-406: Reorganize State & Checkpointing & Recovery Configuration | Flink | 1.20, 2.0 |
4
Hangxiang Yu
Lijie Wang Rui Fan <1996fanrui@gmail.com> Yanfei Lei |
0 | 0 | Zakelly Lan | in progress | FLINK-34255 | info |
| 405 | FLIP-405: Migrate string configuration key to ConfigOption | Flink | 1.19, 1.20, 2.0 |
3
Zhu Zhu
Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Xuannan Su | completed | FLINK-34079 | info |
| 404 | FLIP-404: Create a Redis HyperLogLog Connector for Flink | 0 | 0 | 0 | Jinsui Chen | in progress | FLINK-33873 | info | ||
| 403 | FLIP-403 High Availability Services for OLAP Scenarios | 0 | 0 | 0 | Yangze Guo | unknown | info | |||
| 402 | FLIP-402: Extend ZooKeeper Curator configurations | Flink | 1.20.0 |
3
Matthias Pohl
Yang Wang Martijn Visser |
0 | 0 | Oleksandr Nitavskyi | completed | FLINK-33376 | info |
| 401 | FLIP-401: REST API JSON response deserialization unknown field tolerance | Flink | 1.19 |
2
=?UTF-8?Q?M=C3=A1rton_Balassi?=
Maximilian Michels |
0 | 0 | Gabor Somogyi | completed | FLINK-33268 | info |
| 400 | FLIP-400: AsyncScalarFunction for asynchronous scalar function support |
4
Martijn Visser
Piotr Nowojski Timo Walther Lincoln Lee |
0 | 0 | Panagiotis Garefalakis | in progress | FLINK-33978 | info | ||
| 399 | FLIP-399: Flink Connector Doris |
5
Jing Ge
Robert Metzger Leonard Xu Jiabao Sun Martijn Visser |
0 | 0 | Di Wu | unknown | info | |||
| 398 | FLIP-398: Improve Serialization Configuration And Usage In Flink | Flink | 2.0 |
3
Zhu Zhu
weijie guo Xintong Song |
0 | 0 | Fang Yong | completed | FLINK-34037 | info |
| 397 | FLIP-397: Add config options for administrator JVM options | Flink | 1.19 |
3
Benchao Li
Rui Fan <1996fanrui@gmail.com> Yong Fang |
0 | 0 | Zhanghao Chen | completed | FLINK-33221 | info |
| 396 | FLIP-396: Trial to test GitHub Actions as an alternative for Flink's current Azure CI infrastructure |
9
weijie guo
Sergey Nuyanzin Yangze Guo Lincoln Lee Etienne Chauchot Leonard Xu Rui Fan <1996fanrui@gmail.com> Benchao Li Xintong Song |
0 | 0 | Matthias Pohl | in progress | FLINK-27075 | info | ||
| 395 | FLIP-395: Deprecate Global Aggregator Manager | 0 | 0 | 0 | Zhanghao Chen | under discussion | info | |||
| 394 | [WIP] FLIP-394: Add Metrics for Connector Agnostic Autoscaling | 0 | 0 | 0 | Mason Chen | in progress | FLINK-33575 | info | ||
| 393 | FLIP-393: Make QueryOperations SQL serializable | Flink | 1.19 |
7
Dawid Wysakowicz
Sergey Nuyanzin Timo Walther Lincoln Lee =?UTF-8?Q?Gyula_F=C3=B3ra?= Benchao Li Martijn Visser |
0 | 0 | Dawid Wysakowicz | completed | FLINK-33644 | info |
| 392 | FLIP-392: Deprecate the Legacy Group Window Aggregation | 0 | 0 | 0 | lincoln lee | under discussion | info | |||
| 391 | FLIP-391: Deprecate RuntimeContext#getExecutionConfig |
4
Zhu Zhu
weijie guo Jing Ge Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Junrui Lee | unknown | info | |||
| 390 | FLIP-390: Support System out and err to be redirected to LOG or discarded | Flink | 1.19 |
5
Roman Khachatryan
Piotr Nowojski Leonard Xu Rui Fan <1996fanrui@gmail.com> Hangxiang Yu |
0 | 0 | Rui Fan | completed | FLINK-33625 | info |
| 389 | FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving. | Flink | 1.19 |
2
Qingsheng Ren
Leonard Xu |
0 | 0 | Hongshun Wang | completed | FLINK-32417 | info |
| 388 | FLIP-388: Support Dynamic Logger Level Adjustment | 0 | 0 | 0 | RocMarshal | not accepted | FLINK-33320 | info | ||
| 387 | FLIP-387: Support named parameters for functions and call procedures | Flink | 1.19 |
3
Benchao Li
Timo Walther Lincoln Lee |
0 | 0 | Feng Jin | completed | FLINK-34054 | info |
| 386 | FLIP-386: Support adding custom metrics in Recovery Spans |
3
Roman Khachatryan
Stefan Richter Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Piotr Nowojski | not accepted | FLINK-33697 | info | ||
| 385 | FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter |
5
Roman Khachatryan
Stefan Richter Rui Fan <1996fanrui@gmail.com> Hangxiang Yu Jing Ge |
0 | 0 | Piotr Nowojski | not accepted | FLINK-33696 | info | ||
| 384 | FLIP-384: Introduce TraceReporter and use it to create checkpointing and recovery traces | Flink | 1.19 |
6
Roman Khachatryan
=?UTF-8?Q?David_Mor=C3=A1vek?= Stefan Richter Rui Fan <1996fanrui@gmail.com> Hangxiang Yu Jing Ge |
0 | 0 | Piotr Nowojski | completed | FLINK-33695 | info |
| 383 | FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs |
4
Zhu Zhu
weijie guo Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Lijie Wang | not accepted | FLINK-33892 | info | ||
| 382 | FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs |
3
Lijie Wang
weijie guo Xintong Song |
0 | 0 | Wencong Liu | under discussion | info | |||
| 381 | FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects |
6
Lijie Wang
weijie guo Yangze Guo Zhu Zhu Rui Fan <1996fanrui@gmail.com> Jing Ge |
0 | 0 | Junrui Lee | unknown | info | |||
| 380 | FLIP-380: Support Full Partition Processing On Non-keyed DataStream |
3
Yingjie Cao
weijie guo Xintong Song |
0 | 0 | Wencong Liu | under discussion | info | |||
| 379 | FLIP-379: Dynamic source parallelism inference for batch jobs | Flink | 1.19 |
3
Lijie Wang
Leonard Xu Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Xia Sun | completed | FLINK-33768 | info |
| 378 | FLIP-378: Support Avro timestamp with local timezone | Flink | 1.19 |
4
Jark Wu
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?= Jing Ge Leonard Xu |
0 | 0 | Zhenqiu Huang | completed | FLINK-33198 | info |
| 377 | FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources |
3
Jark Wu
Qingsheng Ren Leonard Xu |
0 | 0 | jiabao.sun | completed | FLINK-34214 | info | ||
| 376 | FLIP-376: Add DISTRIBUTED BY clause | Flink | 1.20 |
6
Sergey Nuyanzin
Lincoln Lee Leonard Xu Benchao Li Martijn Visser Jing Ge |
0 | 0 | Timo Walther | completed | FLINK-33494 | info |
| 375 | FLIP-375: Built-in cross-platform powerful java profiler | Flink | 1.19 |
4
Yangze Guo
Jing Ge Yun Tang Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Yu Chen | completed | FLINK-33325 | info |
| 374 | FLIP-374: Adding a separate configuration for specifying Java Options of the SQL Gateway |
5
Shammon FY
Weihua Hu Rui Fan <1996fanrui@gmail.com> Benchao Li Jing Ge |
0 | 0 | Yangze Guo | unknown | info | |||
| 373 | FLIP-373: Support Configuring Different State TTLs using SQL Hint |
5
liu ron
Sergey Nuyanzin Jark Wu Lincoln Lee Benchao Li |
0 | 0 | Jane Chen | unknown | info | |||
| 372 | FLIP-372: Enhance and synchronize Sink API to match the Source API | Flink | 1.19.0 |
5
Tzu-Li (Gordon) Tai
Leonard Xu =?UTF-8?Q?M=C3=A1rton_Balassi?= =?UTF-8?Q?Gyula_F=C3=B3ra?= Gabor Somogyi |
0 | 0 | Peter Vary | completed | FLINK-33328 | info |
| 371 | FLIP-371: Provide initialization context for Committer creation in TwoPhaseCommittingSink | Flink | 1.19.0 |
5
Tzu-Li (Gordon) Tai
Leonard Xu =?UTF-8?Q?M=C3=A1rton_Balassi?= Martijn Visser Gabor Somogyi |
0 | 0 | Peter Vary | completed | FLINK-25857 | info |
| 370 | FLIP-370: Support Balanced Tasks Scheduling | Flink | 2.2 |
3
Zhu Zhu
Yangze Guo Rui Fan <1996fanrui@gmail.com> |
0 | 0 | RocMarshal | in progress | FLINK-31757 | info |
| 369 | FLIP-369: Introduce LRU cache to accelerate state backend access | 0 | 0 | 0 | Yunfeng Zhou | unknown | info | |||
| 368 | FLIP-368: Reorganize the exceptions thrown in state interfaces | Flink | 2.0 | 0 | 0 | 0 | Zakelly Lan | unknown | info | |
| 367 | FLIP-367: Support Setting Parallelism for Table/SQL Sources | Flink | 1.19 |
8
Shammon FY
Sergey Nuyanzin Yangze Guo Weihua Hu Lincoln Lee Benchao Li Martijn Visser Jing Ge |
0 | 0 | Zhanghao Chen | completed | FLINK-33261 | info |
| 366 | FLIP-366: Support standard YAML for FLINK configuration |
8
Lijie Wang
weijie guo Chesnay Schepler Yangze Guo Zhu Zhu Rui Fan <1996fanrui@gmail.com> Jing Ge Xintong Song |
0 | 0 | Junrui Lee | unknown | info | |||
| 365 | FLIP-365: Introduce flush interval to adjust the interval of emitting results with idempotent semantics | 0 | 0 | 0 | Yunfeng Zhou | under discussion | info | |||
| 364 | FLIP-364: Improve the exponential-delay restart-strategy | flink | 1.19 |
6
weijie guo
Maximilian Michels Zhu Zhu Rui Fan <1996fanrui@gmail.com> Matthias Pohl Jing Ge |
0 | 0 | Rui Fan | completed | FLINK-33735 | info |
| 363 | FLIP-363: Unify the Representation of TaskManager Location in REST API and Web UI | Flink | 1.19 |
4
Weihua Hu
Yangze Guo Jing Ge Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Zhanghao Chen | unknown | info | |
| 362 | FLIP-362: Support minimum resource limitation | Flink | 1.19 |
4
Yangze Guo
Weihua Hu Jing Ge Shammon FY |
0 | 0 | xiangyu feng | completed | FLINK-15959 | info |
| 361 | FLIP-361: Improve GC Metrics | Flink | 1.19 |
7
Jing Ge
Yangze Guo Maximilian Michels Weihua Hu Rui Fan <1996fanrui@gmail.com> Dong Lin Xintong Song |
0 | 0 | Gyula Fora | in progress | FLINK-33120 | info |
| 360 | FLIP-360: Merging the ExecutionGraphInfoStore and the JobResultStore into a single component CompletedJobStore | 0 | 0 | 0 | Matthias Pohl | in progress | FLINK-31709 | info | ||
| 359 | FLIP-359: ignore-unclaimed-state supports the state inside of operator | 0 | 0 | 0 | Rui Fan | in progress | FLINK-32658 | info | ||
| 358 | FLIP-358: flink-avro enhancement and cleanup | 0 | 0 | 0 | Jiangjie Qin | under discussion | info | |||
| 357 | FLIP-357: Deprecate Iteration API of DataStream | Flink | 1.19 |
4
Yangze Guo
Dong Lin Xintong Song Jing Ge |
0 | 0 | Wencong Liu | completed | FLINK-33144 | info |
| 356 | FLIP-356: Support Nested Fields Filter Pushdown | Flink | 1.19.0 |
3
Jark Wu
Martijn Visser Sergey Nuyanzin |
0 | 0 | Venkata krishnan Sowrirajan | completed | FLINK-20767 | info |
| 354 | FLIP-354: Removal of deprecated exception history fields in REST API | 0 | 0 | 0 | Matthias Pohl | completed | FLINK-32688 | info | ||
| 352 | FLIP-352: Use camelCast for all REST API fields/parameters | Flink | 2.0 | 0 | 0 | 0 | Chesnay Schepler | in progress | FLINK-15787 | info |
| 351 | FLIP-351: REST API normalizes +/-Inf / NaN to 0 | Flink | 2.0 | 0 | 0 | 0 | Chesnay Schepler | unknown | info | |
| 350 | FLIP-350: Remove query parameters from Jar handlers | Flink | 2.0 | 0 | 0 | 0 | Chesnay Schepler | unknown | info | |
| 349 | FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package | Flink | 2.0, 3.0 |
2
Gabor Somogyi
Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Chesnay Schepler | completed | FLINK-4602 | info |
| 348 | FLIP-348: Make expanding behavior of virtual metadata columns configurable | Flink | 1.19 |
5
Sergey Nuyanzin
Jark Wu Benchao Li Martijn Visser Jing Ge |
0 | 0 | Timo Walther | completed | FLINK-33028 | info |
| 347 | FLIP-347: Remove IOReadableWritable serialization in Path |
3
weijie guo
Xintong Song Jing Ge |
1
Matthias Pohl
|
0 | Wencong Liu | not accepted | FLINK-5336 | info | ||
| 346 | FLIP-346: Deprecate ManagedTable related APIs | 0 | 0 | 0 | Jane Chen | unknown | info | |||
| 345 | FLIP-345: Add support for dynamic time window function | 0 | 0 | 0 | å¼ ä¸€å¸† | unknown | info | |||
| 344 | FLIP-344: Remove parameter in RichFunction#open |
3
weijie guo
Xintong Song Jing Ge |
0 | 0 | Wencong Liu | not accepted | FLINK-6912 | info | ||
| 343 | FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger() |
4
Matthias Pohl
weijie guo Xintong Song Jing Ge |
0 | 0 | Wencong Liu | completed | FLINK-4675 | info | ||
| 342 | FLIP-342: Remove brackets around keys returned by MetricGroup#getAllVariables | Flink | 2.0 | 0 | 0 | 0 | Chesnay Schepler | in progress | FLINK-24078 | info |
| 341 | FLIP-341: Remove MetricGroup methods accepting an int as a name | Flink | 2.0 | 0 | 0 | 0 | Chesnay Schepler | unknown | info | |
| 340 | FLIP-340: Remove rescale REST endpoint |
5
Zhu Zhu
Matthias Pohl Martijn Visser Konstantin Knauf Xintong Song |
0 | 0 | Chesnay Schepler | unknown | info | |||
| 339 | FLIP-339: Support Adaptive Partition Selection for StreamPartitioner |
2
Wei Zhong
Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Mang Zhang | in progress | FLINK-31655 | info | ||
| 338 | FLIP-338: Remove terminationMode query parameter from job cancellation REST endpoint | 0 | 0 | 0 | Chesnay Schepler | unknown | info | |||
| 337 | FLIP-337: Remove JarRequestBody#programArgs | Flink | 2.0.0 | 0 | 0 | 0 | Chesnay Schepler | unknown | info | |
| 336 | FLIP-336: Remove "now" timestamp field from REST responses | Flink | 2.0.0 |
6
Jing Ge
Zhu Zhu Matthias Pohl Martijn Visser Konstantin Knauf Xintong Song |
0 | 0 | Chesnay Schepler | unknown | info | |
| 335 | FLIP-335: Removing Flink's Time classes | Flink | 1.19, 2.0 |
3
Zhu Zhu
Jing Ge Xintong Song |
0 | 0 | Matthias Pohl | completed | FLINK-32570 | info |
| 334 | FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler | flink-kubernetes-operator | 1.7.0 |
4
=?UTF-8?Q?Gyula_F=C3=B3ra?=
Dong Lin Maximilian Michels Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Rui Fan | completed | FLINK-32723 | info |
| 333 | FLIP-333: Redesign Apache Flink website |
4
Danny Cranmer
Hong Liang Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Deepthi Mohan | completed | FLINK-33046 | info | ||
| 332 | [WIP]FLIP-332: Introduce the concept of state self-sustained | 0 | 0 | 0 | Feifan Wang | unknown | info | |||
| 331 | FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment |
3
Dong Lin
weijie guo Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Dong Lin | in progress | FLINK-32594 | info | ||
| 330 | FLIP-330: Support specifying record timestamp requirement | 0 | 0 | 0 | Yunfeng Zhou | under discussion | info | |||
| 329 | FLIP-329: Add operator attribute to specify support for object-reuse |
2
Dong Lin
Jing Ge |
0 | 0 | Xuannan Su | under discussion | info | |||
| 328 | FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag |
1
Dong Lin
|
0 | 0 | Dong Lin | under discussion | info | |||
| 327 | FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data |
3
Jing Ge
Xintong Song Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Dong Lin | in progress | FLINK-33202 | info | ||
| 326 | FLIP-326: Enhance Watermark to Support Processing-Time Temporal Join | 0 | 0 | 0 | Xuannan Su | under discussion | info | |||
| 324 | FLIP-324: Introduce Runtime Filter for Flink Batch Jobs | Flink | 1.18.0 |
7
Jark Wu
Yangze Guo Zhu Zhu Rui Fan <1996fanrui@gmail.com> yuxia Benchao Li Jing Ge |
0 | 0 | Lijie Wang | completed | FLINK-32486 | info |
| 323 | FLIP-323: Support Attached Execution on Flink Application Completion for Batch Jobs |
3
Dong Lin
Weihua Hu Jing Ge |
0 | 0 | Allison Chang | under discussion | info | |||
| 322 | FLIP-322 Cooldown period for adaptive scheduler |
3
Martijn Visser
Maximilian Michels Rui Fan |
0 | 0 | Etienne Chauchot | under discussion | info | |||
| 321 | FLIP-321: Introduce an API deprecation process | Flink | 1.18 |
7
Dong Lin
Stefan Richter Zhu Zhu Matthias Pohl Martijn Visser Jing Ge Xintong Song |
0 | 0 | Jiangjie Qin | unknown | info | |
| 320 | FLIP-320: Support multiple Flink versions in each Java library release (Flink ML) | ml | 2.3.0 | 0 | 0 | 0 | Jiang Xin | completed | FLINK-32285 | info |
| 319 | FLIP-319: Integrate with Kafka's Support for Proper 2PC Participation (KIP-939) | 0 | 0 | 0 | Tzu-Li (Gordon) Tai | under discussion | info | |||
| 318 | FLIP-318: Support Dynamic Options Provider For Tables In Gateway | 0 | 0 | 0 | Fang Yong | in progress | FLINK-32042 | info | ||
| 317 | FLIP-317: Upgrade Kryo from 2.24.0 to 5.5.0 | 0 | 0 | 0 | Kurt Ostfeld | under discussion | info | |||
| 316 | FLIP-316: Support application mode for SQL Gateway | 0 | 0 | 0 | Paul Lam | under discussion | info | |||
| 315 | FLIP-315 Support Operator Fusion Codegen for Flink SQL | Flink | 1.18 |
2
Jark Wu
weijie guo |
0 | 0 | ron liu | in progress | FLINK-31833 | info |
| 314 | FLIP-314: Support Customized Job Lineage Listener | Flink | 1.19 |
9
=?utf-8?B?5pu55bid6IOE?=
weijie guo Yangze Guo Maximilian Michels Leonard Xu Rui Fan <1996fanrui@gmail.com> =?UTF-8?Q?Gyula_F=C3=B3ra?= Jing Ge =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Fang Yong | unknown | info | |
| 313 | FLIP-313: Add support of User Defined AsyncTableFunction | 0 | 0 | 0 | WenJun Min | under discussion | info | |||
| 312 | FLIP-312: Prometheus Sink Connector | flink-connectors-prometheus | 1.0.0 |
7
Yang Wang
Jing Ge Becket Qin Leonard Xu Hong Martijn Visser Dong Lin |
0 | 0 | Karthi Thyagarajan | completed | FLINK-33137 | info |
| 311 | FLIP-311: Support Call Stored Procedure |
4
Benchao Li
Jing Ge Rui Fan <1996fanrui@gmail.com> Lincoln Lee |
0 | 0 | luoyuxia | unknown | info | |||
| 310 | [WIP]FLIP-310:use VARINT and ZIGZAG to encode ROWDATA in state | Flink | 1.18 | 0 | 0 | 0 | zhouxiaogang | in progress | FLINK-16009 | info |
| 309 | FLIP-309: Support using larger checkpointing interval when source is processing backlog | Flink | 1.19 |
8
Jark Wu
Stefan Richter Zhu Zhu Leonard Xu Rui Fan <1996fanrui@gmail.com> yuxia Piotr Nowojski Jing Ge |
0 |
2
Chesnay Schepler
Piotr Nowojski |
Yunfeng Zhou | completed | FLINK-32514 | info |
| 308 | FLIP-308: Support Time Travel | Flink | 1.18 |
5
Lincoln Lee
Leonard Xu yuxia Benchao Li Jing Ge |
0 | 0 | Feng Jin | completed | FLINK-32472 | info |
| 307 | FLIP-307: Flink Connector Redshift |
4
Danny Cranmer
Martijn Visser Jing Ge Leonard Xu |
0 | 0 | Samrat Deb | in progress | FLINK-31854 | info | ||
| 306 | FLIP-306: Unified File Merging Mechanism for Checkpoints |
3
Piotr Nowojski
Yu Li Rui Fan <1996fanrui@gmail.com> |
0 | 0 | Zakelly Lan | in progress | FLINK-32070 | info | ||
| 305 | FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement |
4
Lincoln Lee
Jing Ge Rui Fan <1996fanrui@gmail.com> yuxia |
0 | 0 | Mang Zhang | unknown | info | |||
| 304 | FLIP-304: Pluggable Failure Enrichers | Flink | 1.18 |
6
weijie guo
Anton Kalashnikov Roman Khachatryan =?UTF-8?Q?David_Mor=C3=A1vek?= Zhu Zhu Piotr Nowojski |
0 | 0 | Panagiotis Garefalakis | completed | FLINK-31508 | info |
| 303 | FLIP-303: Support REPLACE TABLE AS SELECT statement |
3
yuxia
Jing Ge Lincoln Lee |
0 | 0 | luoyuxia | unknown | info | |||
| 302 | FLIP-302: Support TRUNCATE TABLE statement in batch mode |
3
Benchao Li
yuxia Lincoln Lee |
0 | 0 | luoyuxia | unknown | info | |||
| 301 | FLIP-301: Hybrid Shuffle supports Remote Storage | Flink | 1.18 |
3
Zhu Zhu
weijie guo Xintong Song |
0 | 0 | Yuxin Tan | completed | FLINK-31634 | info |
| 300 | FLIP-300: Add targetColumns to DynamicTableSink#Context to solve the null overwrite problem of partial-insert |
6
Jing Ge
Jark Wu yuxia Benchao Li Martijn Visser Dong Lin |
0 | 0 | lincoln lee | not accepted | FLINK-31487 | info | ||
| 299 | FLIP-299: Pub/Sub Lite Connector | 0 | 0 | 0 | Daniel Collins | in progress | FLINK-31229 | info | ||
| 298 | FLIP-298: Unifying the Implementation of SlotManager | 0 | 0 | 0 | Weihua Hu | completed | FLINK-31439 | info | ||
| 297 | FLIP-297: Improve Auxiliary Sql Statements |
3
Jark Wu
Timo Walther yuxia |
0 | 0 | Ran Tao | in progress | FLINK-31256 | info | ||
| 296 | FLIP-296: Extend watermark-related features for SQL | Flink | 1.18.0 |
3
Jark Wu
Leonard Xu Yun Tang |
0 | 0 | Yun Tang | completed | FLINK-31535 | info |
| 295 | FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations | Flink | 1.18 |
5
Jing Ge
Jark Wu Leonard Xu Rui Fan <1996fanrui@gmail.com> Dong Lin |
0 | 0 | Feng Jin | in progress | FLINK-32427 | info |
| 294 | FLIP-294: Support Customized Catalog Modification Listener | Flink | 1.18 |
4
Benchao Li
Jing Ge Leonard Xu yuxia |
0 | 0 | Fang Yong | completed | FLINK-32402 | info |
| 293 | FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway | Flink | 1.18.0 |
6
Dong Lin
weijie guo Leonard Xu Jingsong Li Benchao Li Jing Ge |
0 | 0 | Fang Yong | completed | FLINK-31496 | info |
| 292 | FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration |
6
Jark Wu
Lincoln Lee Leonard Xu Benchao Li godfrey he Jing Ge |
0 | 0 | Jane Chen | unknown | info | |||
| 291 | FLIP-291: Externalized Declarative Resource Management | Flink | 1.18 |
3
Roman Khachatryan
=?UTF-8?Q?Gyula_F=C3=B3ra?= Konstantin Knauf |
0 | 0 | David Morávek | in progress | FLINK-31316 | info |
| 290 | FLIP-290 Operator state compression |
2
Martijn Visser
weijie guo |
0 | 0 | Etienne Chauchot | under discussion | info | |||
| 289 | FLIP-289: Support online inference (Flink ML) | ml | 2.2.0 |
2
Dian Fu
Zhipeng Zhang |
0 | 0 | Jiang Xin | completed | FLINK-30715 | info |
| 288 | FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source | kafka | 4.0.0 |
5
Qingsheng Ren
Leonard Xu Rui Fan <1996fanrui@gmail.com> Martijn Visser Jing Ge |
0 | 0 | Qingsheng Ren | completed | FLINK-31953 | info |
| 287 | FLIP-287: Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID | Flink | 1.18.0 |
6
Lijie Wang
Zhu Zhu Tzu-Li (Gordon) Tai Leonard Xu Martijn Visser Jing Ge |
0 | 0 | João Boto | completed | FLINK-32376 | info |
| 286 | FLIP-286: Fix the API stability/scope annotation inconsistency in AbstractStreamOperator | Flink | 1.17 | 0 | 0 | 0 | Jiangjie Qin | in progress | FLINK-30645 | info |
| 285 | FLIP-285: Refactoring LeaderElection to make Flink support multi-component leader election out-of-the-box | Flink | 1.18.0 |
2
Yang Wang
=?UTF-8?Q?David_Mor=C3=A1vek?= |
0 | 0 | Matthias Pohl | completed | FLINK-26522 | info |
| 284 | FLIP-284 : Making AsyncSinkWriter Flush triggers adjustable |
1
Danny Cranmer
|
0 | 0 | Ahmed Hamdy | unknown | info | |||
| 283 | FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs |
4
Zhu Zhu
Lijie Wang Xintong Song yuxia |
0 | 0 | Junrui Lee | unknown | info | |||
| 282 | FLIP-282: Introduce Delete & Update API |
3
Jark Wu
yuxia Lincoln Lee |
0 | 0 | luoyuxia | unknown | info | |||
| 281 | FLIP-281 Sink Supports Speculative Execution For Batch Job | Flink | 1.17 |
5
Biao Liu
Lijie Wang Zhu Zhu yuxia Jing Zhang |
1
Martijn Visser
|
0 | Biao Liu | completed | FLINK-30725 | info |
| 280 | FLIP-280: Introduce EXPLAIN PLAN_ADVICE to provide SQL advice |
4
Jingsong Li
godfrey he Jark Wu Lincoln Lee |
0 | 0 | Jane Chen | unknown | info | |||
| 279 | FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode |
3
Jark Wu
godfrey he Shengkai Fang |
0 | 0 | Jing Ge | under discussion | info | |||
| 278 | FLIP-278: HybridSource Table & Sql Api Implementation | 0 | 0 | 0 | Ran Tao | under discussion | info | |||
| 277 | FLIP-277: Native GlueCatalog Support in Flink |
5
Dong Lin
Jark Wu Danny Cranmer yuxia Konstantin Knauf |
0 | 0 | Samrat Deb | in progress | FLINK-29549 | info | ||
| 276 | FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store | 0 | 0 | 0 | Fang Yong | under discussion | info | |||
| 275 | FLIP-275: Support Remote SQL Client Based on SQL Gateway |
3
Jark Wu
godfrey he Shengkai Fang |
0 | 0 | Zelin Yu | unknown | info | |||
| 274 | FLIP-274: Introduce metric group for OperatorCoordinator | Flink | 1.18.0 |
5
Jark Wu
Qingsheng Ren Zhu Zhu Leonard Xu Dong Lin |
0 |
2
Chesnay Schepler
Martijn Visser |
Ruan Hang | unknown | info | |
| 273 | FLIP-273: Improve the Catalog API to Support ALTER TABLE syntax |
4
Jingsong Li
Dong Lin Jark Wu Shengkai Fang |
0 | 0 | Shengkai Fang | not accepted | FLINK-30493 | info | ||
| 272 | FLIP-272: Generalized delegation token support | Flink | 1.17 |
3
Danny Cranmer
=?UTF-8?Q?Gyula_F=C3=B3ra?= =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Gabor Somogyi | completed | FLINK-29918 | info |
| 271 | FLIP-271: Autoscaling |
7
=?UTF-8?B?xZByaGlkaSBNw6F0ecOhcw==?=
Thomas Weise Yang Wang Maximilian Michels =?UTF-8?Q?Gyula_F=C3=B3ra?= Dong Lin =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Maximilian Michels | not accepted | FLINK-30260 | info | ||
| 270 | FLIP-270: Repeatable Cleanup of Checkpoints | 0 | 0 | 0 | Matthias Pohl | under discussion | info | |||
| 269 | FLIP-269: Properly Handling the Processing Timers on Job Termination | 0 | 0 | 0 | Yun Gao | unknown | info | |||
| 268 | FLIP-268: Kafka Rack Awareness | 0 | 0 | 0 | Jeremy DeGroot | unknown | info | |||
| 266 | FLIP-266: Simplify network memory configurations for TaskManager | Flink | 1.17 |
3
Zhu Zhu
Lijie Wang Xintong Song |
0 | 0 | Yingjie Cao | completed | FLINK-30469 | info |
| 265 | FLIP-265 Deprecate and remove Scala API support | Flink | 1.17, 2.0 |
3
Matthias Pohl
Maximilian Michels =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Martijn Visser | in progress | FLINK-29739 | info |
| 264 | FLIP-264: Extract CoordinatorContextBase | 0 | 0 | 0 | gang ye | under discussion | info | |||
| 263 | FLIP-263: Improve resolving schema compatibility |
4
godfrey he
Yu Li Yun Tang Yuan Mei |
0 | 0 | Hangxiang Yu | unknown | info | |||
| 262 | FLIP-262: Introduce MongoDB connector | Flink | 1.17 |
4
Matthias Pohl
Martijn Visser Leonard Xu Qingsheng Ren |
0 | 0 | jiabao.sun | completed | FLINK-6573 | info |
| 261 | FLIP-261: Support DEFAULT Constraint In Sql DDL | Flink | 1.3 | 0 | 0 | 0 | Ran Tao | completed | FLINK-4557 | info |
| 260 | FLIP-260: Expose Finish Method For TableFunction |
3
Jingsong Li
Piotr Nowojski Timo Walther |
0 | 0 | lincoln lee | under discussion | info | |||
| 259 | FLIP-259: Use StatefulSet instead of Deployment to deploy Flink with standalone mode on kubernetes | 0 | 0 | 0 | Peng Yuan | not accepted | FLINK-29110 | info | ||
| 258 | FLIP-258: Guarantee binary compatibility for Public/-Evolving APIs between patch releases | Flink | 1.15.3, 1.16 | 0 | 0 | 0 | Chesnay Schepler | completed | FLINK-29255 | info |
| 257 | FLIP-257: Flink JobManager Process Split | 0 | 0 | 0 | ConradJam | under discussion | info | |||
| 256 | FLIP-256: Support Job Dynamic Parameter With Flink Rest Api | Flink | 1.17 |
3
Danny Cranmer
=?UTF-8?Q?Gyula_F=C3=B3ra?= Martijn Visser |
0 | 0 | ConradJam | completed | FLINK-27060 | info |
| 255 | FLIP-255: Introduce pre-aggregated merge to Table Store | 0 | 0 | 0 | Nathan Kan | not accepted | FLINK-27626 | info | ||
| 254 | FLIP-254: Redis Streams Connector |
3
Jingsong Li
Martijn Visser Yu Li |
0 | 0 | Martijn Visser | in progress | FLINK-15571 | info | ||
| 252 | FLIP-252: Amazon DynamoDB Sink Connector | AWS Connectors | 2.0.0 |
1
Martijn Visser
|
0 | 0 | Danny Cranmer | completed | FLINK-24229 | info |
| 251 | FLIP-251: Support collecting arbitrary number of streams | Flink | 1.16 |
2
Martijn Visser
Konstantin Knauf |
0 | 0 | Chesnay Schepler | completed | FLINK-28644 | info |
| 250 | FLIP-250: Support Customized Kubernetes Schedulers Proposal | Flink | 1.17 |
4
Yang Wang
=?UTF-8?Q?Gyula_F=C3=B3ra?= =?UTF-8?Q?M=C3=A1rton_Balassi?= Martijn Visser |
0 | 0 | bzhao | in progress | FLINK-26559 | info |
| 249 | FLIP-249: Flink Web UI Enhancement for Speculative Execution | Flink | 1.16 |
2
Zhu Zhu
Jing Zhang |
0 | 0 | Gen Luo | completed | FLINK-28587 | info |
| 248 | FLIP-248: Introduce dynamic partition pruning | Flink | 1.16 |
2
Jark Wu
Jing Zhang |
0 | 0 | Godfrey He | completed | FLINK-28706 | info |
| 247 | FLIP-247: Bulk fetch of table and column statistics for given partitions | Flink | 1.16 |
1
Jark Wu
|
0 | 0 | Jing Ge | completed | FLINK-28778 | info |
| 246 | FLIP-246: Dynamic Kafka Source (originally Multi Cluster Kafka Source) | kafka | 3.1.0 |
5
Thomas Weise
Tzu-Li (Gordon) Tai Rui Fan <1996fanrui@gmail.com> Martijn Visser Jing Ge |
0 | 0 | Mason Chen | unknown | info | |
| 245 | FLIP-245: Source Supports Speculative Execution For Batch Job | Flink | 1.16 |
3
Guowei Ma
Jing Zhang Zhu Zhu |
0 | 0 | Jing Zhang | completed | FLINK-28397 | info |
| 244 | FLIP-244: Support IterativeCondition with AggregateFunction in CEP Pattern | 0 | 0 | 0 | Mingde Peng | unknown | info | |||
| 243 | FLIP-243: Dedicated Opensearch connectors | Flink | 1.17 |
3
Danny Cranmer
Martijn Visser Matthias Pohl |
0 | 0 | Andriy Redko | completed | FLINK-25756 | info |
| 242 | FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink | Flink | 1.16 |
3
Danny Cranmer
Martijn Visser Piotr Nowojski |
0 | 0 | Hong Liang Teoh | completed | FLINK-28487 | info |
| 241 | FLIP-241: Completed Jobs Information Enhancement | Flink | 1.16 |
4
Zhu Zhu
Yang Wang Yangze Guo Xintong Song |
0 | 0 | Junhan Yang | completed | FLINK-28307 | info |
| 240 | FLIP-240: Introduce "ANALYZE TABLE" Syntax | Flink | 1.16 | 0 | 0 | 0 | Godfrey He | completed | FLINK-28489 | info |
| 239 | FLIP-239: Port JDBC Connector to FLIP-27&FLIP-143 |
5
Sergey Nuyanzin
Qingsheng Ren Leonard Xu Martijn Visser Jing Ge |
0 | 0 | RocMarshal | not accepted | FLINK-25420 | info | ||
| 238 | FLIP-238: Introduce FLIP-27-based Data Generator Source | Flink | 1.17 |
2
Martijn Visser
Qingsheng Ren |
0 | 0 | Alexander Fedulov | completed | FLINK-27919 | info |
| 237 | FLIP-237: Thrift Format Support | 0 | 0 | 0 | Chen Qin | under discussion | info | |||
| 236 | FLIP-236: Asynchronous Job Submission | 0 | 0 | 0 | Nuno Afonso | under discussion | info | |||
| 235 | FLIP-235: Hybrid Shuffle Mode | Flink | 1.16 | 0 | 0 | 0 | Weijie Guo | completed | FLINK-27862 | info |
| 234 | FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems | Flink | 1.16 |
3
Jark Wu
Jingsong Li Martijn Visser |
0 | 0 | lincoln lee | completed | FLINK-28779 | info |
| 233 | FLIP-233: Introduce HTTP Connector | 0 | 0 | 0 | Jeremy Ber | unknown | info | |||
| 232 | FLIP-232: Add Retry Support For Async I/O In DataStream API | Flink | 1.16 |
2
Jark Wu
Jingsong Li |
0 | 0 | lincoln lee | completed | FLINK-27878 | info |
| 231 | FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors | Flink | 1.16 |
5
Jark Wu
Leonard Xu Jingsong Li Jing Zhang Martijn Visser |
0 | 0 | Godfrey He | completed | FLINK-27982 | info |
| 229 | FLIP-229: Introduces Join Hint for Flink SQL Batch Job | Flink | 1.16 |
5
Jark Wu
Timo Walther Leonard Xu godfrey he Yun Tang |
0 | 0 | Godfrey He | completed | FLINK-27853 | info |
| 228 | FLIP-228: Support Within between events in CEP Pattern |
4
Dian Fu
Martijn Visser Utopia Xingbo Huang |
0 | 0 | Nicholas Jiang | unknown | info | |||
| 227 | FLIP-227: Support overdraft buffer | Flink | 1.16 |
3
Dawid Wysakowicz
=?UTF-8?Q?David_Mor=C3=A1vek?= Piotr Nowojski |
0 | 0 | Rui Fan | completed | FLINK-27530 | info |
| 226 | FLIP-226: Introduce Schema Evolution on Table Store |
2
Jark Wu
Jingsong Li |
0 | 0 | Jingsong Lee | not accepted | FLINK-27365 | info | ||
| 225 | FLIP-225: Implement standalone mode support in the kubernetes operator | kubernetes-operator | 1.2.0 |
2
Danny Cranmer
Yang Wang |
0 | 0 | Usamah Jassat | completed | FLINK-27416 | info |
| 224 | FLIP-224: Blocklist Mechanism | Flink | 1.16 |
4
Yang Wang
Zhu Zhu Yangze Guo Xintong Song |
0 | 0 | Lijie Wang | completed | FLINK-28130 | info |
| 223 | FLIP-223: Support HiveServer2 Endpoint | Flink | 1.16 |
1
Jark Wu
|
0 | 0 | Shengkai Fang | completed | FLINK-28149 | info |
| 222 | FLIP-222: Support full job lifecycle statements in SQL client |
2
Jark Wu
Martijn Visser |
0 | 0 | Paul Lam | in progress | FLINK-27344 | info | ||
| 221 | FLIP-221: Abstraction for lookup source cache and metric | Flink | 1.16 |
3
Jark Wu
Martijn Visser Leonard Xu |
0 | 0 | Qingsheng Ren | completed | FLINK-28415 | info |
| 220 | FLIP-220: Binary Sorted State | 0 | 0 | 0 | David Anderson | in progress | FLINK-27176 | info | ||
| 219 | FLIP-219: Revised Format API | 0 | 0 | 0 | Arvid Heise | unknown | info | |||
| 218 | FLIP-218: Support SELECT clause in CREATE TABLE(CTAS) | Flink | 1.17 |
2
Jark Wu
Jing Zhang |
0 | 0 | Mang Zhang | in progress | FLINK-26942 | info |
| 217 | FLIP-217: Support watermark alignment of source splits | Flink | 1.17 |
3
Martijn Visser
Thomas Weise Piotr Nowojski |
0 | 0 | Sebastian Mattheis | completed | FLINK-28853 | info |
| 216 | FLIP-216: Introduce pluggable dialect and plan for migrating Hive dialect | Flink | 1.18 |
6
Jark Wu
Leonard Xu yuxia Jingsong Li Jing Zhang Martijn Visser |
0 | 0 | luoyuxia | completed | FLINK-26603 | info |
| 215 | FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator | kubernetes-operator | 1.0 |
2
Yang Wang
Xintong Song |
0 | 0 | WenJun Min | completed | FLINK-26784 | info |
| 214 | FLIP-214: Support Advanced Function DDL | Flink | 1.16 |
4
Jark Wu
Jing Zhang godfrey he Leonard Xu |
0 | 0 | ron liu | completed | FLINK-14055 | info |
| 213 | FLIP-213: TaskManager's Flame Graphs | 0 | 0 | 0 | Jacky Lau | under discussion | info | |||
| 212 | FLIP-212: Introduce Flink Kubernetes Operator | kubernetes-operator | 1.0 |
7
Thomas Weise
=?UTF-8?Q?Gyula_F=C3=B3ra?= Yang Wang Danny Cranmer Yangze Guo =?UTF-8?Q?M=C3=A1rton_Balassi?= Xintong Song |
0 | 0 | Thomas Weise | completed | FLINK-25963 | info |
| 211 | FLIP-211: Kerberos delegation token framework | Flink | 1.17 |
3
Chesnay Schepler
=?UTF-8?Q?Gyula_F=C3=B3ra?= =?UTF-8?Q?M=C3=A1rton_Balassi?= |
0 | 0 | Márton Balassi | completed | FLINK-21232 | info |
| 210 | FLIP-210: Change logging level dynamically at runtime | 0 | 0 | 0 | Wenhao Ji | unknown | info | |||
| 209 | FLIP-209: Support to run multiple shuffle plugins in one session cluster | 0 | 0 | 0 | Yingjie Cao | under discussion | info | |||
| 208 | FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records |
2
Leonard Xu
Qingsheng Ren |
0 | 0 | Dong Lin | in progress | FLINK-25509 | info | ||
| 207 | FLIP-207: Flink backward and forward compatibility | 0 | 0 | 0 | Jing Ge | under discussion | info | |||
| 206 | FLIP-206: Support PyFlink Runtime Execution in Thread Mode | Flink | 1.15 |
4
Wei Zhong
Dian Fu Thomas Weise Till Rohrmann |
0 | 0 | HuangXingbo | in progress | FLINK-25718 | info |
| 205 | FLIP-205: Support Cache in DataStream for Batch Processing | Flink | 1.16 |
2
Dian Fu
Dong Lin |
0 | 0 | Xuannan Su | completed | FLINK-27521 | info |
| 204 | FLIP-204: Introduce Hash Lookup Join |
4
Jark Wu
Jing Zhang Jingsong Li godfrey he |
0 | 0 | Jing Zhang | in progress | FLINK-23687 | info | ||
| 203 | FLIP-203: Incremental savepoints | Flink | 1.15 |
3
Yu Li
Konstantin Knauf Till Rohrmann |
0 | 0 | Piotr Nowojski | completed | FLINK-25276 | info |
| 202 | [DRAFT] FLIP-202: Introduce ClickHouse Connector | 0 | 0 | 0 | RocMarshal | in progress | FLINK-26999 | info | ||
| 201 | FLIP-201: Persist local state in working directory | Flink | 1.15 |
4
Matthias Pohl
Yang Wang Chesnay Schepler Till Rohrmann |
0 | 0 | Till Rohrmann | completed | FLINK-25817 | info |
| 200 | FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP) | 0 | 0 | 0 | Yunfeng Zhou | under discussion | info | |||
| 199 | FLIP-199: Change some default config values of blocking shuffle for better usability | Flink | 1.15 | 0 | 0 | 0 | Yingjie Cao | completed | FLINK-25636 | info |
| 198 | FLIP-198: Working directory for Flink processes | Flink | 1.15 |
2
Yang Wang
Till Rohrmann |
0 | 0 | Till Rohrmann | completed | FLINK-25402 | info |
| 197 | FLIP-197: API stability graduation process | Flink | 1.15 |
2
=?UTF-8?Q?Ingo_B=c3=bcrk?=
Till Rohrmann |
0 | 0 | Till Rohrmann | in progress | FLINK-25346 | info |
| 196 | FLIP-196: Source API stability guarantees |
2
=?UTF-8?Q?Ingo_B=c3=bcrk?=
Till Rohrmann |
0 | 0 | Till Rohrmann | in progress | FLINK-25345 | info | ||
| 195 | FLIP-195: Improve the name and structure of vertex and operator name for job | Flink | 1.15 |
4
Jark Wu
godfrey he Yangze Guo Yun Tang |
0 | 0 | wenlong lyu | completed | FLINK-25070 | info |
| 194 | FLIP-194: Introduce the JobResultStore | Flink | 1.15 |
4
Zhu Zhu
Matthias Pohl Xintong Song Till Rohrmann |
0 | 0 | Matthias Pohl | completed | FLINK-11813 | info |
| 193 | FLIP-193: Snapshots ownership | Flink | 1.15 | 0 | 0 | 0 | Dawid Wysakowicz | completed | FLINK-25154 | info |
| 192 | FLIP-192: Support withBroadcast in DataStream (FlinkML) | 0 | 0 | 0 | Zhipeng Zhang | unknown | info | |||
| 191 | FLIP-191: Extend unified Sink interface to support small file compaction | Flink | 1.15 |
2
Arvid Heise
Guowei Ma |
0 | 0 | Fabian Paul | completed | FLINK-25555 | info |
| 190 | FLIP-190: Support Version Upgrades for Table API & SQL Programs |
2
=?UTF-8?Q?Ingo_B=c3=bcrk?=
godfrey he |
0 | 0 | Timo Walther | in progress | FLINK-25217 | info | ||
| 189 | FLIP-189: SQL Client Usability Improvements | Flink | 1.18.0 |
4
Jark Wu
Konstantin Knauf Till Rohrmann Timo Walther |
0 | 0 | Sergey Nuyanzin | in progress | FLINK-24890 | info |
| 188 | FLIP-188: Introduce Built-in Dynamic Table Storage | Flink | 1.15 |
4
Kurt Young
godfrey he Becket Qin Jark Wu |
0 | 0 | Jingsong Lee | completed | FLINK-25152 | info |
| 187 | FLIP-187: Adaptive Batch Scheduler | Flink | 1.15 |
2
Zhu Zhu
Till Rohrmann |
0 | 0 | Lijie Wang | completed | FLINK-24892 | info |
| 186 | FLIP-186: Refactor DataStreamUtils#reinterpretAsKeyedStream | 0 | 0 | 0 | Senhong Liu | under discussion | info | |||
| 185 | FLIP-185: Shorter heartbeat timeout and interval default values | 0 | 0 | 0 | Till Rohrmann | in progress | FLINK-23403 | info | ||
| 184 | FLIP-184: Refine ShuffleMaster lifecycle management for pluggable shuffle service framework | Flink | 1.14 |
3
Guowei Ma
Jingsong Li Zhu Zhu |
0 | 0 | Yingjie Cao | completed | FLINK-22910 | info |
| 183 | FLIP-183: Dynamic buffer size adjustment | Flink | 1.14 |
3
Till Rohrmann
Piotr Nowojski Yuan Mei |
0 | 0 | Anton Kalashnikov | completed | FLINK-23451 | info |
| 182 | FLIP-182: Support watermark alignment of FLIP-27 Sources | Flink | 1.15 |
3
Arvid Heise
Thomas Weise Seth Wiesman |
0 | 0 | Piotr Nowojski | completed | FLINK-18450 | info |
| 181 | FLIP-181: Custom netty HTTP request inbound/outbound handlers | Flink | 1.14 |
1
Konstantin Knauf
|
0 | 0 | Márton Balassi | completed | FLINK-23272 | info |
| 180 | FLIP-180: Adjust StreamStatus and Idleness definition | Flink | 1.14 |
4
Tzu-Li (Gordon) Tai
Piotr Nowojski Till Rohrmann Stephan Ewen |
0 | 0 | Arvid Heise | completed | FLINK-23767 | info |
| 179 | FLIP-179: Expose Standardized Operator Metrics | Flink | 1.14 |
3
Chesnay Schepler
Thomas Weise Becket Qin |
0 | 0 | Arvid Heise | completed | FLINK-23652 | info |
| 178 | FLIP-178 Support Advanced Function DDL | 0 | 0 | 0 | Zhenqiu Huang | unknown | info | |||
| 177 | FLIP-177: Extend Sink API | Flink | 1.14 |
3
Danny Cranmer
Thomas Weise Guowei Ma |
0 | 0 | Arvid Heise | completed | FLINK-23621 | info |
| 176 | FLIP-176: Unified Iteration to Support Algorithms (Flink ML) | ml | 2.0 |
4
Guowei Ma
Becket Qin Till Rohrmann Yunfeng Zhou |
0 | 0 | Yun Gao | completed | FLINK-24642 | info |
| 175 | FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator (Flink ML) | ml | 2.0.0 |
1
Dong Lin
|
0 | 0 | Dong Lin | completed | FLINK-23959 | info |
| 174 | FLIP-174: Improve the WithParam interface (Flink ML) | ml | 2.0.0 |
1
Dong Lin
|
0 | 0 | Dong Lin | completed | FLINK-24354 | info |
| 173 | FLIP-173: Support DAG of algorithms (Flink ML) | ml | 2.0.0 |
1
Dong Lin
|
0 | 0 | Dong Lin | completed | FLINK-22915 | info |
| 172 | FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer | Flink | 1.14 |
3
Arvid Heise
Dawid Wysakowicz Piotr Nowojski |
0 | 0 | Wenhao Ji | completed | FLINK-22452 | info |
| 171 | FLIP-171: Async Sink | Flink | 1.15 |
4
Arvid Heise
Danny Cranmer =?UTF-8?B?5YiY5bu65Yia?= Piotr Nowojski |
0 | 0 | Steffen Hausmann | completed | FLINK-24041 | info |
| 170 | FLIP-170: Adding Checkpoint Rejection Mechanism | 0 | 0 | 0 | Senhong Liu | in progress | FLINK-18578 | info | ||
| 169 | FLIP-169: DataStream API for Fine-Grained Resource Requirements | Flink | 1.14 |
5
Arvid Heise
Zhu Zhu =?UTF-8?B?5YiY5bu65Yia?= JING ZHANG Xintong Song |
0 | 0 | Yangze Guo | completed | FLINK-21925 | info |
| 168 | FLIP-168: Speculative Execution for Batch Job | Flink | 1.16 |
4
Guowei Ma
Jing Zhang Zhu Zhu Yun Tang |
0 | 0 | wangwj | completed | FLINK-28131 | info |
| 167 | FLIP-167: Watermarks for Sink API | Flink | 1.14 | 0 | 0 | 0 | Eron Wright | completed | FLINK-22700 | info |
| 166 | FLIP-166: Pinot Connector | 0 | 0 | 0 | Yupeng Fu | unknown | info | |||
| 165 | FLIP-165: Operator's Flame Graphs | Flink | 1.13 |
4
Zhu Zhu
Roman Khachatryan Till Rohrmann Piotr Nowojski |
0 | 0 | Alexander Fedulov | completed | FLINK-13550 | info |
| 164 | FLIP-164: Improve Schema Handling in Catalogs | Flink | 1.13 |
3
Dawid Wysakowicz
Seth Wiesman Jark Wu |
0 | 0 | Timo Walther | in progress | FLINK-21394 | info |
| 163 | FLIP-163: SQL Client Improvements | Flink | 1.13 |
3
Jark Wu
godfrey he Timo Walther |
0 | 0 | Shengkai Fang | completed | FLINK-21454 | info |
| 162 | FLIP-162: Consistent Flink SQL time function behavior | Flink | 1.13 |
3
Jark Wu
Kurt Young Timo Walther |
0 | 0 | Leonard Xu | completed | FLINK-21617 | info |
| 161 | FLIP-161: Configuration through envrionment variables | 0 | 0 | 0 | Ingo Bürk | unknown | info | |||
| 160 | FLIP-160: Adaptive Scheduler | Flink | 1.13 |
6
Yu Li
Robert Metzger Maximilian Michels Zhu Zhu Xintong Song Till Rohrmann |
0 | 0 | Till Rohrmann | completed | FLINK-21075 | info |
| 159 | FLIP-159: Reactive Mode | Flink | 1.13 |
4
Zhu Zhu
Till Rohrmann Yu Li Xintong Song |
0 | 0 | Till Rohrmann | completed | FLINK-10407 | info |
| 158 | FLIP-158: Generalized incremental checkpoints | Flink | 1.15 | 0 | 0 | 0 | Roman Khachatryan | completed | FLINK-21352 | info |
| 157 | FLIP-157: Migrate Flink Documentation from Jekyll to Hugo | Flink | 1.13 | 0 | 0 | 0 | Seth Wiesman | completed | FLINK-21193 | info |
| 156 | FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements | Flink | 1.13 |
3
Zhu Zhu
Till Rohrmann Xintong Song |
0 | 0 | Yangze Guo | completed | FLINK-21267 | info |
| 155 | FLIP-155: Introduce a few convenient operations in Table API | 0 | 0 | 0 | Dian Fu | under discussion | info | |||
| 154 | FLIP-154: SQL Implicit Type Coercion | 0 | 0 | 0 | Danny Chen | in progress | FLINK-17484 | info | ||
| 153 | FLIP-153: Support state access in Python DataStream API | Flink | 1.13 |
4
Dian Fu
Yu Li Becket Qin Yun Tang |
0 | 0 | Shuiqiang Chen | completed | FLINK-21111 | info |
| 152 | FLIP-152: Hive Query Syntax Compatibility | Flink | 1.13 | 0 | 0 | 0 | Rui Li | in progress | FLINK-21529 | info |
| 151 | FLIP-151: Incremental snapshots for heap-based state backend |
3
Roman Khachatryan
Yu Li Piotr Nowojski |
0 | 0 | Roman Khachatryan | in progress | FLINK-21648 | info | ||
| 150 | FLIP-150: Introduce Hybrid Source | Flink | 1.14 |
4
Arvid Heise
Thomas Weise Becket Qin Stephan Ewen |
0 | 0 | Nicholas Jiang | in progress | FLINK-22668 | info |
| 149 | FLIP-149: Introduce the upsert-kafka Connector | Flink | 1.12 | 0 | 0 | 0 | Jark Wu | completed | FLINK-19857 | info |
| 148 | FLIP-148: Introduce Sort-Based Blocking Shuffle to Flink | Flink | 1.13 |
1
Kurt Young
|
0 | 0 | Yingjie Cao | completed | FLINK-19582 | info |
| 147 | FLIP-147: Support Checkpoints After Tasks Finished | Flink | 1.14 |
7
Arvid Heise
Guowei Ma =?UTF-8?B?5YiY5bu65Yia?= Piotr Nowojski Dawid Wysakowicz JING ZHANG Aljoscha Krettek |
0 | 0 | Yun Gao | completed | FLINK-2491 | info |
| 146 | FLIP-146: Improve new TableSource and TableSink interfaces | Flink | 1.13 | 0 | 0 | 0 | Jingsong Lee | completed | FLINK-19719 | info |
| 145 | FLIP-145: Support SQL windowing table-valued function | Flink | 1.13 |
3
Jark Wu
Pengcheng Liu Timo Walther |
0 | 0 | Danny Chen | completed | FLINK-19604 | info |
| 144 | FLIP-144: Native Kubernetes HA for Flink | Flink | 1.12 |
2
Xintong Song
Till Rohrmann |
0 | 0 | Yang Wang | completed | FLINK-12884 | info |
| 143 | FLIP-143: Unified Sink API | Flink | 1.12 |
4
Jingsong Li
Kostas Kloudas =?UTF-8?B?5YiY5bu65Yia?= Aljoscha Krettek |
0 | 0 | Guowei Ma | completed | FLINK-19510 | info |
| 142 | FLIP-142: Disentangle StateBackends from Checkpointing | Flink | 1.13 |
8
Yu Li
Kostas Kloudas Tzu-Li (Gordon) Tai David Anderson Konstantin Knauf Dawid Wysakowicz Till Rohrmann Aljoscha Krettek |
0 | 0 | Seth Wiesman | completed | FLINK-19463 | info |
| 141 | FLIP-141: Intra-Slot Managed Memory Sharing | Flink | 1.12 | 0 | 0 | 0 | Xintong Song | completed | FLINK-19177 | info |
| 140 | FLIP-140: Introduce batch-style execution for bounded keyed streams | Flink | 1.12 |
2
Seth Wiesman
Aljoscha Krettek |
0 | 0 | Dawid Wysakowicz | completed | FLINK-19268 | info |
| 139 | FLIP-139: General Python User-Defined Aggregate Function Support on Table API | Flink | 1.13 |
3
Dian Fu
Hequn Cheng jincheng sun |
0 | 0 | Wei Zhong | completed | FLINK-19185 | info |
| 138 | FLIP-138: Declarative Resource management | Flink | 1.12 | 0 | 0 | 0 | Chesnay Schepler | completed | FLINK-10404 | info |
| 137 | FLIP-137: Support Pandas UDAF in PyFlink | Flink | 1.12 |
2
Hequn Cheng
jincheng sun |
0 | 0 | HuangXingbo | completed | FLINK-19169 | info |
| 136 | FLIP-136: Improve interoperability between DataStream and Table API | Flink | 1.14 |
4
Kurt Young
Jingsong Li Jark Wu Xingcan Cui |
0 | 0 | Timo Walther | completed | FLINK-19976 | info |
| 135 | FLIP-135: Approximate Task-Local Recovery |
3
Becket Qin
Yu Li Piotr Nowojski |
0 | 0 | Yuan Mei | in progress | FLINK-18112 | info | ||
| 134 | FLIP-134: Batch execution for the DataStream API | Flink | 1.12 |
1
Dawid Wysakowicz
|
0 | 0 | Kostas Kloudas | completed | FLINK-19316 | info |
| 133 | FLIP-133: Rework PyFlink Documentation | Flink | 1.12 |
4
Dian Fu
Hequn Cheng Seth Wiesman jincheng sun |
0 | 0 | Jincheng Sun | completed | FLINK-18775 | info |
| 132 | FLIP-132: Temporal Table DDL and Temporal Table Join | Flink | 1.12 | 0 | 0 | 0 | Leonard Xu | completed | FLINK-16824 | info |
| 131 | FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API) | 0 | 0 | 0 | Aljoscha Krettek | in progress | FLINK-19153 | info | ||
| 130 | FLIP-130: Support Python DataStream API (Stateless part) | Flink | 1.12 |
3
Hequn Cheng
Aljoscha Krettek jincheng sun |
0 | 0 | Shuiqiang Chen | completed | FLINK-18761 | info |
| 129 | FLIP-129: Refactor Descriptor API to register connectors in Table API | Flink | 1.14 |
4
Jark Wu
Jingsong Li JING ZHANG Timo Walther |
0 | 0 | Jark Wu | completed | FLINK-23062 | info |
| 128 | FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers | Flink | 1.12 | 0 | 0 | 0 | Danny Cranmer | completed | FLINK-17688 | info |
| 127 | FLIP-127: Support Elasticsearch Source Connector | 0 | 0 | 0 | Jacky Lau | not accepted | FLINK-16713 | info | ||
| 126 | FLIP-126: Unify (and separate) Watermark Assigners | Flink | 1.11 | 0 | 0 | 0 | Aljoscha Krettek | completed | FLINK-17653 | info |
| 125 | FLIP-125: Confluent Schema Registry Catalog | Flink | 1.3 | 0 | 0 | 0 | Danny Chen | unknown | info | |
| 124 | FLIP-124: Add open/close and Collector to (De)SerializationSchema | Flink | 1.11 |
3
Jark Wu
Timo Walther Aljoscha Krettek |
0 | 0 | Dawid Wysakowicz | completed | FLINK-17305 | info |
| 123 | FLIP-123: DDL and DML compatibility for Hive connector | Flink | 1.11 | 0 | 0 | 0 | Rui Li | completed | FLINK-17198 | info |
| 122 | FLIP-122: New Connector Property Keys for New Factory | Flink | 1.11 |
1
Jark Wu
|
0 | 0 | Jark Wu | completed | FLINK-17025 | info |
| 121 | FLIP-121: Support Cython Optimizing Python User Defined Function | Flink | 1.11 |
3
Dian Fu
Hequn Cheng jincheng sun |
0 | 0 | HuangXingbo | completed | FLINK-17115 | info |
| 120 | FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame | Flink | 1.11 |
3
Dian Fu
Hequn Cheng jincheng sun |
0 | 0 | Dian Fu | completed | FLINK-17146 | info |
| 119 | FLIP-119: Pipelined Region Scheduling | Flink | 1.12 |
2
Kurt Young
Zhu Zhu |
0 | 0 | Gary Yao | completed | FLINK-16430 | info |
| 118 | FLIP-118: Improve Flink’s ID system | Flink | 1.12 | 0 | 0 | 0 | Yangze Guo | completed | FLINK-15679 | info |
| 117 | FLIP-117: HBase catalog | 0 | 0 | 0 | Flavio Pompermaier | unknown | info | |||
| 116 | FLIP-116: Unified Memory Configuration for Job Managers | Flink | 1.11 | 0 | 0 | 0 | Andrey Zagrebin | completed | FLINK-16614 | info |
| 115 | FLIP-115: Filesystem connector in Table |
2
Jingsong Li
Jark Wu |
0 | 0 | Jingsong Lee | unknown | info | |||
| 114 | FLIP-114: Support Python UDF in SQL Client | Flink | 1.11 |
3
Dian Fu
Hequn Cheng jincheng sun |
0 | 0 | Wei Zhong | completed | FLINK-16971 | info |
| 113 | FLIP-113: Supports Dynamic Table Options for Flink SQL |
1
Timo Walther
|
0 | 0 | Danny Chen | unknown | info | |||
| 112 | FLIP-112: Support User-Defined Metrics in Python UDF | Flink | 1.11 |
2
Dian Fu
Hequn Cheng |
0 | 0 | Hequn Cheng | completed | FLINK-16670 | info |
| 111 | FLIP-111: Docker image unification | Flink | 1.11 |
2
Till Rohrmann
Andrey Zagrebin |
0 | 0 | Andrey Zagrebin | completed | FLINK-17160 | info |
| 110 | FLIP-110: Support LIKE clause in CREATE TABLE | Flink | 1.11 | 0 | 0 | 0 | Dawid Wysakowicz | completed | FLINK-17001 | info |
| 109 | FLIP-109: Improve Hive dependencies out-of-box experience | 0 | 0 | 0 | Jingsong Lee | unknown | info | |||
| 108 | FLIP-108: Add GPU support in Flink | Flink | 1.11 |
1
Till Rohrmann
|
0 | 0 | Yangze Guo | completed | FLINK-17044 | info |
| 107 | FLIP-107: Handling of metadata in SQL connectors | Flink | 1.12 |
4
Dawid Wysakowicz
Konstantin Knauf Jark Wu Aljoscha Krettek |
0 | 0 | Dawid Wysakowicz | completed | FLINK-15869 | info |
| 106 | FLIP-106: Support Python UDF in SQL Function DDL | Flink | 1.11 |
2
Dian Fu
Hequn Cheng |
0 | 0 | Wei Zhong | completed | FLINK-16665 | info |
| 105 | FLIP-105: Support to Interpret Changelog in Flink SQL (Introducing Debezium and Canal Format) | Flink | 1.11 |
1
Jark Wu
|
0 | 0 | Jark Wu | completed | FLINK-15331 | info |
| 104 | FLIP-104: Add More Metrics to Jobmanager | Flink | 1.12 | 0 | 0 | 0 | YadongXie | completed | FLINK-19661 | info |
| 103 | FLIP-103: Better TM/JM Log Display | Flink | 1.11 |
5
Kurt Young
Jark Wu jincheng sun Zhu Zhu Till Rohrmann |
0 | 0 | YadongXie | completed | FLINK-13987 | info |
| 102 | FLIP-102: Add More Metrics to TaskManager | Flink | 1.12 | 0 | 0 | 0 | YadongXie | completed | FLINK-14431 | info |
| 101 | FLIP-101: Add Pending Slots Detail | 0 | 0 | 0 | YadongXie | in progress | FLINK-14138 | info | ||
| 100 | FLIP-100: Add Attempt Information |
1
Gary Yao
|
0 | 0 | YadongXie | in progress | FLINK-16050 | info | ||
| 99 | FLIP-99: Make Max Exception Configurable | Flink | 1.10 |
3
Jark Wu
Gary Yao Till Rohrmann |
0 | 0 | YadongXie | in progress | FLINK-11374 | info |
| 98 | FLIP-98: Better Back Pressure Detection |
3
Jark Wu
Kurt Young Till Rohrmann |
0 | 0 | YadongXie | not accepted | FLINK-14127 | info | ||
| 97 | FLIP-97: Support Scalar Vectorized Python UDF in PyFlink | Flink | 1.11 | 0 | 0 | 0 | Dian Fu | completed | FLINK-16114 | info |
| 96 | FLIP-96: Support Python ML Pipeline API | Flink | 1.11 | 0 | 0 | 0 | Hequn Cheng | completed | FLINK-16187 | info |
| 95 | FLIP-95: New TableSource and TableSink interfaces | 0 | 0 | 0 | Timo Walther | in progress | FLINK-16987 | info | ||
| 94 | FLIP-94: Rework 2-phase commit abstractions | 0 | 0 | 0 | Roman Khachatryan | not accepted | FLINK-15776 | info | ||
| 93 | FLIP-93: JDBC catalog and Postgres catalog | 0 | 0 | 0 | Bowen Li | in progress | FLINK-15350 | info | ||
| 92 | FLIP-92: Add N-Ary Stream Operator in Flink | Flink | 1.11 |
1
Nico Kruber
|
0 | 0 | Piotr Nowojski | completed | FLINK-15688 | info |
| 91 | FLIP-91: Support SQL Gateway | Flink | 1.16 |
2
Jark Wu
Timo Walther |
0 | 0 | Jark Wu | completed | FLINK-15472 | info |
| 90 | FLIP-90: Support SQL 2016-2017 JSON functions in Table API & SQL | Flink | 1.15 | 0 | 0 | 0 | Forward Xu | completed | FLINK-9477 | info |
| 89 | FLIP-89: Improve usability of TableConfig | 0 | 0 | 0 | Dawid Wysakowicz | unknown | info | |||
| 88 | FLIP-88: PyFlink User-Defined Function Resource Management | Flink | 1.10 |
2
Jark Wu
Hequn Cheng |
0 | 0 | Dian Fu | completed | FLINK-14026 | info |
| 87 | FLIP-87: Primary key constraints in Table API | Flink | 1.11 | 0 | 0 | 0 | Dawid Wysakowicz | completed | FLINK-14977 | info |
| 86 | FLIP-86: Improve Connector Properties | Flink | 1.10 |
4
Jark Wu
Kurt Young Timo Walther Aljoscha Krettek |
0 | 0 | Jark Wu | in progress | FLINK-14644 | info |
| 85 | FLIP-85: Flink Application Mode | Flink | 1.11 |
4
Aljoscha Krettek
tison Rong Rong Venkata Sanath Muppalla |
0 | 0 | Zhenqiu Huang | completed | FLINK-16654 | info |
| 84 | FLIP-84: Improve & Refactor API of TableEnvironment & Table | Flink | 1.11 |
2
Kurt Young
Timo Walther |
0 | 0 | Terry Wang | completed | FLINK-16361 | info |
| 83 | FLIP-83: Flink End-to-end Performance Testing Framework |
5
Yu Li
Becket Qin jincheng sun Gary Yao Hequn Cheng |
0 | 0 | Yu Li | in progress | FLINK-14917 | info | ||
| 82 | FLIP-82: Use real per-job mode for YARN per-job attached execution | 0 | 0 | 0 | Aljoscha Krettek | unknown | info | |||
| 81 | FLIP-81: Executor-related new ConfigOptions. | Flink | 1.10 |
2
Dawid Wysakowicz
Aljoscha Krettek |
0 | 0 | Kostas Kloudas | unknown | info | |
| 80 | FLIP-80: Expression String Serializable and Deserializable | 0 | 0 | 0 | Jark Wu | unknown | info | |||
| 79 | FLIP-79: Function DDL Support | Flink | 1.10 |
3
Kurt Young
Bowen Li Shuyi Chen |
0 | 0 | Zhenqiu Huang | completed | FLINK-7151 | info |
| 78 | FLIP-78: Flink Python UDF Environment and Dependency Management | Flink | 1.10 |
4
Jark Wu
Hequn Cheng Aljoscha Krettek jincheng sun |
0 | 0 | Wei Zhong | completed | FLINK-14019 | info |
| 77 | FLIP-77: Introduce ConfigOptions with Data Types | Flink | 1.10 |
1
Dawid Wysakowicz
|
0 | 0 | Timo Walther | completed | FLINK-14491 | info |
| 76 | FLIP-76: Unaligned Checkpoints | Flink | 1.11 |
2
Piotr Nowojski
Yu Li |
0 | 0 | Arvid Heise | completed | FLINK-14551 | info |
| 75 | FLIP-75: Flink Web UI Improvement Proposal |
1
Piotr Nowojski
|
0 | 0 | YadongXie | unknown | info | |||
| 74 | FLIP-74: Flink JobClient API | Flink | 1.10 |
1
Aljoscha Krettek
|
0 | 0 | Zili Chen | completed | FLINK-14392 | info |
| 73 | FLIP-73: Introducing Executors for job submission | Flink | 1.10 | 0 | 0 | 0 | Kostas Kloudas | completed | FLINK-14376 | info |
| 72 | FLIP-72: Introduce Pulsar Connector | Flink | 1.14 | 0 | 0 | 0 | Yijie Shen | completed | FLINK-14146 | info |
| 71 | FLIP-71: E2E View support in FLINK SQL | Flink | 1.11 |
1
Timo Walther
|
0 | 0 | Zhenghua Gao | completed | FLINK-17105 | info |
| 70 | FLIP-70: Flink SQL Computed Column Design | Flink | 1.10 |
2
Jark Wu
Kurt Young |
0 | 0 | Danny Chen | completed | FLINK-14386 | info |
| 69 | FLIP-69: Flink SQL DDL Enhancement | Flink | 1.10 |
1
Bowen Li
|
0 | 0 | Terry Wang | completed | FLINK-14686 | info |
| 68 | FLIP-68: Extend Core Table System with Pluggable Modules | Flink | 1.10 | 0 | 0 | 0 | Bowen Li | completed | FLINK-14132 | info |
| 67 | FLIP-67: Cluster partitions lifecycle | Flink | 1.11 | 0 | 0 | 0 | Chesnay Schepler | completed | FLINK-14474 | info |
| 66 | FLIP-66: Support Time Attribute in SQL DDL | Flink | 1.10 | 0 | 0 | 0 | Jark Wu | completed | FLINK-14320 | info |
| 65 | FLIP-65: New type inference for Table API UDFs |
6
Jark Wu
jincheng sun Rong Rong Hequn Cheng Aljoscha Krettek |
0 | 0 | Timo Walther | in progress | FLINK-13191 | info | ||
| 64 | FLIP-64: Support for Temporary Objects in Table module | Flink | 1.11 |
1
Dawid Wysakowicz
|
0 | 0 | Dawid Wysakowicz | completed | FLINK-14485 | info |
| 63 | FLIP-63: Rework table partition support | Flink | 1.10 | 0 | 0 | 0 | Jingsong Lee | completed | FLINK-14249 | info |
| 62 | FLIP-62: Set default restart delay for FixedDelay- and FailureRateRestartStrategy to 1s | Flink | 1.10 |
2
Chesnay Schepler
Till Rohrmann |
0 | 0 | Till Rohrmann | completed | FLINK-13884 | info |
| 61 | FLIP-61: Simplify Flink's cluster level RestartStrategy configuration | Flink | 1.10 |
2
Chesnay Schepler
Till Rohrmann |
0 | 0 | Till Rohrmann | completed | FLINK-13921 | info |
| 60 | FLIP-60: Restructure the Table API & SQL documentation | 0 | 0 | 0 | Timo Walther | in progress | FLINK-19524 | info | ||
| 59 | FLIP-59: Enable execution configuration from Configuration object | Flink | 1.10 |
4
Kostas Kloudas
tison =?UTF-8?Q?Gyula_F=C3=B3ra?= Aljoscha Krettek |
0 | 0 | Dawid Wysakowicz | completed | FLINK-14785 | info |
| 58 | FLIP-58: Flink Python User-Defined Stateless Function for Table | Flink | 1.10 |
1
Shaoxuan Wang
|
0 | 0 | Dian Fu | completed | FLINK-14013 | info |
| 57 | FLIP-57: Rework FunctionCatalog | Flink | 1.10 | 0 | 0 | 0 | Bowen Li | completed | FLINK-14090 | info |
| 56 | FLIP-56: Dynamic Slot Allocation | Flink | 1.13 |
2
Gary Yao
Till Rohrmann |
0 | 0 | Xintong Song | completed | FLINK-14187 | info |
| 55 | FLIP-55: Introduction of a Table API Java Expression DSL | Flink | 1.11 | 0 | 0 | 0 | Timo Walther | completed | FLINK-11890 | info |
| 54 | FLIP-54: Evolve ConfigOption and Configuration | 0 | 0 | 0 | Timo Walther | under discussion | info | |||
| 53 | FLIP-53: Fine Grained Operator Resource Management | Flink | 1.10 | 0 | 0 | 0 | Xintong Song | completed | FLINK-14058 | info |
| 52 | FLIP-52 : Remove legacy Program interface. | Flink | 1.10 | 0 | 0 | 0 | Kostas Kloudas | completed | FLINK-13713 | info |
| 51 | FLIP-51: Rework of the Expression Design | 0 | 0 | 0 | Jingsong Lee | not accepted | FLINK-13773 | info | ||
| 50 | FLIP-50: Spill-able Heap Keyed State Backend | 0 | 0 | 0 | Yu Li | in progress | FLINK-12692 | info | ||
| 49 | FLIP-49: Unified Memory Configuration for TaskExecutors | Flink | 1.10 | 0 | 0 | 0 | Xintong Song | completed | FLINK-13980 | info |
| 48 | FLIP-48: Pluggable Intermediate Result Storage | 0 | 0 | 0 | Xuannan Su | in progress | FLINK-13570 | info | ||
| 47 | FLIP-47: Checkpoints vs. Savepoints | 0 | 0 | 0 | Kostas Kloudas | under discussion | info | |||
| 46 | FLIP-46: Graceful Shutdown Handling by UDFs | 0 | 0 | 0 | Kostas Kloudas | in progress | FLINK-13103 | info | ||
| 45 | FLIP-45: Reinforce Job Stop Semantic | 0 | 0 | 0 | Yu Li | not accepted | FLINK-12619 | info | ||
| 44 | FLIP-44: Support Local Aggregation in Flink | 0 | 0 | 0 | vinoyang | in progress | FLINK-12786 | info | ||
| 43 | FLIP-43: State Processor API | Flink | 1.9 | 0 | 0 | 0 | Seth Wiesman | in progress | FLINK-12047 | info |
| 42 | FLIP-42: Rework Flink Documentation | Flink | 1.3 | 0 | 0 | 0 | Konstantin Knauf | in progress | FLINK-12639 | info |
| 41 | FLIP-41: Unify Binary format for Keyed State | Flink | 1.13 | 0 | 0 | 0 | Tzu-Li (Gordon) Tai | completed | FLINK-20976 | info |
| 40 | FLIP-40: Flink Driver | 0 | 0 | 0 | Shuiqiang Chen | under discussion | info | |||
| 39 | FLIP-39: Flink ML pipeline and ML libs | 0 | 0 | 0 | Shuiqiang Chen | not accepted | FLINK-12470 | info | ||
| 38 | FLIP-38: Python Table API | Flink | 1.10 | 0 | 0 | 0 | Jincheng Sun | completed | FLINK-12308 | info |
| 37 | FLIP-37: Rework of the Table API Type System | 0 | 0 | 0 | Timo Walther | in progress | FLINK-12251 | info | ||
| 36 | FLIP-36: Support Interactive Programming in Flink |
2
Timo Walther
Aljoscha Krettek |
0 | 0 | Jiangjie Qin | in progress | FLINK-19343 | info | ||
| 35 | FLIP-35: Support Chinese Documents and Website | Flink | 1.9 | 0 | 0 | 0 | Jark Wu | in progress | FLINK-11526 | info |
| 34 | FLIP-34: Terminate/Suspend Job with Savepoint | Flink | 1.9 | 0 | 0 | 0 | Kostas Kloudas | completed | FLINK-11458 | info |
| 33 | FLIP-33: Standardize Connector Metrics | Flink | 1.14 | 0 | 0 | 0 | Jiangjie Qin | completed | FLINK-11576 | info |
| 32 | FLIP-32: Restructure flink-table for future contributions | Flink | 1.14 | 0 | 0 | 0 | Timo Walther | completed | FLINK-11439 | info |
| 31 | FLIP-31: Pluggable Shuffle Service | Flink | 1.9 | 0 | 0 | 0 | Zhijiang Wang | completed | FLINK-10653 | info |
| 30 | FLIP-30: Unified Catalog APIs | Flink | 1.9 | 0 | 0 | 0 | Xuefu Zhang | completed | FLINK-11275 | info |
| 29 | FLIP-29: Support map/flatMap/aggregate/flatAggregate on TableAPI | Flink | 1.9 | 0 | 0 | 0 | sunjincheng | completed | FLINK-10972 | info |
| 28 | FLIP-28: Long-term goal of making flink-table Scala-free | 0 | 0 | 0 | Timo Walther | unknown | info | |||
| 27 | FLIP-27: Refactor Source Interface | Flink | 1.12 |
4
Piotr Nowojski
Becket Qin Stephan Ewen jincheng sun |
0 | 0 | Aljoscha Krettek | in progress | FLINK-10740 | info |
| 26 | FLIP-26: Service Authorization (SSL Mutual Authentication) | 0 | 0 | 0 | Eron Wright | unknown | info | |||
| 25 | FLIP-25: Support User State TTL Natively | Flink | 1.6 | 0 | 0 | 0 | Bowen Li | completed | FLINK-3089 | info |
| 24 | FLIP-24: SQL Client | Flink | 1.5 | 0 | 0 | 0 | Timo Walther | completed | FLINK-7594 | info |
| 23 | FLIP-23 - Model Serving | 0 | 0 | 0 | Stavros Kontopoulos | under discussion | info | |||
| 22 | FLIP-22: Eager State Declaration | 0 | 0 | 0 | Tzu-Li (Gordon) Tai | under discussion | info | |||
| 21 | FLIP-21: Improve object Copying/Reuse Mode for Streaming Runtime | 0 | 0 | 0 | Stephan Ewen | in progress | FLINK-7828 | info | ||
| 20 | FLIP-20: Integration of SQL and CEP | Flink | 1.7 | 0 | 0 | 0 | Jark Wu | in progress | FLINK-6935 | info |
| 19 | FLIP-19: Improved BLOB storage architecture | Flink | 1.4 | 0 | 0 | 0 | Nico Kruber | unknown | info | |
| 18 | FLIP-18: Code Generation for improving sorting performance | 0 | 0 | 0 | Pattarawat Chormai | in progress | FLINK-5734 | info | ||
| 17 | FLIP-17: Side Inputs for DataStream API | 0 | 0 | 0 | Aljoscha Krettek | in progress | FLINK-6131 | info | ||
| 16 | FLIP-16: Loop Fault Tolerance | 0 | 0 | 0 | Paris Carbone | not accepted | FLINK-3257 | info | ||
| 15 | FLIP-15: Redesign Iterations (Scoping, Flow Control and Termination) | 0 | 0 | 0 | Paris Carbone | in progress | FLINK-5089 | info | ||
| 14 | FLIP-14: crossGroup Operator | 0 | 0 | 0 | Greg Hogan | unknown | FLINK-1267 | info | ||
| 13 | FLIP-13: Side Outputs in Flink | Flink | 1.3 | 0 | 0 | 0 | Chen Qin | completed | FLINK-4460 | info |
| 12 | FLIP-12: Asynchronous I/O Design and Implementation | Flink | 1.2 | 0 | 0 | 0 | david wang | completed | FLINK-4391 | info |
| 11 | FLIP-11: Table API Stream Aggregations | Flink | 1.3 | 0 | 0 | 0 | Timo Walther | completed | FLINK-4557 | info |
| 10 | FLIP-10: Unify Checkpoints and Savepoints | Flink | 1.2 | 0 | 0 | 0 | Ufuk Celebi | completed | FLINK-4484 | info |
| 9 | FLIP-9: Trigger DSL | 0 | 0 | 0 | Kostas Kloudas | unknown | info | |||
| 8 | FLIP-8: Rescalable Non-Partitioned State | Flink | 1.2 | 0 | 0 | 0 | Ufuk Celebi | completed | FLINK-4379 | info |
| 7 | FLIP-7: Expose metrics to WebInterface | Flink | 1.2 | 0 | 0 | 0 | Chesnay Schepler | completed | FLINK-4389 | info |
| 6 | FLIP-6: Flink Deployment and Process Model - Standalone, Yarn, Mesos, Kubernetes, etc. | Flink | 1.5 | 0 | 0 | 0 | Stephan Ewen | completed | FLINK-4319 | info |
| 5 | FLIP-5: Only send data to each taskmanager once for broadcasts | 0 | 0 | 0 | Felix Neutatz | not accepted | FLINK-4175 | info | ||
| 4 | FLIP-4: Enhance Window Evictor | Flink | 1.2 | 0 | 0 | 0 | vishnu viswanath | completed | FLINK-4174 | info |
| 3 | FLIP-3: Organization of Documentation | Flink | 1.2 | 0 | 0 | 0 | Stephan Ewen | completed | FLINK-4463 | info |
| 2 | FLIP-2: Extending Window Function Metadata | Flink | 1.3 | 0 | 0 | 0 | Aljoscha Krettek | completed | FLINK-4997 | info |
| 1 | FLIP-1: Fine Grained Recovery from Task Failures | Flink | 1.9 | 0 | 0 | 0 | Aljoscha Krettek | completed | FLINK-4256 | info |