dev  

Messages by Date

• 2026/10/24 [jira] [Created] (FLINK-41133) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41134) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Yuepeng Pan (Jira)
• 2026/10/24 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Aleksandr Iushmanov
• 2026/10/24 [jira] [Created] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input Martijn Visser (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41136) Exactly-once JdbcSink in BATCH mode fails for good after its committer restarts mid-commit Martijn Visser (Jira)
• 2026/10/24 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Weiqing Yang
• 2026/10/24 [jira] [Created] (FLINK-41132) Release Testing Instructions: FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41129) [release-2.4] Add release notes Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41128) [release-2.4] Verify that no exclusions were erroneously added to the japicmp plugin Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41126) [release-2.4] Triage release blockers in JIRA Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41127) [release-2.4] Review and update documentation Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41125) [release-2.4] Cross-team testing Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41124) [release-2.4] Review release notes in JIRA Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41123) [release-2.4] Prepare RC0 release Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
• 2026/10/24 Re: [PR] [FLINK-41117][ci] Use ubuntu 26 in ci docker image [flink-ci-docker] via GitHub
• 2026/10/24 [jira] [Created] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource Martijn Visser (Jira)
• 2026/10/24 [PR] [FLINK-41117][ci] Use ubuntu 26 in ci docker image [flink-ci-docker] via GitHub
• 2026/10/24 [jira] [Created] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• 2026/10/24 [jira] [Created] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41115) Checkpoint cleanup can starve AdaptiveScheduler execution-graph creation David Peacock (Jira)
• 2026/10/23 Re: [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Zander Matheson
• 2026/10/23 [jira] [Created] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG Gustavo de Morais (Jira)
• 2026/10/23 Re: [DISCUSS] FLIP-618: Edit, Inspect and Build VARIANT Values Ramin Gharib
• 2026/10/23 Re: [DISCUSS] FLIP-618: Edit, Inspect and Build VARIANT Values Timo Walther
• 2026/10/23 Re: [DISCUSS] FLINK-37987: JdbcDynamicTableSink to Sink V2 in place Krishna Sai
• 2026/10/23 [jira] [Created] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom Purushottam Sinha (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41110) Find VARIANT object fields by comparing UTF-8 bytes Ramin Gharib (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41112) Support Flink 1.20 in the Cassandra connector Martijn Visser (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Dian Fu (Jira)
• 2026/10/23 [DISCUSS] Make ON CONFLICT optional by default in Flink 2.4 Gustavo de Morais
• 2026/10/23 Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Ferenc Csaky via dev
• 2026/10/23 [jira] [Created] (FLINK-41111) Changelog mode errors of FlinkChangelogModeInferenceProgram do not identify the part of the query that produces the changes Moritz Manner (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xin Chen (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Dian Fu (Jira)
• 2026/10/23 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API Maximilian Michels
• 2026/10/23 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Maximilian Michels
• 2026/10/23 [jira] [Created] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Dian Fu (Jira)
• 2026/10/23 [jira] [Created] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Dian Fu (Jira)
• 2026/10/23 [DISCUSS] FLINK-37987: JdbcDynamicTableSink to Sink V2 in place Martijn Visser
• 2026/10/23 [jira] [Created] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• 2026/10/22 Re: [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Dian Fu
• 2026/10/22 [jira] [Created] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41098) Streaming mode: IN / NOT IN in the SELECT list drops all rows when the subquery result is empty Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41097) AVG returns NULL for a group with a NULL value once adaptive local hash aggregation switches to bypass mode Yaoxuan Wu (Jira)
• 2026/10/22 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Yuepeng Pan
• 2026/10/22 [jira] [Created] (FLINK-41092) RocksDB restore fails with ClassCastException when restoring KEY_VALUE_V2 state metadata from async ForSt Aaron He (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41096) Wrong result when a Table with a non-equi correlated scalar subquery is used twice in one query Yaoxuan Wu (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41095) MapStateAdaptor does not remove keys mapped to null in asyncPut and asyncPutAll Aaron He (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41093) AsyncKeyedStateBackendAdaptor ignores the TTL config of State V2 descriptors Aaron He (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41094) ForSt async MapState operations ignore RocksIterator#status() on invalid iterators and close batch iterators across threads Aaron He (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41091) Honor null-entry removal and reject null maps in ForSt asyncPutAll Aaron He (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed Utkarsh Vashishtha (Jira)
• 2026/10/22 [jira] [Created] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• 2026/10/22 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
• 2026/10/22 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
• 2026/10/22 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Austin Cawley-Edwards
• 2026/10/22 [DISCUSS] Supporting Flink 2.2/2.3 for flink-connector-aws M Junaid
• 2026/10/22 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
• 2026/10/22 [jira] [Created] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• 2026/10/22 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
• 2026/10/22 Re: [VOTE] FLIP-616: Materialized Tables support for Table API Gustavo de Morais
• 2026/10/22 [DISCUSS] FLIP-618: Edit, Inspect and Build VARIANT Values Ramin Gharib
• 2026/10/22 Re: [VOTE] FLIP-616: Materialized Tables support for Table API Timo Walther
• 2026/10/22 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Samrat Deb
• 2026/10/22 Re: [VOTE] FLIP-616: Materialized Tables support for Table API Ramin Gharib
• 2026/10/22 [jira] [Created] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
• 2026/10/22 [VOTE] FLIP-616: Materialized Tables support for Table API Timo Theusner
• 2026/10/22 [jira] [Created] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects Ramin Gharib (Jira)
• 2026/10/22 Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Gabor Somogyi
• 2026/10/22 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
• 2026/10/22 Re: [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Gyula Fóra
• 2026/10/22 [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector Martijn Visser
• 2026/10/22 [jira] [Created] (FLINK-41085) AppendOnlyTopNFunction emits an inconsistent changelog after cache eviction when sorting on NaN Bettle (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41084) Common & Source-Specific Metrics sukang (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41083) Add quickstart examples and best practice for Flink CDC docs Xiqian Yu (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41082) Polish Flink CDC docs and fix format issues Xiqian Yu (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41081) Provide EN / ZH bilingual docs for Flink CDC Xiqian Yu (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41080) [UMBRELLA] Polish Flink CDC docs and enrich contents Xiqian Yu (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41077) RpcEndpoint.MainThreadExecutor#schedule swallows exceptions thrown by the scheduled task Martijn Visser (Jira)
• 2026/10/21 [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] via GitHub
• 2026/10/21 [jira] [Created] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 Purushottam Sinha (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41076) Bump Netty to 4.2.17.Final in flink-shaded release-21.0 Purushottam Sinha (Jira)
• 2026/10/21 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Efrat Levitan
• 2026/10/21 [jira] [Created] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41074) Blue/green deployment can retire the active deployment using readiness from an older candidate revision Luca Castelli (Jira)
• 2026/10/21 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Mika Naylor via dev
• 2026/10/21 [jira] [Created] (FLINK-41072) Test configuration randomization on GitHub Actions always uses the same seed Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Rion Williams (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41071) Upgrade Testcontainers to 1.21.4 in the Cassandra connector to support Docker 29 Martijn Visser (Jira)
• 2026/10/21 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Purushottam Sinha
• 2026/10/21 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Sangkyoon Nam
• 2026/10/21 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib David Anderson
• 2026/10/21 [REQUEST] Unassigned bug/flaky test issues for 2.4 Mika Naylor via dev
• 2026/10/21 [jira] [Created] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws Muhammad (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41067) Window and interval joins store rows whose join key can never match Rion Williams (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE Gustavo de Morais (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs Timo Walther (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41064) 'State TTL Heap backend end-to-end test' fails on a "Trying to access closed classloader" log4j error in the TaskManager .out files Martijn Visser (Jira)
• 2026/10/21 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Aleksandr Savonin
• 2026/10/21 [jira] [Created] (FLINK-41063) DataStream large-record sorting unnecessarily falls back to Kryo for payload serialization Jira
• 2026/10/21 Re: Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
• 2026/10/21 Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Timo Walther
• 2026/10/21 Re: [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Gustavo de Morais
• 2026/10/21 [ANNOUNCE] New Apache Flink Committer - Ramin Gharib Timo Walther
• 2026/10/21 Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Gustavo de Morais
• 2026/10/21 [jira] [Created] (FLINK-41062) PARSE_XML and TRY_PARSE_XML can run out of memory for large documents Moritz Manner (Jira)
• 2026/10/21 Re: [REQUEST] Creating versions 2.4.1 and 2.5.0 in Jira Rui Fan
• 2026/10/21 [jira] [Created] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Han Yin (Jira)
• 2026/10/21 [REQUEST] Creating versions 2.4.1 and 2.5.0 in Jira Mika Naylor via dev
• 2026/10/21 [jira] [Created] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41059) FineGrainedSlotManager schedules requirement checks into the main thread after suspend() Martijn Visser (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41058) Fluss pipeline sink ignores table options defined in transform rules Hongshun Wang (Jira)
• 2026/10/21 [jira] [Created] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events Yanquan Lv (Jira)
• 2026/10/20 Re: Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Gustavo de Morais
• 2026/10/20 Re:Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
• 2026/10/20 [jira] [Created] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize Sergey Nuyanzin (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41055) StreamingMultiJoinOperator stores rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store Diljeet Singh (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41052) Helm chart: recreate the operator pod on ConfigMap changes and support annotations on the operator Deployment Gerk Elznik (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41043) NettyShuffleMaster.registerJob fails with "HashMap$Node cannot be cast to HashMap$TreeNode" when jobs start concurrently Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41053) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint cannot find chk-1 on restore on release-1.20 Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41050) Canary health checks revert canary metadata changes and restart a healthy operator Dennis-Mircea Ciupitu (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41046) HBaseConnectorITCase.testTableSinkDisabledBufferFlush expected [+I[1, 6]] but was [+I[1, 1]] Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41045) unning Kerberized YARN application on Docker test (custom fs plugin)' fails with NoResourceAvailableException because two of three TaskManager containers never register Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41042) TaskExecutorTest.testHeartbeatTimeoutWithJobManager fails in teardown with Boxed InterruptedException Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41041) Maven waits until the time budget after a JDK 8 surefire fork crashes with SIGSEGV in libjvm.so Martijn Visser (Jira)
• 2026/10/20 [jira] [Created] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Muhammad (Jira)
• 2026/10/19 Re: [Flink CDC][Bug] MongoDB CDC recreates change stream cursor from the task's starting offset Xiqian YU
• 2026/10/19 [jira] [Created] (FLINK-41026) [format/avro] Convert timestamps above precision 3 as microseconds in both directions Pritam Kumar (Jira)
• 2026/10/19 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
• 2026/10/19 [jira] [Created] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Yaoxuan Wu (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41038) WHERE CAST(x AS DECIMAL(10, 2)) IS NULL returns NULL for x when the cast overflows Yaoxuan Wu (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41037) DISTINCT over a FULL OUTER JOIN drops a row when the grouping key is NULL (batch mode) Yaoxuan Wu (Jira)
• 2026/10/19 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Ryan van Huuksloot via dev
• 2026/10/19 [jira] [Created] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty Biao Geng (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41036) [postgres-cdc] Restoring from a checkpoint taken inside a large transaction runs out of heap Mohsen Rezaei (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41031) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41030) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41035) Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false Dennis-Mircea Ciupitu (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41027) [format/avro] Add an option to map time-millis and time-micros to INT and BIGINT Pritam Kumar (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41029) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41033) Savepoint history cleanup disposes the savepoint referenced by status.jobStatus.upgradeSavepointPath, causing restore failures (FileNotFoundException) Saurabh Kanawade (Jira)
• 2026/10/19 Cobble-Flink adds async state support for Apache Flink 2.x Zakelly Lan
• 2026/10/19 [jira] [Created] (FLINK-41024) Upgrade PyFlink docs to Sphinx 9.1 Martijn Visser (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41023) Build English and Chinese PyFlink docs from one lockfile Martijn Visser (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink Hongshun Wang (Jira)
• 2026/10/19 [jira] [Created] (FLINK-41025) Add config option to control enableServiceLinks of JobManager and TaskManager pods Guotao Ding (Jira)
• 2026/10/19 Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
• 2026/10/18 [Flink CDC][Bug] MongoDB CDC recreates change stream cursor from the task's starting offset Sonal Maheshwari
• 2026/10/18 [jira] [Created] (FLINK-41021) Update commons-beanutils to 1.11.0 and jsoup to 1.23.2 Martijn Visser (Jira)
• 2026/10/18 [jira] [Created] (FLINK-41022) Update lz4-java to 1.12.0 Martijn Visser (Jira)
• 2026/10/18 [jira] [Created] (FLINK-41020) PyFlink docs: Update dependencies with open Dependabot advisories Martijn Visser (Jira)
• 2026/10/18 [jira] [Created] (FLINK-41019) COMPILE PLAN does not record table.exec.sink.nested-constraint-enforcer, so EXECUTE PLAN uses the cluster's value sepuri sai krishna (Jira)
• 2026/10/18 Re: [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Yunfeng Zhou
• 2026/10/17 [jira] [Created] (FLINK-41018) Introduce BIT_COUNT as a built-in function for SQL and Table API Yuepeng Pan (Jira)
• 2026/10/17 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Zhe Wang
• 2026/10/17 [jira] [Created] (FLINK-41017) Use DecimalData#isCompact while casting Sergey Nuyanzin (Jira)
• 2026/10/17 [jira] [Created] (FLINK-41016) Missing uids on the operators PyFlink adds for key_by, partition_custom and KeyedStream can prevent submission with auto-generated UIDs disabled Sangkyoon Nam (Jira)
• 2026/10/16 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Zhe Wang
• 2026/10/16 Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
• 2026/10/16 Re: [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Zhanghao Chen
• 2026/10/16 Re: [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Zhanghao Chen
• 2026/10/16 Re: [DISCUSS] Release flink-connector-pulsar v5.0.0 Ferenc Csaky via dev
• 2026/10/16 Re: [DISCUSS] Flink Community Skills Gustavo de Morais
• 2026/10/16 [jira] [Created] (FLINK-41013) Use a hash consistent with SQL equality to match MAP keys and array elements Ramin Gharib (Jira)
• 2026/10/16 [jira] [Created] (FLINK-41015) [JUnit5 Migration] Migrate the remaining of the junit4 testing class to junit5 of flink-test-utils module. Yuepeng Pan (Jira)
• 2026/10/16 [jira] [Created] (FLINK-41014) Add an adaptive retry mode to the native S3 connector Gabor Somogyi (Jira)
• 2026/10/15 [jira] [Created] (FLINK-41012) Schema change apply failure leads to unrecoverable crash loop: redundant skip + null evolved schema leak after job restart zhanglu153 (Jira)
• 2026/10/15 Re:Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
• 2026/10/15 [jira] [Created] (FLINK-41011) [pipeline-connector/doris] Auto-created Doris table drops NOT NULL constraint of source columns tchivs (Jira)
• 2026/10/15 [jira] [Created] (FLINK-41010) [cdc-base] NPE in HybridSplitAssigner.createStreamSplit when failed snapshot splits are re-added after assigner finished tchivs (Jira)
• 2026/10/15 Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Gustavo de Morais
• 2026/10/15 Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Mate Czagany
• 2026/10/15 [jira] [Created] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink Yubiao Feng (Jira)
• 2026/10/15 [jira] [Created] (FLINK-41008) Support multi-table transaction stream load in StarRocks pipeline connector peiyu (Jira)
• 2026/10/15 [jira] [Created] (FLINK-41007) ON CONFLICT clause is silently ignored when table.exec.sink.upsert-materialize is NONE sepuri sai krishna (Jira)
• 2026/10/15 [jira] [Created] (FLINK-41006) upgrade starrocks connector to 1.2.16 peiyu (Jira)
• 2026/10/15 Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
• 2026/10/15 Re: [DISCUSS] FLIP-613 : Remote Artifact Fetch for Session-Mode Job Submission Krishna Sai
• 2026/10/15 Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Gustavo de Morais
• 2026/10/15 [jira] [Created] (FLINK-41005) MiniCluster should clean up partially started services when start() fails Dale Lane (Jira)

• Earlier messages