Log in
Skip to sidebar
Skip to main content
Linked Applications
Loading…
Apache Software Foundation
Spaces
Hit enter to search
Help
Online Help
Keyboard Shortcuts
Feed Builder
What’s new
What’s new
Available Gadgets
About Confluence
Log in
Apache Flink
Page tree
Browse pages
Configure
Space tools
View Page
A
t
tachments (0)
Page History
Page Information
View in Hierarchy
View Source
Delete comments
Export to PDF
Export to Word
Copy Page Tree
Pages
Apache Flink Home
Flink Improvement Proposals
Page Information
Title:
Flink Improvement Proposals
Author:
Matthias J. Sax
Jul 08, 2016
Last Changed by:
Martijn Visser
May 01, 2024
Tiny Link:
(useful for email)
https://cwiki.apache.org/confluence/x/zwriAw
Export As:
Word
·
PDF
Incoming Links
Apache Flink (12)
Page:
Design Documents
Page:
FLIP-354: Removal of deprecated exception history fields in REST API
Page:
FLIP-323: Support Attached Execution on Flink Application Completion for Batch Jobs
Home page:
Apache Flink Home
Page:
FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement
Page:
FLIP-413: Enable unaligned checkpoints by default
Page:
FLIP-443: Interruptible timers firing
Page:
FLIP Template
Page:
FLIP Connector Template
Page:
FLIP-448: Add sub-task spans to TraceReporter for checkpointing
Page:
FLIP-444: Native file copy support
Page:
FLIP-446: Kubernetes Operator State Snapshot CRD
Paimon (1)
Page:
Paimon Improvement Proposals
DORIS (1)
Page:
Doris Improvement Proposals
Apache OpenNLP (1)
Page:
OpenNLP Improvement Proposals
Hierarchy
Parent Page
Home page:
Apache Flink Home
Children (454)
Page:
FLIP Template
Page:
FLIP Connector Template
Page:
FLIP-1: Fine Grained Recovery from Task Failures
Page:
FLIP-2: Extending Window Function Metadata
Page:
FLIP-3: Organization of Documentation
Page:
FLIP-4: Enhance Window Evictor
Page:
FLIP-5: Only send data to each taskmanager once for broadcasts
Page:
FLIP-6: Flink Deployment and Process Model - Standalone, Yarn, Mesos, Kubernetes, etc.
Page:
FLIP-7: Expose metrics to WebInterface
Page:
FLIP-8: Rescalable Non-Partitioned State
Show all...
Page:
FLIP-9: Trigger DSL
Page:
FLIP-10: Unify Checkpoints and Savepoints
Page:
FLIP-11: Table API Stream Aggregations
Page:
FLIP-12: Asynchronous I/O Design and Implementation
Page:
FLIP-13: Side Outputs in Flink
Page:
FLIP-14: crossGroup Operator
Page:
FLIP-15: Redesign Iterations (Scoping, Flow Control and Termination)
Page:
FLIP-16: Loop Fault Tolerance
Page:
FLIP-17: Side Inputs for DataStream API
Page:
FLIP-18: Code Generation for improving sorting performance
Page:
FLIP-19: Improved BLOB storage architecture
Page:
FLIP-20: Integration of SQL and CEP
Page:
FLIP-21: Improve object Copying/Reuse Mode for Streaming Runtime
Page:
FLIP-22: Eager State Declaration
Page:
FLIP-23 - Model Serving
Page:
FLIP-24: SQL Client
Page:
FLIP-25: Support User State TTL Natively
Page:
FLIP-26: Service Authorization (SSL Mutual Authentication)
Page:
FLIP-27: Refactor Source Interface
Page:
FLIP-28: Long-term goal of making flink-table Scala-free
Page:
FLIP-29: Support map/flatMap/aggregate/flatAggregate on TableAPI
Page:
FLIP-30: Unified Catalog APIs
Page:
FLIP-31: Pluggable Shuffle Service
Page:
FLIP-32: Restructure flink-table for future contributions
Page:
FLIP-33: Standardize Connector Metrics
Page:
FLIP-34: Terminate/Suspend Job with Savepoint
Page:
FLIP-35: Support Chinese Documents and Website
Page:
FLIP-36: Support Interactive Programming in Flink
Page:
FLIP-37: Rework of the Table API Type System
Page:
FLIP-38: Python Table API
Page:
FLIP-39: Flink ML pipeline and ML libs
Page:
FLIP-40: Flink Driver
Page:
FLIP-41: Unify Binary format for Keyed State
Page:
FLIP-42: Rework Flink Documentation
Page:
FLIP-43: State Processor API
Page:
FLIP-44: Support Local Aggregation in Flink
Page:
FLIP-45: Reinforce Job Stop Semantic
Page:
FLIP-46: Graceful Shutdown Handling by UDFs
Page:
FLIP-47: Checkpoints vs. Savepoints
Page:
FLIP-48: Pluggable Intermediate Result Storage
Page:
FLIP-49: Unified Memory Configuration for TaskExecutors
Page:
FLIP-50: Spill-able Heap Keyed State Backend
Page:
FLIP-51: Rework of the Expression Design
Page:
FLIP-52 : Remove legacy Program interface.
Page:
FLIP-53: Fine Grained Operator Resource Management
Page:
FLIP-54: Evolve ConfigOption and Configuration
Page:
FLIP-55: Introduction of a Table API Java Expression DSL
Page:
FLIP-56: Dynamic Slot Allocation
Page:
FLIP-57: Rework FunctionCatalog
Page:
FLIP-58: Flink Python User-Defined Stateless Function for Table
Page:
FLIP-59: Enable execution configuration from Configuration object
Page:
FLIP-60: Restructure the Table API & SQL documentation
Page:
FLIP-61: Simplify Flink's cluster level RestartStrategy configuration
Page:
FLIP-62: Set default restart delay for FixedDelay- and FailureRateRestartStrategy to 1s
Page:
FLIP-63: Rework table partition support
Page:
FLIP-64: Support for Temporary Objects in Table module
Page:
FLIP-66: Support Time Attribute in SQL DDL
Page:
FLIP-67: Cluster partitions lifecycle
Page:
FLIP-68: Extend Core Table System with Pluggable Modules
Page:
FLIP-69: Flink SQL DDL Enhancement
Page:
FLIP-70: Flink SQL Computed Column Design
Page:
FLIP-71: E2E View support in FLINK SQL
Page:
FLIP-72: Introduce Pulsar Connector
Page:
FLIP-73: Introducing Executors for job submission
Page:
FLIP-74: Flink JobClient API
Page:
FLIP-75: Flink Web UI Improvement Proposal
Page:
FLIP-76: Unaligned Checkpoints
Page:
FLIP-77: Introduce ConfigOptions with Data Types
Page:
FLIP-78: Flink Python UDF Environment and Dependency Management
Page:
FLIP-79: Function DDL Support
Page:
FLIP-65: New type inference for Table API UDFs
Page:
FLIP-80: Expression String Serializable and Deserializable
Page:
FLIP-81: Executor-related new ConfigOptions.
Page:
FLIP-82: Use real per-job mode for YARN per-job attached execution
Page:
FLIP-83: Flink End-to-end Performance Testing Framework
Page:
FLIP-84: Improve & Refactor API of TableEnvironment & Table
Page:
FLIP-85: Flink Application Mode
Page:
FLIP-86: Improve Connector Properties
Page:
FLIP-87: Primary key constraints in Table API
Page:
FLIP-88: PyFlink User-Defined Function Resource Management
Page:
FLIP-89: Improve usability of TableConfig
Page:
FLIP-90: Support SQL 2016-2017 JSON functions in Table API & SQL
Page:
FLIP-91: Support SQL Gateway
Page:
FLIP-92: Add N-Ary Stream Operator in Flink
Page:
FLIP-93: JDBC catalog and Postgres catalog
Page:
FLIP-94: Rework 2-phase commit abstractions
Page:
FLIP-95: New TableSource and TableSink interfaces
Page:
FLIP-96: Support Python ML Pipeline API
Page:
FLIP-97: Support Scalar Vectorized Python UDF in PyFlink
Page:
FLIP-98: Better Back Pressure Detection
Page:
FLIP-99: Make Max Exception Configurable
Page:
FLIP-100: Add Attempt Information
Page:
FLIP-101: Add Pending Slots Detail
Page:
FLIP-102: Add More Metrics to TaskManager
Page:
FLIP-103: Better TM/JM Log Display
Page:
FLIP-104: Add More Metrics to Jobmanager
Page:
FLIP-105: Support to Interpret Changelog in Flink SQL (Introducing Debezium and Canal Format)
Page:
FLIP-106: Support Python UDF in SQL Function DDL
Page:
FLIP-107: Handling of metadata in SQL connectors
Page:
FLIP-108: Add GPU support in Flink
Page:
FLIP-109: Improve Hive dependencies out-of-box experience
Page:
FLIP-110: Support LIKE clause in CREATE TABLE
Page:
FLIP-111: Docker image unification
Page:
FLIP-112: Support User-Defined Metrics in Python UDF
Page:
FLIP-113: Supports Dynamic Table Options for Flink SQL
Page:
FLIP-114: Support Python UDF in SQL Client
Page:
FLIP-115: Filesystem connector in Table
Page:
FLIP-116: Unified Memory Configuration for Job Managers
Page:
FLIP-117: HBase catalog
Page:
FLIP-118: Improve Flink’s ID system
Page:
FLIP-119: Pipelined Region Scheduling
Page:
FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame
Page:
FLIP-121: Support Cython Optimizing Python User Defined Function
Page:
FLIP-122: New Connector Property Keys for New Factory
Page:
FLIP-123: DDL and DML compatibility for Hive connector
Page:
FLIP-124: Add open/close and Collector to (De)SerializationSchema
Page:
FLIP-125: Confluent Schema Registry Catalog
Page:
FLIP-126: Unify (and separate) Watermark Assigners
Page:
FLIP-127: Support Elasticsearch Source Connector
Page:
FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers
Page:
FLIP-129: Refactor Descriptor API to register connectors in Table API
Page:
FLIP-130: Support Python DataStream API (Stateless part)
Page:
FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API)
Page:
FLIP-132: Temporal Table DDL and Temporal Table Join
Page:
FLIP-133: Rework PyFlink Documentation
Page:
FLIP-134: Batch execution for the DataStream API
Page:
FLIP-135: Approximate Task-Local Recovery
Page:
FLIP-136: Improve interoperability between DataStream and Table API
Page:
FLIP-137: Support Pandas UDAF in PyFlink
Page:
FLIP-138: Declarative Resource management
Page:
FLIP-139: General Python User-Defined Aggregate Function Support on Table API
Page:
FLIP-140: Introduce batch-style execution for bounded keyed streams
Page:
FLIP-141: Intra-Slot Managed Memory Sharing
Page:
FLIP-142: Disentangle StateBackends from Checkpointing
Page:
FLIP-143: Unified Sink API
Page:
FLIP-144: Native Kubernetes HA for Flink
Page:
FLIP-145: Support SQL windowing table-valued function
Page:
FLIP-146: Improve new TableSource and TableSink interfaces
Page:
FLIP-147: Support Checkpoints After Tasks Finished
Page:
FLIP-148: Introduce Sort-Based Blocking Shuffle to Flink
Page:
FLIP-149: Introduce the upsert-kafka Connector
Page:
FLIP-150: Introduce Hybrid Source
Page:
FLIP-151: Incremental snapshots for heap-based state backend
Page:
FLIP-152: Hive Query Syntax Compatibility
Page:
FLIP-153: Support state access in Python DataStream API
Page:
FLIP-154: SQL Implicit Type Coercion
Page:
FLIP-155: Introduce a few convenient operations in Table API
Page:
FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements
Page:
FLIP-157: Migrate Flink Documentation from Jekyll to Hugo
Page:
FLIP-158: Generalized incremental checkpoints
Page:
FLIP-159: Reactive Mode
Page:
FLIP-160: Adaptive Scheduler
Page:
FLIP-161: Configuration through envrionment variables
Page:
FLIP-162: Consistent Flink SQL time function behavior
Page:
FLIP-163: SQL Client Improvements
Page:
FLIP-164: Improve Schema Handling in Catalogs
Page:
FLIP-165: Operator's Flame Graphs
Page:
FLIP-166: Pinot Connector
Page:
FLIP-167: Watermarks for Sink API
Page:
FLIP-168: Speculative Execution for Batch Job
Page:
FLIP-169: DataStream API for Fine-Grained Resource Requirements
Page:
FLIP-170: Adding Checkpoint Rejection Mechanism
Page:
FLIP-171: Async Sink
Page:
FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer
Page:
FLIP-173: Support DAG of algorithms (Flink ML)
Page:
FLIP-174: Improve the WithParam interface (Flink ML)
Page:
FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator (Flink ML)
Page:
FLIP-176: Unified Iteration to Support Algorithms (Flink ML)
Page:
FLIP-181: Custom netty HTTP request inbound/outbound handlers
Page:
FLIP-177: Extend Sink API
Page:
FLIP-178 Support Advanced Function DDL
Page:
FLIP-179: Expose Standardized Operator Metrics
Page:
FLIP-180: Adjust StreamStatus and Idleness definition
Page:
FLIP-183: Dynamic buffer size adjustment
Page:
FLIP-182: Support watermark alignment of FLIP-27 Sources
Page:
FLIP-184: Refine ShuffleMaster lifecycle management for pluggable shuffle service framework
Page:
FLIP-185: Shorter heartbeat timeout and interval default values
Page:
FLIP-186: Refactor DataStreamUtils#reinterpretAsKeyedStream
Page:
FLIP-187: Adaptive Batch Scheduler
Page:
FLIP-188: Introduce Built-in Dynamic Table Storage
Page:
FLIP-189: SQL Client Usability Improvements
Page:
FLIP-190: Support Version Upgrades for Table API & SQL Programs
Page:
FLIP-191: Extend unified Sink interface to support small file compaction
Page:
FLIP-192: Support withBroadcast in DataStream (FlinkML)
Page:
FLIP-193: Snapshots ownership
Page:
FLIP-194: Introduce the JobResultStore
Page:
FLIP-195: Improve the name and structure of vertex and operator name for job
Page:
FLIP-196: Source API stability guarantees
Page:
FLIP-197: API stability graduation process
Page:
FLIP-198: Working directory for Flink processes
Page:
FLIP-199: Change some default config values of blocking shuffle for better usability
Page:
FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)
Page:
FLIP-201: Persist local state in working directory
Page:
[DRAFT] FLIP-202: Introduce ClickHouse Connector
Page:
FLIP-203: Incremental savepoints
Page:
FLIP-204: Introduce Hash Lookup Join
Page:
FLIP-205: Support Cache in DataStream for Batch Processing
Page:
FLIP-206: Support PyFlink Runtime Execution in Thread Mode
Page:
FLIP-207: Flink backward and forward compatibility
Page:
FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records
Page:
FLIP-209: Support to run multiple shuffle plugins in one session cluster
Page:
FLIP-210: Change logging level dynamically at runtime
Page:
FLIP-211: Kerberos delegation token framework
Page:
FLIP-212: Introduce Flink Kubernetes Operator
Page:
FLIP-213: TaskManager's Flame Graphs
Page:
FLIP-214: Support Advanced Function DDL
Page:
FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator
Page:
FLIP-216: Introduce pluggable dialect and plan for migrating Hive dialect
Page:
FLIP-217: Support watermark alignment of source splits
Page:
FLIP-218: Support SELECT clause in CREATE TABLE(CTAS)
Page:
FLIP-219: Revised Format API
Page:
FLIP-220: Binary Sorted State
Page:
FLIP-221: Abstraction for lookup source cache and metric
Page:
FLIP-222: Support full job lifecycle statements in SQL client
Page:
FLIP-223: Support HiveServer2 Endpoint
Page:
FLIP-224: Blocklist Mechanism
Page:
FLIP-225: Implement standalone mode support in the kubernetes operator
Page:
FLIP-226: Introduce Schema Evolution on Table Store
Page:
FLIP-227: Support overdraft buffer
Page:
FLIP-228: Support Within between events in CEP Pattern
Page:
FLIP-229: Introduces Join Hint for Flink SQL Batch Job
Page:
FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors
Page:
FLIP-232: Add Retry Support For Async I/O In DataStream API
Page:
FLIP-233: Introduce HTTP Connector
Page:
FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems
Page:
FLIP-235: Hybrid Shuffle Mode
Page:
FLIP-236: Asynchronous Job Submission
Page:
FLIP-237: Thrift Format Support
Page:
FLIP-238: Introduce FLIP-27-based Data Generator Source
Page:
FLIP-239: Port JDBC Connector to FLIP-27&FLIP-143
Page:
FLIP-240: Introduce "ANALYZE TABLE" Syntax
Page:
FLIP-241: Completed Jobs Information Enhancement
Page:
FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink
Page:
FLIP-243: Dedicated Opensearch connectors
Page:
FLIP-244: Support IterativeCondition with AggregateFunction in CEP Pattern
Page:
FLIP-245: Source Supports Speculative Execution For Batch Job
Page:
FLIP-246: Dynamic Kafka Source (originally Multi Cluster Kafka Source)
Page:
FLIP-247: Bulk fetch of table and column statistics for given partitions
Page:
FLIP-248: Introduce dynamic partition pruning
Page:
FLIP-249: Flink Web UI Enhancement for Speculative Execution
Page:
FLIP-250: Support Customized Kubernetes Schedulers Proposal
Page:
FLIP-251: Support collecting arbitrary number of streams
Page:
FLIP-252: Amazon DynamoDB Sink Connector
Page:
FLIP-254: Redis Streams Connector
Page:
FLIP-255: Introduce pre-aggregated merge to Table Store
Page:
FLIP-256: Support Job Dynamic Parameter With Flink Rest Api
Page:
FLIP-257: Flink JobManager Process Split
Page:
FLIP-258: Guarantee binary compatibility for Public/-Evolving APIs between patch releases
Page:
FLIP-259: Use StatefulSet instead of Deployment to deploy Flink with standalone mode on kubernetes
Page:
FLIP-260: Expose Finish Method For TableFunction
Page:
FLIP-261: Support DEFAULT Constraint In Sql DDL
Page:
FLIP-262: Introduce MongoDB connector
Page:
FLIP-263: Improve resolving schema compatibility
Page:
FLIP-264: Extract CoordinatorContextBase
Page:
FLIP-265 Deprecate and remove Scala API support
Page:
FLIP-266: Simplify network memory configurations for TaskManager
Page:
FLIP 267: Iceberg Connector
Page:
FLIP-268: Kafka Rack Awareness
Page:
FLIP-269: Properly Handling the Processing Timers on Job Termination
Page:
FLIP-270: Repeatable Cleanup of Checkpoints
Page:
FLIP-271: Autoscaling
Page:
FLIP-272: Generalized delegation token support
Page:
FLIP-273: Improve the Catalog API to Support ALTER TABLE syntax
Page:
FLIP-274: Introduce metric group for OperatorCoordinator
Page:
FLIP-275: Support Remote SQL Client Based on SQL Gateway
Page:
FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store
Page:
FLIP-277: Native GlueCatalog Support in Flink
Page:
FLIP-278: HybridSource Table & Sql Api Implementation
Page:
FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode
Page:
FLIP-280: Introduce EXPLAIN PLAN_ADVICE to provide SQL advice
Page:
FLIP-281 Sink Supports Speculative Execution For Batch Job
Page:
FLIP-282: Introduce Delete & Update API
Page:
FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs
Page:
FLIP-284 : Making AsyncSinkWriter Flush triggers adjustable
Page:
FLIP-285: Refactoring LeaderElection to make Flink support multi-component leader election out-of-the-box
Page:
FLIP-286: Fix the API stability/scope annotation inconsistency in AbstractStreamOperator
Page:
FLIP-287: Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID
Page:
FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
Page:
FLIP-289: Support online inference (Flink ML)
Page:
FLIP-290 Operator state compression
Page:
FLIP-291: Externalized Declarative Resource Management
Page:
FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration
Page:
FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway
Page:
FLIP-294: Support Customized Catalog Modification Listener
Page:
FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations
Page:
FLIP-296: Extend watermark-related features for SQL
Page:
FLIP-297: Improve Auxiliary Sql Statements
Page:
FLIP-298: Unifying the Implementation of SlotManager
Page:
FLIP-299: Pub/Sub Lite Connector
Page:
FLIP-300: Add targetColumns to DynamicTableSink#Context to solve the null overwrite problem of partial-insert
Page:
FLIP-301: Hybrid Shuffle supports Remote Storage
Page:
FLIP-302: Support TRUNCATE TABLE statement in batch mode
Page:
FLIP-303: Support REPLACE TABLE AS SELECT statement
Page:
FLIP-304: Pluggable Failure Enrichers
Page:
FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement
Page:
FLIP-306: Unified File Merging Mechanism for Checkpoints
Page:
FLIP-307: Flink Connector Redshift
Page:
FLIP-308: Support Time Travel
Page:
FLIP-309: Support using larger checkpointing interval when source is processing backlog
Page:
[WIP]FLIP-310:use VARINT and ZIGZAG to encode ROWDATA in state
Page:
FLIP-311: Support Call Stored Procedure
Page:
FLIP 312: Add Yarn ACLs to Flink Containers
Page:
FLIP-312: Prometheus Sink Connector
Page:
FLIP-313: Add support of User Defined AsyncTableFunction
Page:
FLIP-314: Support Customized Job Lineage Listener
Page:
FLIP-315 Support Operator Fusion Codegen for Flink SQL
Page:
FLIP-316: Support application mode for SQL Gateway
Page:
FLIP-317: Upgrade Kryo from 2.24.0 to 5.5.0
Page:
FLIP-318: Support Dynamic Options Provider For Tables In Gateway
Page:
FLIP-319: Integrate with Kafka's Support for Proper 2PC Participation (KIP-939)
Page:
FLIP-320: Support multiple Flink versions in each Java library release (Flink ML)
Page:
FLIP-321: Introduce an API deprecation process
Page:
FLIP-322 Cooldown period for adaptive scheduler
Page:
FLIP-323: Support Attached Execution on Flink Application Completion for Batch Jobs
Page:
FLIP-324: Introduce Runtime Filter for Flink Batch Jobs
Page:
FLIP-326: Enhance Watermark to Support Processing-Time Temporal Join
Page:
FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data
Page:
FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag
Page:
FLIP-329: Add operator attribute to specify support for object-reuse
Page:
FLIP-330: Support specifying record timestamp requirement
Page:
FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment
Page:
[WIP]FLIP-332: Introduce the concept of state self-sustained
Page:
FLIP-333: Redesign Apache Flink website
Page:
FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler
Page:
FLIP-335: Removing Flink's Time classes
Page:
FLIP-336: Remove "now" timestamp field from REST responses
Page:
FLIP-337: Remove JarRequestBody#programArgs
Page:
FLIP-338: Remove terminationMode query parameter from job cancellation REST endpoint
Page:
FLIP-339: Adaptive Channel selection for partitioner
Page:
FLIP-340: Remove rescale REST endpoint
Page:
FLIP-341: Remove MetricGroup methods accepting an int as a name
Page:
FLIP-342: Remove brackets around keys returned by MetricGroup#getAllVariables
Page:
FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()
Page:
FLIP-344: Remove parameter in RichFunction#open
Page:
FLIP-345: Add support for dynamic time window function
Page:
FLIP-346: Deprecate ManagedTable related APIs
Page:
FLIP-347: Remove IOReadableWritable serialization in Path
Page:
FLIP-348: Make expanding behavior of virtual metadata columns configurable
Page:
FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package
Page:
FLIP-350: Remove query parameters from Jar handlers
Page:
FLIP-351: REST API normalizes +/-Inf / NaN to 0
Page:
FLIP-352: Use camelCast for all REST API fields/parameters
Page:
FLIP-354: Removal of deprecated exception history fields in REST API
Page:
FLIP 355: Add parent dir of files to classpath using yarn.provided.lib.dirs
Page:
FLIP-356: Support Nested Fields Filter Pushdown
Page:
FLIP-357: Deprecate Iteration API of DataStream
Page:
FLIP-358: flink-avro enhancement and cleanup
Page:
FLIP-359: ignore-unclaimed-state supports the state inside of operator
Page:
FLIP-360: Merging the ExecutionGraphInfoStore and the JobResultStore into a single component CompletedJobStore
Page:
FLIP-361: Improve GC Metrics
Page:
FLIP-362: Support minimum resource limitation
Page:
FLIP-363: Unify the Representation of TaskManager Location in REST API and Web UI
Page:
FLIP-364: Improve the exponential-delay restart-strategy
Page:
FLIP-365: Introduce flush interval to adjust the interval of emitting results with idempotent semantics
Page:
FLIP-366: Support standard YAML for FLINK configuration
Page:
FLIP-367: Support Setting Parallelism for Table/SQL Sources
Page:
FLIP-368: Reorganize the exceptions thrown in state interfaces
Page:
FLIP-369: Introduce LRU cache to accelerate state backend access
Page:
FLIP-370: Support Balanced Tasks Scheduling
Page:
FLIP-371: Provide initialization context for Committer creation in TwoPhaseCommittingSink
Page:
FLIP-372: Enhance and synchronize Sink API to match the Source API
Page:
FLIP-373: Support Configuring Different State TTLs using SQL Hint
Page:
FLIP-374: Adding a separate configuration for specifying Java Options of the SQL Gateway
Page:
FLIP-375: Built-in cross-platform powerful java profiler
Page:
FLIP-376: Add DISTRIBUTED BY clause
Page:
FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources
Page:
FLIP-378: Support Avro timestamp with local timezone
Page:
FLIP-379: Dynamic source parallelism inference for batch jobs
Page:
FLIP-380: Support Full Partition Processing On Non-keyed DataStream
Page:
FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects
Page:
FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs
Page:
FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs
Page:
FLIP-384: Introduce TraceReporter and use it to create checkpointing and recovery traces
Page:
FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter
Page:
FLIP-386: Support adding custom metrics in Recovery Spans
Page:
FLIP-387: Support named parameters for functions and call procedures
Page:
FLIP-388: Support Dynamic Logger Level Adjustment
Page:
FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving.
Page:
FLIP-390: Support System out and err to be redirected to LOG or discarded
Page:
FLIP-391: Deprecate RuntimeContext#getExecutionConfig
Page:
FLIP-392: Deprecate the Legacy Group Window Aggregation
Page:
FLIP-393: Make QueryOperations SQL serializable
Page:
[WIP] FLIP-394: Add Metrics for Connector Agnostic Autoscaling
Page:
FLIP-395: Deprecate Global Aggregator Manager
Page:
FLIP-396: Trial to test GitHub Actions as an alternative for Flink's current Azure CI infrastructure
Page:
FLIP-397: Add config options for administrator JVM options
Page:
FLIP-398: Improve Serialization Configuration And Usage In Flink
Page:
FLIP-399: Flink Connector Doris
Page:
FLIP-400: AsyncScalarFunction for asynchronous scalar function support
Page:
FLIP-401: REST API JSON response deserialization unknown field tolerance
Page:
FLIP-402: Extend ZooKeeper Curator configurations
Page:
FLIP-403 High Availability Services for OLAP Scenarios
Page:
FLIP-404: Create a Redis HyperLogLog Connector for Flink
Page:
FLIP-405: Migrate string configuration key to ConfigOption
Page:
FLIP-406: Reorganize State & Checkpointing & Recovery Configuration
Page:
FLIP-407: Improve Flink Client performance in interactive scenarios
Page:
FLIP-408: [Umbrella] Introduce DataStream API V2
Page:
FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction
Page:
FLIP-410: Config, Context and Processing Timer Service of DataStream API V2
Page:
FLIP-411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change
Page:
FLIP-412: Add the time-consuming span of each stage when starting the Flink job to TraceReporter
Page:
FLIP-413: Enable unaligned checkpoints by default
Page:
FLIP-414: Support Retry Mechanism in RocksDBStateDataTransfer
Page:
FLIP-415: Introduce a new join operator to support minibatch
Page:
FLIP-416: Deprecate and remove the RestoreMode#LEGACY
Page:
FLIP-417: Expose JobManagerOperatorMetrics via REST API
Page:
FLIP-418: Show data skew score on Flink Dashboard
Page:
FLIP-419: Optimize multi-sink query plan generation
Page:
FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes
Page:
FLIP-421: Support Custom Conversion for LogicalTypes
Page:
[WIP] FLIP-422: Add option to control the default partitioner when the parallelism of upstream and downstream operator does not match
Page:
FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Page:
FLIP-424: Asynchronous State APIs
Page:
FLIP-425: Asynchronous Execution Model
Page:
FLIP-426: Grouping Remote State Access
Page:
FLIP-427: ForSt - Disaggregated state Store
Page:
FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State
Page:
[WIP]FLIP-429: Local Disk as a Secondary Cache for Disaggregated State
Page:
[WIP]FLIP-430: Remote Compaction For Disaggregated State
Page:
[WIP]FLIP-431: Metrics For Disaggregated State
Page:
[WIP]FLIP-432: TM State Ownership for Disaggregated State & Faster Checkpoint or Recovery
Page:
FLIP-433: State Access on DataStream API V2
Page:
FLIP-434: Support optimizations for pre-partitioned data sources
Page:
FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines
Page:
FLIP-436: Introduce Catalog-related Syntax
Page:
FLIP-437: Support ML Models in Flink SQL
Page:
FLIP-438: Amazon SQS Sink Connector
Page:
FLIP-439: Externalize Kudu Connector from Bahir
Page:
[WIP] FLIP-440: User-defined Polymorphic Table Functions
Page:
FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI
Page:
FLIP-442: General Improvement to Configuration for Flink 2.0
Page:
FLIP-443: Interruptible timers firing
Page:
FLIP-444: Native file copy support
Page:
FLIP-445: Support dynamic parallelism inference for HiveSource
Page:
FLIP-446: Kubernetes Operator State Snapshot CRD
Page:
FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
Page:
FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table
Page:
FLIP-448: Add sub-task spans to TraceReporter for checkpointing
Page:
FLIP-449: Reorganization of flink-connector-jdbc
Page:
FLIP-450: Improve Runtime Configuration for Flink 2.0
Page:
FLIP-451: Introduce timeout configuration to AsyncSink API
Page:
FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Page:
FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Page:
FLIP-454: New Apicurio Avro format
Hide...
Labels
There are no labels assigned to this page.
Recent Changes
Time
Editor
May 01, 2024 15:28
Martijn Visser
View Changes
May 01, 2024 15:13
Martijn Visser
View Changes
Apr 25, 2024 06:30
Xuannan Su
View Changes
Apr 24, 2024 11:37
João Boto
View Changes
Apr 24, 2024 08:02
Piotr Nowojski
View Page History
Outgoing Links
External Links (4)
https://cwiki.apache.org/confluence/display/FLINK/Flink+Imp…
https://cwiki.apache.org/confluence/display/FLINK/Flink+Imp…
https://www.apache.org/foundation/voting.html#Veto
https://cwiki.apache.org/confluence/display/FLINK/Flink+Byl…
Overview
Content Tools
Apps
{"serverDuration": 411, "requestCorrelationId": "9c9d147284a8dafb"}