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