dev  

Messages by Date

• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing weijie guo
• 2026/05/27 [jira] [Created] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Hang Ruan
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yun Gao
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Xintong Song
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yuepeng Pan
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yuan Mei
• 2026/05/27 Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yuan Mei
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing FeatZhang
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Charles Zhang
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Jark Wu
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Zhu Zhu
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Leonard Xu
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Lincoln Lee
• 2026/05/27 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
• 2026/05/27 Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
• 2026/05/27 [SUMMARY] Release 2.3 SYNC Yuepeng Pan
• 2026/05/27 Re: Slack invitation Weiqing Yang
• 2026/05/27 [jira] [Created] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults Gerk Elznik (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39790) State latency/size tracking metrics not exported without sampling Efrat Levitan (Jira)
• 2026/05/27 Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
• 2026/05/27 Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
• 2026/05/27 [jira] [Created] (FLINK-39789) AvroSchemaConverter.convertToDataType(String) ignores local-timestamp-* and timestamp-nanos logical types, silently maps to BIGINT Shekhar Prasad Rajak (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39788) Pekko error "Actor not found" when Kubernetes namespace starts from digit Vladislav Keda (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39787) Build broken for flink-benchmarks David Anderson (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure Samrat Deb (Jira)
• 2026/05/27 [DISCUSS] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
• 2026/05/27 [jira] [Created] (FLINK-39785) Add end-to-end tests for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39784) Add translation rule to block usage of SNAPSHOT function outside of LATERAL context Fabian Hueske (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39782) Add SNAPSHOT built-in table function definition Fabian Hueske (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39783) Add translation rules to convert lateral call of SNAPSHOT function into join operator Fabian Hueske (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39781) Add operator for LATERAL SNAPSHOT Join Fabian Hueske (Jira)
• 2026/05/27 Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
• 2026/05/27 [jira] [Created] (FLINK-39780) Make TABLE keyword optional in LATERAL context Fabian Hueske (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39779) FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume Samrat Deb (Jira)
• 2026/05/27 Re: [DISCUSS] FLIP-582: Support RpcOperator Service Charles Zhang
• 2026/05/27 Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Martijn Visser
• 2026/05/27 [jira] [Created] (FLINK-39777) Support configurable HashFunction strategies in PrePartitionOperator Yanquan Lv (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39776) Expose JobInfo on Source contexts Aleksandr Savonin (Jira)
• 2026/05/27 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Fabian Hueske
• 2026/05/27 [jira] [Created] (FLINK-39775) Snapshot split metadata is not released after switching to stream phase, causing large JobManager coordinator state and OOM with many snapshot splits yuanfenghu (Jira)
• 2026/05/27 [jira] [Created] (FLINK-39774) Format YEAR-MONTH interval keys as months instead of days Fan Deng (Jira)
• 2026/05/27 [DISCUSS] FLIP-XXX: Independent Checkpoint Based On Pipeline Region 熊饶饶
• 2026/05/27 [jira] [Created] (FLINK-39773) ClusterEntryPointTest fails on java25 Sergey Nuyanzin (Jira)
• 2026/05/26 [DISCUSS] FLIP-582: Support RpcOperator Service Yi Zhang
• 2026/05/26 Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Alan Sheinberg via dev
• 2026/05/26 [jira] [Created] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests Purushottam Sinha (Jira)
• 2026/05/26 [jira] [Created] (FLINK-39771) [JUnit5 Migration] Module: flink-cep Purushottam Sinha (Jira)
• 2026/05/26 [jira] [Created] (FLINK-39770) [JUnit5 Migration] Module: flink-state-processing-api Purushottam Sinha (Jira)
• 2026/05/26 [jira] [Created] (FLINK-39769) [JUnit5 Migration] Module: flink-examples-streaming Purushottam Sinha (Jira)
• 2026/05/26 [jira] [Created] (FLINK-39768) Module: flink-avro - migrate AvroStreamingFileSinkITCase straggler Purushottam Sinha (Jira)
• 2026/05/26 Re: Flink Consumption of ASF Shared GitHub-hosted Runners Robert Metzger
• 2026/05/26 Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Ramin Gharib
• 2026/05/26 [jira] [Created] (FLINK-39767) [JUnit5 Migration] Module: flink-statebackend-forst Purushottam Sinha (Jira)
• 2026/05/26 [jira] [Created] (FLINK-39766) Remove AggregatedMetric copy that made redundant by Flink 1.20 dependency upgrade Aleksandr Savonin (Jira)
• 2026/05/26 [ANNOUNCE] Apache Flink Kubernetes Operator 1.15.0 released Gyula Fóra
• 2026/05/26 [DISCUSS] CEP NFA partial match accumulation causes unbounded memory/CPU growth for high-frequency start events 1193179897
• 2026/05/26 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Zakelly Lan
• 2026/05/26 [jira] [Created] (FLINK-39765) Add FLIP-314 lineage support (LineageVertexProvider) to MySQL CDC source connector Jaskaran Singh Kukreja (Jira)
• 2026/05/26 Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause FeatZhang
• 2026/05/26 Re: [VOTE] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Gabor Somogyi
• 2026/05/26 [VOTE] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project Martijn Visser
• 2026/05/26 RE: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
• 2026/05/26 [jira] [Created] (FLINK-39764) Support dynamic table options in Table API Mika Naylor (Jira)
• 2026/05/26 Re: Flink Consumption of ASF Shared GitHub-hosted Runners Sergey Nuyanzin
• 2026/05/26 Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Kui Yuan
• 2026/05/26 [jira] [Created] (FLINK-39763) Allow inferring constants with `IS NOT DISTINCT FROM` Sergey Nuyanzin (Jira)
• 2026/05/26 Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Kui Yuan
• 2026/05/26 [jira] [Created] (FLINK-39762) Wget is absent for java25 docker Sergey Nuyanzin (Jira)
• 2026/05/26 Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function Timo Walther
• 2026/05/26 Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Timo Walther
• 2026/05/26 RE: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
• 2026/05/26 [jira] [Created] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning Jira
• 2026/05/26 Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Lincoln Lee
• 2026/05/25 Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Gen Luo
• 2026/05/25 [jira] [Created] (FLINK-39760) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• 2026/05/25 [jira] [Created] (FLINK-39756) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• 2026/05/25 [jira] [Created] (FLINK-39759) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• 2026/05/25 [jira] [Created] (FLINK-39758) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• 2026/05/25 [jira] [Created] (FLINK-39757) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• 2026/05/25 Re: [DISCUSS] Release Flink 1.20.5 Xintong Song
• 2026/05/25 [jira] [Created] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Sergey Nuyanzin (Jira)
• 2026/05/25 [jira] [Created] (FLINK-39754) DataOutputSerializer.resize() int overflow causes O(n²) growth near 2 GB Saulius Valatka (Jira)
• 2026/05/25 [jira] [Created] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
• 2026/05/25 Re: Flink CEP: can CEP reliably implement "condition true for T minutes" ? rohit patil
• 2026/05/25 Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function 熊饶饶
• 2026/05/25 [jira] [Created] (FLINK-39752) Thread EventRecorder through FlinkResourceContext instead of holding it on the factory Dennis-Mircea Ciupitu (Jira)
• 2026/05/25 [DISCUSS] Introducing DECLARE VARIABLE in Flink SQL Chanhae Oh
• 2026/05/25 Re: [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Xia Sun
• 2026/05/25 [jira] [Created] (FLINK-39751) Introduce FailsOnJava25 Sergey Nuyanzin (Jira)
• 2026/05/25 [jira] [Created] (FLINK-39750) Drop FailsOnJava11 Sergey Nuyanzin (Jira)
• 2026/05/25 Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger Feng Jin
• 2026/05/25 [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function FeatZhang
• 2026/05/25 [jira] [Created] (FLINK-39749) [mysql-cdc] Introduce scan.incremental.snapshot.string-key.compare-mode to align Java and MySQL ordering for string chunk keys Ziyan Lee (Jira)
• 2026/05/25 [DISCUSS] Release Flink 1.20.5 Yunfeng Zhou
• 2026/05/25 [jira] [Created] (FLINK-39748) Postgres CDC snapshot produces wrong values for TIMESTAMP / TIMESTAMPTZ / DATE columns with historical dates Di Wu (Jira)
• 2026/05/25 Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Kui Yuan
• 2026/05/25 Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Kui Yuan
• 2026/05/25 RE: [DISCUSS] FLINK-36456 — Datadog reporter: support DD_API_KEY env var Thierno BARRY via dev
• 2026/05/24 Re: Slack invitation Leonard Xu
• 2026/05/24 Slack invitation Soumitra Kumar
• 2026/05/24 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/05/24 [jira] [Created] (FLINK-39747) Upgrade test to junit 5 Fan Deng (Jira)
• 2026/05/24 [jira] [Created] (FLINK-39746) Add jdk25 profile in in common_docker.sh Sergey Nuyanzin (Jira)
• 2026/05/24 [jira] [Created] (FLINK-39745) Web dashboard: surface watermark lag as a per-job timeline Purushottam Sinha (Jira)
• 2026/05/24 [jira] [Created] (FLINK-39744) Release Testing: Verify FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• 2026/05/24 Re: [VOTE] Release flink-connector-http v1.0.0, release candidate 2 Ferenc Csaky
• 2026/05/23 [jira] [Created] (FLINK-39743) Incorrect Expected Processing Rate Computation Devika Sudheer (Jira)
• 2026/05/23 [jira] [Created] (FLINK-39742) FlinkImageBuilder checks for Java 25 Sergey Nuyanzin (Jira)
• 2026/05/23 Re: [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer zihao chen
• 2026/05/23 Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
• 2026/05/22 [jira] [Created] (FLINK-39741) Add generic type hints to DataStream functions in functions.py Vaibhav S Gowda (Jira)
• 2026/05/22 Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger zihao chen
• 2026/05/22 [jira] [Created] (FLINK-39740) LinkedMultiSetState updates highestSqnAndSizeState unconditionally Roman Khachatryan (Jira)
• 2026/05/22 [jira] [Created] (FLINK-39739) Add java25 to docker imae Sergey Nuyanzin (Jira)
• 2026/05/22 [jira] [Created] (FLINK-39738) React to checkpoint ACK RPC failures Roman Khachatryan (Jira)
• 2026/05/22 [jira] [Created] (FLINK-39737) Add native s3 connector throttling support Gabor Somogyi (Jira)
• 2026/05/22 [jira] [Created] (FLINK-39736) Do not allow security manager for jdk24+ Sergey Nuyanzin (Jira)
• 2026/05/22 [jira] [Created] (FLINK-39735) Expose input upsert key on TableSemantics for ProcessTableFunctions Ramin Gharib (Jira)
• 2026/05/22 [jira] [Created] (FLINK-39734) Exclude 2.1 and 2.2 from GHA nightly Sergey Nuyanzin (Jira)
• 2026/05/22 [REVIEW] Pavel Zeger
• 2026/05/22 [RESULT][VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Gabor Somogyi
• 2026/05/22 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Gabor Somogyi
• 2026/05/22 Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Gabor Somogyi
• 2026/05/22 Flink Consumption of ASF Shared GitHub-hosted Runners Robert Thomson
• 2026/05/22 Re: [DISCUSS] FLIP-578: In-place Table to Materialized Table conversion Arvid Heise via dev
• 2026/05/22 [jira] [Created] (FLINK-39733) Do not use net.jcip.annotations Sergey Nuyanzin (Jira)
• 2026/05/22 Re: [VOTE] Release flink-connector-pulsar v4.2.0, release candidate #1 David Radley
• 2026/05/22 [jira] [Created] (FLINK-39732) Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) Hongshun Wang (Jira)
• 2026/05/22 Slack invitation Alexis Sarda-Espinosa
• 2026/05/22 Re: [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer Fan Deng
• 2026/05/22 [jira] [Created] (FLINK-39731) SqlValidatorImpl should reject MATCH_RECOGNIZE with duplicate MEASURE Sergey Nuyanzin (Jira)
• 2026/05/22 [VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
• 2026/05/21 [jira] [Created] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client Jubin Soni (Jira)
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Yanquan Lv
• 2026/05/21 [DISCUSS] FLIP-580 AsyncTableFunction supports user-defined timeout handling logic. Kui Yuan
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Sergey Nuyanzin
• 2026/05/21 [jira] [Created] (FLINK-39729) CorrelateRestoreTest.testRestore[8] (CORRELATE_WITH_LITERAL_AGG) is flaky due to non-deterministic changelog ordering Jim Hughes (Jira)
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Yash Anand
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Aleksandr Savonin
• 2026/05/21 [jira] [Created] (FLINK-39728) KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions Jim Hughes (Jira)
• 2026/05/21 [jira] [Created] (FLINK-39727) flink-kubernetes-operator: Bump fabric8 and operator-sdk to retire transitive CVEs Purushottam Sinha (Jira)
• 2026/05/21 The Flink blog David Radley
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Samrat Deb
• 2026/05/21 Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Aleksandr Iushmanov
• 2026/05/21 [jira] [Created] (FLINK-39726) Update create table syntax with using connection Hao Li (Jira)
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Hao Li
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Ramin Gharib
• 2026/05/21 [jira] [Created] (FLINK-39725) from_source does not use timestamp assigner in pyflink Andrew Feng (Jira)
• 2026/05/21 Re: [SUMMARY] Release 2.3 sync Yuepeng Pan
• 2026/05/21 [jira] [Created] (FLINK-39724) CsvFormatReader produces a stream which fails get_type() and assign_timestamps_and_watermarks() Andrew Feng (Jira)
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Ryan van Huuksloot via dev
• 2026/05/21 [jira] [Created] (FLINK-39723) KafkaTableITCase.testExactlyOnceSink fails due to transactional ID reuse across test runs Aleksandr Savonin (Jira)
• 2026/05/21 Public CA single-purpose EKU Gyula Komlossi
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Austin Cawley-Edwards
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Dawid Wysakowicz
• 2026/05/21 Re: [DISCUSS] FLIP-579: LATERAL SNAPSHOT Join Timo Walther
• 2026/05/21 Re: [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Swapnal Varma
• 2026/05/21 [ANNOUNCE] New Apache Flink Committer - Gustavo de Morais Timo Walther
• 2026/05/21 Apache infrastructure PR wanting to change default rulesets. David Radley
• 2026/05/21 [jira] [Created] (FLINK-39722) Support Fluss CDC Yaml Source Hongshun Wang (Jira)
• 2026/05/21 [jira] [Created] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. Hongshun Wang (Jira)
• 2026/05/21 Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
• 2026/05/21 Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Martijn Visser
• 2026/05/21 [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
• 2026/05/20 [jira] [Created] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
• 2026/05/20 RE: [VOTE] Release flink-connector-kafka v5.0.0, release candidate #1 Ferenc Csaky
• 2026/05/20 Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger Martijn Visser
• 2026/05/20 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Márton Balassi
• 2026/05/20 Re: Java 25 Support Sergey Nuyanzin
• 2026/05/20 Re: Java 25 Support Sergey Nuyanzin
• 2026/05/20 Re: Java 25 Support Martijn Visser
• 2026/05/20 回复：[DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger rocxing
• 2026/05/20 Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
• 2026/05/20 Re: [VOTE] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Roman Khachatryan
• 2026/05/20 Re: [DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer zihao chen
• 2026/05/20 [jira] [Created] (FLINK-39719) TemporalRowTimeJoinOperator produces wrong results for late probe-side records Fabian Hueske (Jira)
• 2026/05/20 [jira] [Created] (FLINK-39718) [pipeline][paimon] Paimon sink fails with distributed source when target table does not exist Ran Tao (Jira)
• 2026/05/20 Re: Re: Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
• 2026/05/20 Flink CEP: can CEP reliably implement "condition true for T minutes" ? rohit patil
• 2026/05/20 [jira] [Created] (FLINK-39717) Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE Ramin Gharib (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39716) ES timeout related config used the wrong time unit reswqa (Jira)
• 2026/05/19 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• 2026/05/19 [SUMMARY] Release 2.3 sync Hao Li
• 2026/05/19 [jira] [Created] (FLINK-39715) [Table/Planner] IndexOutOfBoundsException in FlinkExpandConversionRule for ORDER BY followed by global aggregate in batch mode Yaoxuan Wu (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39714) Backport AGENTS.md to active branches 1.20, 2.0, and 2.2 Mingliang Liu (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39713) flink-kubernetes-operator: Bump log4j, jackson, and Beam to retire CVEs Purushottam Sinha (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Aleksandr Savonin (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39711) Allow setting maxExceptions on JobExceptionsMessageParameters / ApplicationExceptionsMessageParameters Aleksandr Savonin (Jira)
• 2026/05/19 Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Rahul Bhattacharya
• 2026/05/19 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Zakelly Lan
• 2026/05/19 [jira] [Created] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39709) Update documentation for native-s3-fs Samrat Deb (Jira)
• 2026/05/19 Re: [DISCUSS] FLIP-XXX: Support Pluggable Storage Backend for HistoryServer zihao chen
• 2026/05/19 Re: Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger zihao chen
• 2026/05/19 [jira] [Created] (FLINK-39708) Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics Gustavo de Morais (Jira)
• 2026/05/19 [jira] [Created] (FLINK-39707) Update Flink Connector OpenSearch to Flink Connector Parent POM 2.0 Mukul Gupta (Jira)
• 2026/05/19 State TTL support gap in DataStream API V2 (FLINK-34547) khertz11
• 2026/05/19 Re:[DISCUSS] FLIP-XXX: Introduce Lazy Loading for HistoryServer 魏祚

• Earlier messages
• Later messages