dev

Messages by Date

2026/10/13 [jira] [Created] (FLINK-40987) Allow overriding or disabling a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
2026/10/13 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
2026/10/13 Re: Help with Confluence account creation Sumin Joo
2026/10/13 [REMINDER] Flink 2.4 feature freeze planned for 20 October Sumin Joo
2026/10/13 [jira] [Created] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Biao Geng (Jira)
2026/10/13 [jira] [Created] (FLINK-40985) [Iceberg] Support per-table location override in Iceberg pipeline sink VISHAL B (Jira)
2026/10/13 Re: [DISCUSS][FLINK-40574] Upgrade SLF4J from 1.7 to 2.x Martijn Visser
2026/10/13 [jira] [Created] (FLINK-40984) Port the batch aggregate ITCases in flink-table-planner to Java Martijn Visser (Jira)
2026/10/13 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Hang Ruan
2026/10/12 [jira] [Created] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Rango (Jira)
2026/10/12 [jira] [Created] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed Xiaobing Fang (Jira)
2026/10/12 [jira] [Created] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks Martijn Visser (Jira)
2026/10/12 [jira] [Created] (FLINK-40978) Cast from VARIANT through FromVariantConverter Ramin Gharib (Jira)
2026/10/12 [jira] [Created] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results Hanyu Zheng (Jira)
2026/10/12 [jira] [Created] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
2026/10/12 Re: [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Fabian Hueske
2026/10/12 [jira] [Created] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery Xiaobing Fang (Jira)
2026/10/12 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
2026/10/12 [jira] [Created] (FLINK-40974) HadoopIOFormatsITCase#testJobWithObjectReuse runs without object reuse Martijn Visser (Jira)
2026/10/12 [jira] [Created] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation Martijn Visser (Jira)
2026/10/12 [jira] [Created] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize Martijn Visser (Jira)
2026/10/12 [jira] [Created] (FLINK-40980) JsonRowDataSerDeSchemaTest array tests don't cover the JsonParser deserializer Martijn Visser (Jira)
2026/10/12 Re: [DISCUSS] FLIP-613 : Remote Artifact Fetch for Session-Mode Job Submission Dale Lane via dev
2026/10/12 [jira] [Created] (FLINK-40976) JoinToMultiJoinForReorderRule applies a post-join filter twice when merging joins for reorder Hanyu Zheng (Jira)
2026/10/12 [jira] [Created] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes Sergey Nuyanzin (Jira)
2026/10/12 Re:[DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
2026/10/12 [jira] [Created] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases Martijn Visser (Jira)
2026/10/12 Re: Help with Confluence account creation Rui Fan
2026/10/12 [jira] [Created] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history Hao Yu (Jira)
2026/10/12 Help with Confluence account creation Sumin Joo
2026/10/12 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Yanquan Lv
2026/10/11 Re: [DISCUSS] FLIP-613 : Remote Artifact Fetch for Session-Mode Job Submission Krishna Sai
2026/10/11 [SUMMARY] Flink 2.4 Release Sync - 09.10.26 Sumin Joo
2026/10/11 [DISCUSS] FLIP-613 : Remote Artifact Fetch for Session-Mode Job Submission Dale Lane via dev
2026/10/11 Re: [DISCUSS] Flink Community Skills Krishna Sai
2026/10/11 Re: [DISCUSS] Flink Community Skills Purushottam Sinha
2026/10/10 [DISCUSS] Flink Community Skills Rui Fan
2026/10/10 Re: [ANNOUNCE] Apache Flink CDC 3.7.0 released Yanquan Lv
2026/10/10 [ANNOUNCE] Apache Flink CDC 3.7.0 released Xiqian YU
2026/10/10 [RESULT][VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Xiqian YU
2026/10/10 [DISCUSS] Apache Flink 1.20.6 release Rui Fan
2026/10/10 [DISCUSS] Apache Flink 2.2.2 release Rui Fan
2026/10/10 [DISCUSS] Apache Flink 2.3.1 release Rui Fan
2026/10/10 Re: [ANNOUNCE] Apache Flink CDC 3.7.0 released Leonard Xu
2026/10/10 [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Yunfeng Zhou
2026/10/09 Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Lincoln Lee
2026/10/09 Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Xiqian YU
2026/10/09 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo via dev
2026/10/09 [jira] [Created] (FLINK-40968) Accept map() as op_mapping in Table API toChangelog() and fromChangelog() Timo Theusner (Jira)
2026/10/09 [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
2026/10/09 Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Spoorthi Basu
2026/10/09 [jira] [Created] (FLINK-40967) Restore test files of OVER_AGGREGATE_TIME_BOUNDED_NON_PARTITIONED_ROWS_WITH_OUT_OF_ORDER_RECORDS cannot be regenerated Martijn Visser (Jira)
2026/10/09 A New Flink Native Engine StreamFusion Based On DataFusion Jacky Lau
2026/10/08 [jira] [Created] (FLINK-40966) Reuse Fluss metadata clients across schema operations Xiaobing Fang (Jira)
2026/10/08 Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Hang Ruan
2026/10/08 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
2026/10/08 [jira] [Created] (FLINK-40965) Treat IF as conditional function in code gen Sergey Nuyanzin (Jira)
2026/10/08 [jira] [Created] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Sumaiya Azad (Jira)
2026/10/08 [jira] [Created] (FLINK-40963) Add support for DATE and TIME conversion to JSON Saketh Kurnool (Jira)
2026/10/08 [jira] [Created] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode Saketh Kurnool (Jira)
2026/10/08 [jira] [Created] (FLINK-40956) Fall back to stateless delete when savepoint on deletion keeps failing Gyula Fora (Jira)
2026/10/08 Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Peter Huang
2026/10/08 [jira] [Created] (FLINK-40961) Support NOTIFY_STATEFUL_SETS Timo Walther (Jira)
2026/10/08 [jira] [Created] (FLINK-40960) [JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module Yuepeng Pan (Jira)
2026/10/08 Re: [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Timo Walther
2026/10/08 [jira] [Created] (FLINK-40959) Batch sort can emit unsorted rows if comparator implementation is long enough to be split Mate Czagany (Jira)
2026/10/08 Re: [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Gustavo de Morais
2026/10/08 [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Vas Shabu
2026/10/08 Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Yanquan Lv
2026/10/08 [jira] [Created] (FLINK-40958) VARIANT might fail with StackOverflow Sergey Nuyanzin (Jira)
2026/10/08 Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Yanquan Lv
2026/10/08 [jira] [Created] (FLINK-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials luana (Jira)
2026/10/08 [jira] [Created] (FLINK-40955) Give up and remove finalizer after cleanup keeps failing with a timeout Gyula Fora (Jira)
2026/10/08 [jira] [Created] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout Gyula Fora (Jira)
2026/10/08 [jira] [Created] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory Gabor Somogyi (Jira)
2026/10/08 [jira] [Created] (FLINK-40952) ForSt: rescale restore never closes the temporary DB's DBOptions copy, leaking the slot-shared block cache Yordan Pavlov (Jira)
2026/10/07 [jira] [Created] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs peiyu (Jira)
2026/10/07 Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Zhanghao Chen
2026/10/07 Re: [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Dian Fu
2026/10/07 Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Leonard Xu
2026/10/07 [jira] [Created] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output Martijn Visser (Jira)
2026/10/07 [jira] [Created] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." Martijn Visser (Jira)
2026/10/07 [jira] [Created] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join Martijn Visser (Jira)
2026/10/07 [jira] [Created] (FLINK-40947) ROLLUP / CUBE / GROUPING SETS with () return no grand-total row on an empty input Yaoxuan Wu (Jira)
2026/10/07 [jira] [Created] (FLINK-40946) SUM / AVG on DECIMAL(38, s) over a join are rounded to scale 6 Yaoxuan Wu (Jira)
2026/10/07 [jira] [Created] (FLINK-40945) -0.0 and 0.0 are different keys in GROUP BY, DISTINCT, UNION and hash joins Yaoxuan Wu (Jira)
2026/10/07 [jira] [Created] (FLINK-40936) Built-in functions compare VARIANT array elements and map keys by their binary encoding Ramin Gharib (Jira)
2026/10/07 [jira] [Created] (FLINK-40944) CPU limit-factor inflates the JVM's availableProcessors() to the CPU limit Jira
2026/10/07 [DISCUSS] config providers for Flink? Dale Lane via dev
2026/10/07 [jira] [Created] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column Sergey Nuyanzin (Jira)
2026/10/07 [jira] [Created] (FLINK-40941) Add warmup for janino Sergey Nuyanzin (Jira)
2026/10/07 [jira] [Created] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1) Jira
2026/10/07 [jira] [Created] (FLINK-40942) NativeS3FileSystem#getFileStatus fails with "Key cannot be empty" for bucket-root paths Jira
2026/10/07 [jira] [Created] (FLINK-40940) HTTP lookup source drops the row for a failed call with continue-on-error unless the planner calls applyReadableMetadata Arvid Heise (Jira)
2026/10/07 [jira] [Created] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
2026/10/07 [jira] [Created] (FLINK-40938) Support AT_TIMESTAMP feature in DynamDB Streams connector Abhi Gupta (Jira)
2026/10/07 [jira] [Created] (FLINK-40939) TRY_RESOLVE accepts non-deterministic join keys and join conditions on updating inputs with a unique key Gustavo de Morais (Jira)
2026/10/06 [jira] [Created] (FLINK-40935) VAR_SAMP / STDDEV_SAMP return -1 for a group with a single row Yaoxuan Wu (Jira)
2026/10/06 [jira] [Created] (FLINK-40934) Table API row() fails when AS aliases produce duplicate field names Ramin Gharib (Jira)
2026/10/06 [jira] [Created] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yaoxuan Wu (Jira)
2026/10/06 [jira] [Created] (FLINK-40932) Arm state schema evolution for ListState and MapState of RowData Weiqing Yang (Jira)
2026/10/06 [jira] [Created] (FLINK-40929) SUM on DECIMAL silently returns a wrong, order-dependent value after an overflow Yaoxuan Wu (Jira)
2026/10/06 [jira] [Created] (FLINK-40930) MIN/MAX on FLOAT/DOUBLE return NaN only if NaN is the first input row (order-dependent result) Yaoxuan Wu (Jira)
2026/10/06 [jira] [Created] (FLINK-40928) DISTINCT over a cross join with an IS NULL filter returns rows with NULL that are not in the input Yaoxuan Wu (Jira)
2026/10/06 [jira] [Created] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime Yahya Kisana (Jira)
2026/10/06 Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Peter Huang
2026/10/06 Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source David Radley
2026/10/06 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava via dev
2026/10/06 [jira] [Created] (FLINK-40926) Projection push down records a ReadingMetadata ability without metadata keys Arvid Heise (Jira)
2026/10/06 Re: [DISCUSS] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Vas Shabu
2026/10/06 [jira] [Created] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently Sergey Nuyanzin (Jira)
2026/10/06 [jira] [Created] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check sepuri sai krishna (Jira)
2026/10/05 [jira] [Created] (FLINK-40923) `a >= b` on DOUBLE NaN keeps the row in one query but drops it when the input is first written to a table (reflexive comparison simplified to TRUE) Yaoxuan Wu (Jira)
2026/10/05 [jira] [Created] (FLINK-40922) DISTINCT over GROUP BY ROLLUP returns duplicate rows Yaoxuan Wu (Jira)
2026/10/05 [jira] [Created] (FLINK-40921) Invoke statebackend's close() and dispose() in right order Zakelly Lan (Jira)
2026/10/05 [jira] [Created] (FLINK-40920) SELECT 1 / (2 + 3) fails with ClassCastException: RexCall cannot be cast to RexLiteral in ExpressionReducer Yaoxuan Wu (Jira)
2026/10/05 [jira] [Created] (FLINK-40919) AVG on INT returns wrong result when the planner rewrites it into SUM/COUNT (INT sum overflows) Yaoxuan Wu (Jira)
2026/10/05 [jira] [Created] (FLINK-40918) SIGTERM during application-mode HA recovery permanently fails the suspended jobs of a PyFlink application Ian Stewart (Jira)
2026/10/05 [DISCUSS] Maintenance status and plans for several Flink repositories Aleksandr Savonin
2026/10/05 Re: [DISCUSS] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Mate Czagany
2026/10/05 [jira] [Created] (FLINK-40917) Deeply nested VARIANT values overflow the stack in toJson(), CAST to STRING and the variant builder Ramin Gharib (Jira)
2026/10/05 [jira] [Created] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations Isaac Montenegro Jimenez (Jira)
2026/10/05 [jira] [Created] (FLINK-40915) Relax non-deterministic join-condition check for LATERAL SNAPSHOT join Fabian Hueske (Jira)
2026/10/05 [jira] [Created] (FLINK-40914) Support partial updates on LATERAL SNAPSHOT join build side Fabian Hueske (Jira)
2026/10/05 [jira] [Created] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race Efrat Levitan (Jira)
2026/10/05 [jira] [Created] (FLINK-40912) ExactlyOnceKafkaWriter never closes the AdminClient it creates for the listing abort strategy Aleksandr Savonin (Jira)
2026/10/05 [jira] [Created] (FLINK-40911) Variant builder mishandles a nested variant and a value of exactly 16 MiB Ramin Gharib (Jira)
2026/10/05 [jira] [Created] (FLINK-40910) Reject VARIANT where SQL needs equality. Byte comparison gives wrong results in GROUP BY, DISTINCT, joins and = Ramin Gharib (Jira)
2026/10/05 [jira] [Created] (FLINK-40909) Support filter push down for element access on ARRAY, MAP and VARIANT (ITEM) Arvid Heise (Jira)
2026/10/05 [jira] [Created] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0> Martijn Visser (Jira)
2026/10/05 [jira] [Created] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn Martijn Visser (Jira)
2026/10/05 [jira] [Created] (FLINK-40906) DataFrameWindowITTests.test_hop_window_aggregation fails with a DispatcherGateway.submitJob timeout Martijn Visser (Jira)
2026/10/04 Re: [DISCUSS][FLINK-40574] Upgrade SLF4J from 1.7 to 2.x Piotr Przybylski
2026/10/04 [jira] [Created] (FLINK-40905) Bump Pekko to 1.7.1 Sergey Nuyanzin (Jira)
2026/10/04 Re: [DISCUSS] FLIP-615: Snapshot Splitters for Table and Database Ingestion Chanhae Oh
2026/10/02 [Announcement] Flink 2.4 Release Manager Sync Meeting #3 Chanhae Oh
2026/10/02 [jira] [Created] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism Rui Fan (Jira)
2026/10/02 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API Sergey Nuyanzin
2026/10/02 [jira] [Created] (FLINK-40903) Add source host info in TM disconnect error Peter Huang (Jira)
2026/10/02 [jira] [Created] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column Fabian Hueske (Jira)
2026/10/02 Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Krishna Sai
2026/10/02 [jira] [Created] (FLINK-40901) JSON functions return the result of a previous row when JSON_TYPE or JSON_LENGTH is skipped Moritz Manner (Jira)
2026/10/02 Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Ferenc Csaky via dev
2026/10/02 [jira] [Created] (FLINK-40899) ON CONFLICT validation masks the NDU error for lookup joins Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40900) NDU analyzer does not check predicates pushed into a CDC source Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40898) TRY_RESOLVE wrongly rejects non-deterministic filters inside ChangelogNormalize Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40891) NDU plan visitor does not propagate determinism requirements through PTFs without REQUIRE_UPDATE_BEFORE Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands sepuri sai krishna (Jira)
2026/10/02 [jira] [Created] (FLINK-40896) Add built-in DEDUPLICATE_KEEP_FIRST PTF Gustavo de Morais (Jira)
2026/10/02 [jira] [Created] (FLINK-40895) Make use cache in code splitter Sergey Nuyanzin (Jira)
2026/10/02 Re: [DISCUSS] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Gustavo de Morais
2026/10/02 Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Krishna Sai
2026/10/02 [jira] [Created] (FLINK-40892) Stale IGNORE override on the changelog PTF tests Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40893) Update the determinism page for the current state of the NDU handling Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40890) LATERAL SNAPSHOT build side passes TRY_RESOLVE with non-deterministic columns Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40889) NDU plan visitor has no branch for VECTOR_SEARCH, TRY_RESOLVE and EXPLAIN PLAN_ADVICE fail Martijn Visser (Jira)
2026/10/02 Re: Release flink-connector-aws [6.1.0] Andreas Bube via dev
2026/10/02 [jira] [Created] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events DongShengHe (Jira)
2026/10/02 [RESULT][VOTE] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
2026/10/02 [jira] [Created] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty" Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
2026/10/02 [jira] [Created] (FLINK-40885) Support LATERAL SNAPSHOT join in the Table API Fabian Hueske (Jira)
2026/10/01 [jira] [Created] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters Robert Metzger (Jira)
2026/10/01 Re: Release flink-connector-aws [6.1.0] Ahmed Hamdy
2026/10/01 [jira] [Created] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction Bonnie Varghese (Jira)
2026/10/01 [jira] [Created] (FLINK-40882) Janino should compile same class only once Sergey Nuyanzin (Jira)
2026/10/01 Release flink-connector-aws [6.1.0] Roberts, Madison via dev
2026/10/01 [jira] [Created] (FLINK-40881) Update Flink wiki with new configs and user guide Peter Huang (Jira)
2026/10/01 [jira] [Created] (FLINK-40880) Support dynamic ratelimit in source coordinator with checkpoint latency control loop Peter Huang (Jira)
2026/10/01 [jira] [Created] (FLINK-40879) Add dynamic ratelimit Flink options Peter Huang (Jira)
2026/10/01 [jira] [Created] (FLINK-40878) Add dynamic rate limit interfaces Peter Huang (Jira)
2026/10/01 [jira] [Created] (FLINK-40877) Support Dynamic Rate Limit in Flink Sources Peter Huang (Jira)
2026/10/01 [jira] [Created] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
2026/10/01 [jira] [Created] (FLINK-40875) Optimization to let streaming joins fill key-only deletes instead of adding a ChangelogNormalize Gustavo de Morais (Jira)
2026/10/01 [jira] [Created] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
2026/10/01 Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Gustavo de Morais
2026/10/01 [jira] [Created] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT Ramin Gharib (Jira)
2026/10/01 [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Ferenc Csaky via dev
2026/10/01 Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Gustavo de Morais
2026/10/01 [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Ferenc Csaky via dev
2026/10/01 [jira] [Created] (FLINK-40873) Fix overlapping config key prefixes in the operator Gyula Fora (Jira)
2026/10/01 [jira] [Created] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
2026/10/01 Re: [DISCUSS] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Vas Shabu
2026/09/30 [jira] [Created] (FLINK-40870) End-to-end test coverage for FlinkMiniCluster Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40869) Document FlinkMiniCluster and add a MiniCluster example Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40868) Report operator metrics for FlinkMiniCluster resources Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40867) Support FlinkStateSnapshot for FlinkMiniCluster jobs Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40866) Add FlinkMiniClusterController and register the FlinkMiniCluster kind Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40865) Add the FlinkMiniCluster observer Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40864) Add the FlinkMiniCluster Flink service and reconciler Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40863) Derive FlinkMiniCluster memory configuration from spec.resources Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40862) Generate the MiniCluster pod, Deployment, Service and ConfigMap Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40861) Add the FlinkMiniCluster custom resource definition and API types Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Dale Lane (Jira)
2026/09/30 [jira] [Created] (FLINK-40859) FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane (Jira)
2026/09/30 [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Peter Huang
2026/09/30 [jira] [Created] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset kim (Jira)
2026/09/30 [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane via dev
2026/09/30 [jira] [Created] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)