dev  

Messages by Date

• 2026/06/27 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
• 2026/06/27 Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Yuepeng Pan
• 2026/06/27 Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Roman Khachatryan
• 2026/06/26 Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Ferenc Csaky
• 2026/06/26 [jira] [Created] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Chris Johnson (Jira)
• 2026/06/26 Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Aleksandr Savonin
• 2026/06/26 [jira] [Created] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Jim Hughes (Jira)
• 2026/06/26 [jira] [Created] (FLINK-40001) Upgrade Calcite version to 1.42.0 Sergey Nuyanzin (Jira)
• 2026/06/26 [jira] [Created] (FLINK-40000) Remove the redundant testing util class SynchronousComponentMainThreadExecutor ChanBin OH (Jira)
• 2026/06/26 [jira] [Created] (FLINK-39999) Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 Sergey Nuyanzin (Jira)
• 2026/06/26 [jira] [Created] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Raj (Jira)
• 2026/06/26 [jira] [Created] (FLINK-39997) Upgrade pemja to 0.6.1 Florian Vazelle (Jira)
• 2026/06/26 Re: [ANNOUNCE] Apache Flink 2.3.0 released Rui Fan
• 2026/06/26 Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Rui Fan
• 2026/06/26 Re: [DISCUSS] FLIP-588: Support per-job delegation tokens Gabor Somogyi
• 2026/06/26 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
• 2026/06/25 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/06/25 [ANNOUNCE] Apache Flink 2.3.0 released David Anderson
• 2026/06/25 Re: [DISCUSS] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
• 2026/06/25 [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
• 2026/06/25 [jira] [Created] (FLINK-39996) Migrate KafkaSink EOS recovery to Kafka public PreparedTxnState API Shekhar Prasad Rajak (Jira)
• 2026/06/25 Re: [DISCUSS] FLIP-XXX Monotonic Counters support Efrat Levitan
• 2026/06/25 Re: [DISCUSS] FLIP-590: Introduce Multimodal Data Types: Vector, Tensor, and Image Geng Biao
• 2026/06/25 Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Yuepeng Pan
• 2026/06/25 Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Ferenc Csaky
• 2026/06/25 [jira] [Created] (FLINK-39995) Add ISO-8601 timestamp format with explicit timezone offset support Jira
• 2026/06/25 [DISCUSS] FLIP-598: [Filesystems] Gen2 Datalake SDK Native FileSystem for Azure Aleksandr Iushmanov
• 2026/06/25 [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
• 2026/06/25 [jira] [Created] (FLINK-39994) Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/06/25 [jira] [Created] (FLINK-39993) Correct documentation examples for ProcessTableFunctionTestHarness Mika Naylor (Jira)
• 2026/06/24 [jira] [Created] (FLINK-39992) Drop ReplaceIntersectWithSemiJoinRule Jacky Lau (Jira)
• 2026/06/24 [jira] [Created] (FLINK-39991) Drop ReplaceIntersectWithSemiJoinRule Jacky Lau (Jira)
• 2026/06/24 [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 주수민
• 2026/06/24 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Zander Matheson
• 2026/06/24 Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Poorvank Bhatia
• 2026/06/24 [jira] [Created] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader Bowen Li (Jira)
• 2026/06/24 [jira] [Created] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions Filippo Ghibellini (Jira)
• 2026/06/24 [jira] [Created] (FLINK-39988) Support composite types in filter push-down for savepoint Table API connector Ilya Soin (Jira)
• 2026/06/24 [jira] [Created] (FLINK-39987) Update docs related to flink-state-processing-api Ilya Soin (Jira)
• 2026/06/24 [jira] [Created] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs raoraoxiong (Jira)
• 2026/06/24 Re: [DISCUSS] FLIP-588: Support per-job delegation tokens Gabor Somogyi
• 2026/06/24 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region Roman Khachatryan
• 2026/06/24 [jira] [Created] (FLINK-39985) Drop ReplaceMinusWithAntiJoinRule Jacky Lau (Jira)
• 2026/06/24 [jira] [Created] (FLINK-39984) `requestThreadDump` blocks the JM/TM main thread and can cause heartbeat timeout / job failure xingsuo-zbz (Jira)
• 2026/06/23 [jira] [Created] (FLINK-39983) Drop FlinkPruneEmptyRules Jacky Lau (Jira)
• 2026/06/23 [jira] [Created] (FLINK-39982) Drop SqlCollectionTypeNameSpec and SqlJsonQueryFunction from Flink codebase Sergey Nuyanzin (Jira)
• 2026/06/23 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
• 2026/06/23 退订 wdmcode via dev
• 2026/06/23 [jira] [Created] (FLINK-39981) Autoscaler cannot trigger source rebalance after active split removal on dynamic Kafka source Xin Gao (Jira)
• 2026/06/23 Re: [DISCUSS] FLIP-588: Support per-job delegation tokens Alan Sheinberg via dev
• 2026/06/23 [jira] [Created] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes Bowen Li (Jira)
• 2026/06/23 [jira] [Created] (FLINK-39979) DynamicKafkaSource does not mark reader idle when metadata removal leaves a subtask with no active subreaders Bowen Li (Jira)
• 2026/06/23 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava via dev
• 2026/06/23 [jira] [Created] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button Purushottam Sinha (Jira)
• 2026/06/23 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region Zakelly Lan
• 2026/06/23 [jira] [Created] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework Zakelly Lan (Jira)
• 2026/06/23 Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Ryan van Huuksloot via dev
• 2026/06/23 Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
• 2026/06/23 [jira] [Created] (FLINK-39976) Flink cdc pipeline support db2 source pipeline connector Daishuyuan (Jira)
• 2026/06/23 [jira] [Created] (FLINK-39975) Flaky DerbyDynamicTableSourceITCase.testLimit: JdbcSourceSplitReader does not recover from a connection closed during source cancellation Tomoyuki NAKAMURA (Jira)
• 2026/06/22 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
• 2026/06/22 [jira] [Created] (FLINK-39974) Release flink-connector-jdbc v6.0.0 for Flink 2.2 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39973) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39972) Release flink-connector-jdbc v3.4.0 for Flink 1.20 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39971) Support and Release Connectors for Flink 2.2 Chanhae Oh (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39970) Kubernetes Operator proceeds with cluster resubmission after Deployment deletion wait timeout, causing AlreadyExists / object-is-being-deleted race Bowen Li (Jira)
• 2026/06/22 Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Aleksandr Iushmanov
• 2026/06/22 Re: Future direction of Flink's S3 filesystem implementations Aleksandr Iushmanov
• 2026/06/22 [jira] [Created] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/22 Re: [DISCUSS] FLIP-XXX Monotonic Counters support Ryan van Huuksloot via dev
• 2026/06/22 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Jark Wu
• 2026/06/22 [jira] [Created] (FLINK-39968) [Optimization] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance yyka (Jira)
• 2026/06/22 [jira] [Created] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error Santwana Verma (Jira)
• 2026/06/22 [DISCUSS] FLIP-592: First-Class Accelerator Resource Support Yi Zhang
• 2026/06/22 [jira] [Created] (FLINK-39966) FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only lincoln lee (Jira)
• 2026/06/22 [VOTE] FLIP-545: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
• 2026/06/21 [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
• 2026/06/21 [jira] [Created] (FLINK-39965) Flink CDC should clear schema state and table-level caches after DropTableEvent Ran Tao (Jira)
• 2026/06/21 Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
• 2026/06/21 Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
• 2026/06/21 Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
• 2026/06/21 Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
• 2026/06/21 Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer Feng Jin
• 2026/06/21 Re: Request for PMC to get PyPI access Yuepeng Pan
• 2026/06/21 RE: Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Jing-Jia Hung
• 2026/06/21 [jira] [Created] (FLINK-39964) Incremental checkpoint taken after a CLAIM-mode restore from a native savepoint is not restorable Aleksandr Savonin (Jira)
• 2026/06/21 [ANNOUNCE] Apache Flink Agents 0.3.0 released wenjin
• 2026/06/20 [jira] [Created] (FLINK-39963) Runtime: ExecutionTimeBasedSlowTaskDetectorTest.testBalancedInput flaky Purushottam Sinha (Jira)
• 2026/06/20 [jira] [Created] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky Purushottam Sinha (Jira)
• 2026/06/20 [jira] [Created] (FLINK-39961) Support routing across models in Flink SQL (ML_PREDICT) Purshotam Shah (Jira)
• 2026/06/20 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API Sergey Nuyanzin
• 2026/06/20 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API Sergey Nuyanzin
• 2026/06/20 [jira] [Created] (FLINK-39960) Remove broken JavaDoc shortcode usage from JDBC datastream docs Dennis-Mircea Ciupitu (Jira)
• 2026/06/20 Re: [PR] [hotfix] Add `.gitignore` [flink-ci-docker] via GitHub
• 2026/06/20 [PR] [hotfix] Add `.gitignore` [flink-ci-docker] via GitHub
• 2026/06/20 Re: [DISCUSS] FLIP-590: Introduce Multimodal Data Types: Vector, Tensor, and Image Yanquan Lv
• 2026/06/19 Re: Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2026/06/19 [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2026/06/19 Re: [VOTE] FLIP-588: Support per-job delegation tokens Roman Khachatryan
• 2026/06/19 [jira] [Created] (FLINK-39959) Improve the autoscaler context structure and propagation Dennis-Mircea Ciupitu (Jira)
• 2026/06/19 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
• 2026/06/19 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region Roman Khachatryan
• 2026/06/19 Re: [DISCUSS] FLIP-588: Support per-job delegation tokens Gabor Somogyi
• 2026/06/19 [RESULT] [VOTE] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
• 2026/06/19 [VOTE] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
• 2026/06/19 [RESULT][VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 wenjin
• 2026/06/19 [jira] [Created] (FLINK-39958) Autoscaler Flink REST client timeout is silently overridden by the operator client timeout Dennis-Mircea Ciupitu (Jira)
• 2026/06/19 Re: Future direction of Flink's S3 filesystem implementations Gabor Somogyi
• 2026/06/19 [RESULT][VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
• 2026/06/19 Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
• 2026/06/19 Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
• 2026/06/19 [jira] [Created] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements Ramin Gharib (Jira)
• 2026/06/18 Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Alan Zhang
• 2026/06/18 RE: Future direction of Flink's S3 filesystem implementations ctrlaltdilj
• 2026/06/18 [jira] [Created] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Zhenqiu Huang (Jira)
• 2026/06/18 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
• 2026/06/18 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
• 2026/06/18 Request for PMC to get PyPI access Yuepeng Pan
• 2026/06/18 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
• 2026/06/18 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Yuepeng Pan
• 2026/06/18 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Chanhae Oh
• 2026/06/18 Re: [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
• 2026/06/18 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Chanhae Oh
• 2026/06/18 [jira] [Created] (FLINK-39955) PTF OutputTypeStrategy can emit time indicator types Fabian Hueske (Jira)
• 2026/06/18 Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Dian Fu
• 2026/06/18 Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Zhu Zhu
• 2026/06/17 Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Xintong Song
• 2026/06/17 Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Weiqing Yang
• 2026/06/17 [RESULT][VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
• 2026/06/17 Re: [VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
• 2026/06/17 Re: [VOTE] Release 2.3.0, release candidate #4 Weiqing Yang
• 2026/06/17 Re: [VOTE] Release 2.3.0, release candidate #4 weijie guo
• 2026/06/17 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Yong Fang
• 2026/06/17 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Zander Matheson
• 2026/06/17 [jira] [Created] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/06/17 Re: [VOTE] Release 2.3.0, release candidate #4 Martijn Visser
• 2026/06/17 Re: [VOTE] Release 2.3.0, release candidate #4 Samrat Deb
• 2026/06/17 [jira] [Created] (FLINK-39953) AbstractFlinkService.deleteBlocking() swallows KubernetesClientTimeoutException allowing cluster upgrade to proceed on top of still-running cluster Lucas Borges (Jira)
• 2026/06/17 Re: [VOTE] Release 2.3.0, release candidate #4 Rui Fan
• 2026/06/17 Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Leonard Xu
• 2026/06/17 [jira] [Created] (FLINK-39952) CallContextMock.isArgumentNull() does not correctly implement interface contract Fabian Hueske (Jira)
• 2026/06/17 Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Rich Bowen
• 2026/06/17 Re: [VOTE] Release 2.3.0, release candidate #4 Keith Lee
• 2026/06/17 Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Gabor Somogyi
• 2026/06/17 Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Cole Bailey via dev
• 2026/06/17 Re: [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
• 2026/06/17 [jira] [Created] (FLINK-39951) [Python] ArrayConstructor uses == for String comparison, silently truncating long array values to int Jubin Soni (Jira)
• 2026/06/17 [jira] [Created] (FLINK-39950) [sqlserver] scan.incremental.snapshot.chunk.key-column only searches primary key columns instead of all table columns Jubin Soni (Jira)
• 2026/06/17 [jira] [Created] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• 2026/06/16 [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
• 2026/06/16 [jira] [Created] (FLINK-39948) The flink-table-planner module failed to compile with JDK 11 reswqa (Jira)
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 David Anderson
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 Rich Bowen
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 Rich Bowen
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 Rich Bowen
• 2026/06/16 Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 Hao Li
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #3 Yuepeng Pan
• 2026/06/16 RE: Re: [DISCUSS] AI-Assisted Contributions and AI Tooling Support in Apache Flink Mehrtens, Mazrim
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #3 Sergey Nuyanzin
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #3 Gustavo de Morais
• 2026/06/16 [jira] [Created] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Yuepeng Pan (Jira)
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
• 2026/06/16 Re: [VOTE] Release 2.3.0, release candidate #4 Gustavo de Morais
• 2026/06/16 [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 wenjin
• 2026/06/16 RE: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
• 2026/06/16 [RESULT][VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
• 2026/06/16 RE: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
• 2026/06/16 [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer zihao chen
• 2026/06/16 Re: [ANNOUNCE] New Apache Flink Committer - Hao Li Ramin Gharib
• 2026/06/15 Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Efrat Levitan
• 2026/06/15 [FLINK-39639] Silent data loss when a split is assigned after a source finishes Spoorthi Basu
• 2026/06/15 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions 오찬빈
• 2026/06/15 [jira] [Created] (FLINK-39946) Unaligned checkpoint restore can mis-map union input channel state after reordering UIDed sources Bowen Li (Jira)
• 2026/06/15 [jira] [Created] (FLINK-39945) CAST of DECIMAL changed with Calcite 1.38.0 Sergey Nuyanzin (Jira)
• 2026/06/15 [jira] [Created] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough Xin Gao (Jira)
• 2026/06/15 [jira] [Created] (FLINK-39943) IS [NOT ]JSON changed nullability after upgrade to Calcite 1.38.0 Sergey Nuyanzin (Jira)
• 2026/06/15 [jira] [Created] (FLINK-39942) Add support for frame exclusion in window functions Sergey Nuyanzin (Jira)
• 2026/06/15 Fwd: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/06/15 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/06/15 [jira] [Created] (FLINK-39941) Weekly CI fails because pip no longer supports Python 3.8 Aleksandr Savonin (Jira)
• 2026/06/15 [jira] [Created] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Bowen Li (Jira)
• 2026/06/15 [DISCUSS] FLIP-XXX Monotonic Counters support Efrat Levitan
• 2026/06/15 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Yuepeng Pan
• 2026/06/15 Future direction of Flink's S3 filesystem implementations Samrat Deb
• 2026/06/15 Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Yuepeng Pan
• 2026/06/15 Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Yanquan Lv
• 2026/06/15 [jira] [Created] (FLINK-39939) FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu (Jira)
• 2026/06/15 [jira] [Created] (FLINK-39938) FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu (Jira)
• 2026/06/15 [RESULT][VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• 2026/06/15 [RESULT][VOTE] FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
• 2026/06/15 Re: [VOTE] FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
• 2026/06/15 Re: [VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• 2026/06/15 Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Rui Fan
• 2026/06/15 Re: [DISCUSS] Release Plan for the Next Group of Flink JDBC Connector Versions Rui Fan
• 2026/06/15 Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Leonard Xu
• 2026/06/15 Re: [DISCUSS] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
• 2026/06/15 [VOTE] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
• 2026/06/15 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan

• Earlier messages