dev

Messages by Date

2026/05/08 Re: [VOTE] Release 2.1.2, release candidate #2 Yuepeng Pan
2026/05/08 Re: [VOTE] Release 2.0.2, release candidate #4 Yuepeng Pan
2026/05/08 Re: [VOTE] Release 2.1.2, release candidate #2 Yuepeng Pan
2026/05/08 Re: [VOTE] Release 2.2.1, release candidate #3 Yuepeng Pan
2026/05/08 [jira] [Created] (FLINK-39638) Make codegen reuse result of JSON parse in JSON_VALUE, JSON_QUERY Sergey Nuyanzin (Jira)
2026/05/08 [jira] [Created] (FLINK-39637) Filter push-down for the savepoint table connector Ilya Soin (Jira)
2026/05/08 Re: [VOTE] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Yuepeng Pan
2026/05/08 [jira] [Created] (FLINK-39636) Add "produces_full_deletes" parameter in TO_CHANGELOG Gustavo de Morais (Jira)
2026/05/08 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Dennis-Mircea Ciupitu
2026/05/08 Re: [VOTE] Release 2.0.2, release candidate #4 Timo Walther
2026/05/08 Re: [VOTE] Release 2.1.2, release candidate #2 Timo Walther
2026/05/08 Re: [VOTE] Release 2.2.1, release candidate #3 Timo Walther
2026/05/08 [jira] [Created] (FLINK-39635) [security] Support comma-separated list in security.ssl.protocol Imre Balassa (Jira)
2026/05/08 [jira] [Created] (FLINK-39634) Savepoint Table API connector incorrectly infers map state key type Ilya Soin (Jira)
2026/05/08 Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger zihao chen
2026/05/08 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Gyula Fóra
2026/05/08 Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
2026/05/08 [jira] [Created] (FLINK-39633) PostgreSQL CDC backfill throws NullPointerException when WAL stream carries records for other captured tables Di Wu (Jira)
2026/05/07 [jira] [Created] (FLINK-39632) Add fromChangelog() / toChangelog() convenience methods to PartitionedTable Ramin Gharib (Jira)
2026/05/07 Re:Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing zhangjiaogg
2026/05/07 Re: [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger Feng Jin
2026/05/07 [jira] [Created] (FLINK-39631) Integrate GPU sidecar inference with Table/SQL and provide end-to-end example featzhang (Jira)
2026/05/07 [jira] [Created] (FLINK-39628) Implement asynchronous batched inference RPC in GPU sidecar featzhang (Jira)
2026/05/07 [jira] [Created] (FLINK-39625) Support GPU-based model inference via sidecar/actor pattern featzhang (Jira)
2026/05/07 [jira] [Created] (FLINK-39627) Introduce flink-gpu-sidecar module with service skeleton featzhang (Jira)
2026/05/07 [jira] [Created] (FLINK-39626) Extend ResourceProfile to declare GPU resources on TaskManager featzhang (Jira)
2026/05/07 [jira] [Created] (FLINK-39629) Add Async I/O operator that invokes GPU sidecar from DataStream API featzhang (Jira)
2026/05/07 [jira] [Created] (FLINK-39630) Schedule GPU-affinity operators via ResourceManager featzhang (Jira)
2026/05/07 [jira] [Created] (FLINK-39624) `TtlListState.asyncGet()` returns a non-null wrapper around a null inner iterator, causing NPE in `onNext`/`isEmpty` when the state is empty Jira
2026/05/07 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Prashant Bhardwaj
2026/05/07 [jira] [Created] (FLINK-39623) Strict UTF-8 validation in CAST(BYTES AS STRING) Gustavo de Morais (Jira)
2026/05/07 [jira] [Created] (FLINK-39622) [postgres] CustomPostgresSchema re-reads JDBC metadata for every split, causing O(N²) snapshot startup Jira
2026/05/07 Re: Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
2026/05/07 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Austin Cawley-Edwards
2026/05/07 RE: [ANNOUNCE] New Apache Flink PMC Member – David Anderson David Radley
2026/05/07 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Purushottam Sinha via dev
2026/05/07 Re:Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Xuyang
2026/05/07 [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #2 Gyula Fóra
2026/05/07 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Gustavo de Morais
2026/05/07 退订 [email protected]
2026/05/06 Re: [ANNOUNCE] Apache Flink 1.20.4 released Ramin Gharib
2026/05/06 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Hang Ruan
2026/05/06 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Sergey Nuyanzin
2026/05/06 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Gyula Fóra
2026/05/06 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing zihao chen
2026/05/06 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing 熊饶饶
2026/05/06 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yong Fang
2026/05/06 [jira] [Created] (FLINK-39621) Incremental-snapshot based sources may get stuck in binlog-backfill stage Xiqian Yu (Jira)
2026/05/06 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Leonard Xu
2026/05/06 [jira] [Created] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner haiqingchen (Jira)
2026/05/06 Re: [SUMMARY] Release 2.3 sync, blocked on cross-team testing Yuepeng Pan
2026/05/06 RE: [ANNOUNCE] Apache Flink 1.20.4 released wenjin
2026/05/06 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Yuepeng Pan
2026/05/06 Re: [FLINK-30514] Review request for HybridSourceReader bug fix Leonard Xu
2026/05/06 [jira] [Created] (FLINK-39619) Add release note for flink 2.3 release Hao Li (Jira)
2026/05/06 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Dennis-Mircea Ciupitu
2026/05/06 [jira] [Created] (FLINK-39618) FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options Dennis-Mircea Ciupitu (Jira)
2026/05/06 Re: [ANNOUNCE] Apache Flink 1.20.4 released Peter Huang
2026/05/06 Re: [ANNOUNCE] Apache Flink 1.20.4 released Efrat Levitan
2026/05/06 [jira] [Created] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices Herbert Wang (Jira)
2026/05/06 Re: [VOTE] Release 2.2.1, release candidate #3 Fabian Hueske
2026/05/06 Re: [VOTE] Release 2.1.2, release candidate #2 Fabian Hueske
2026/05/06 Re: [VOTE] Release 2.0.2, release candidate #4 Fabian Hueske
2026/05/06 [FLINK-30514] Review request for HybridSourceReader bug fix yun . er . run
2026/05/06 [jira] [Created] (FLINK-39616) Add instructions on how to fix ordering with ORDER BY when using FROM_CHANGELOG Gustavo de Morais (Jira)
2026/05/06 [jira] [Created] (FLINK-39615) Translate documentation in changelog.md to chinese Gustavo de Morais (Jira)
2026/05/06 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Ryan van Huuksloot via dev
2026/05/06 [jira] [Created] (FLINK-39614) Support TO_CHANGELOG: retract stream -> retract stream with set semantics Gustavo de Morais (Jira)
2026/05/06 Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Rion Williams
2026/05/06 Re: Hackathon at Community Over Code Glasgow — is Flink interested? Ramin Gharib
2026/05/06 [ANNOUNCE] New Apache Flink PMC Member – David Anderson Timo Walther
2026/05/06 Re: [ANNOUNCE] Apache Flink 1.20.4 released Gustavo de Morais
2026/05/06 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing FeatZhang
2026/05/06 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Márton Balassi
2026/05/06 [ANNOUNCE] Apache Flink 1.20.4 released Sergey Nuyanzin
2026/05/06 Re: [DISCUSS] Request for help with publishing docker images Sergey Nuyanzin
2026/05/06 Re:Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Xuyang
2026/05/06 Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Hongshun Wang
2026/05/06 Re: [DISCUSS] FLIP-XXX: Filter-Aware Source Reuse in Table Planner Hongshun Wang
2026/05/06 Re: [SUMMARY] Release 2.3 sync, blocked on cross-team testing Xiqian YU
2026/05/05 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
2026/05/05 [jira] [Created] (FLINK-39613) Flink pipeline cdc primary-keys / partition-keys cannot resolve backtick-quoted identifiers that are used as projection aliases Ran Tao (Jira)
2026/05/05 [jira] [Created] (FLINK-39612) [Model] Add HTTP connection pool management for Triton inference featzhang (Jira)
2026/05/05 [jira] [Created] (FLINK-39611) [Model] Add sequence ID auto-increment support for Triton inference featzhang (Jira)
2026/05/05 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gen Luo
2026/05/05 [jira] [Created] (FLINK-39610) Mongo CDC connector supports specifying SSL context Xiqian Yu (Jira)
2026/05/05 Re: [SUMMARY] Release 2.3 sync, blocked on cross-team testing Hao Li
2026/05/05 [SUMMARY] Release 2.3 sync, blocked on cross-team testing David Anderson
2026/05/05 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Leonard Xu
2026/05/05 Re: [DISCUSS] Compress file benchmark regression resolution for Flink 2.3 release Yuepeng Pan
2026/05/05 [jira] [Created] (FLINK-39609) update Dynamic Kafka Source doc with new python/sql examples and other improvement details Bowen Li (Jira)
2026/05/05 Hackathon at Community Over Code Glasgow — is Flink interested? Rich Bowen
2026/05/05 [jira] [Created] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage Swapna Marru (Jira)
2026/05/05 [jira] [Created] (FLINK-39607) Add right Nullable annotation and precondition for config Samrat Deb (Jira)
2026/05/05 [DISCUSS] Release flink-connector-pulsar for Flink 1.20 Ferenc Csaky
2026/05/05 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Gyula Fóra
2026/05/05 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Roman Khachatryan
2026/05/05 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing FeatZhang
2026/05/05 Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Roman Khachatryan
2026/05/05 [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
2026/05/05 [jira] [Created] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses Ramin Gharib (Jira)
2026/05/05 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Sergey Nuyanzin
2026/05/05 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Gustavo de Morais
2026/05/04 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Efrat Levitan
2026/05/04 [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
2026/05/04 [jira] [Created] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization Swapna Marru (Jira)
2026/05/04 [DISCUSS] Request for help with publishing docker images Sergey Nuyanzin
2026/05/04 [jira] [Created] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields Natea Eshetu Beshada (Jira)
2026/05/04 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
2026/05/04 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Ryan van Huuksloot via dev
2026/05/04 [jira] [Created] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS Samrat Deb (Jira)
2026/05/04 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
2026/05/04 Re: Flink Kubernetes Operator 1.15.0 release planning Gyula Fóra
2026/05/04 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Gabor Somogyi
2026/05/04 [jira] [Created] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions Gustavo de Morais (Jira)
2026/05/04 [jira] [Created] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API Gustavo de Morais (Jira)
2026/05/04 [jira] [Created] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
2026/05/04 [DISCUSS] FLINK-25672: FileSource enumerator remembers paths of all already processed files Sophia Izokun via dev
2026/05/04 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Rion Williams
2026/05/04 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Farooq Qaiser via dev
2026/05/04 Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Ryan van Huuksloot via dev
2026/05/04 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Piotr Nowojski
2026/05/04 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gen Luo
2026/05/04 Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Rui Fan
2026/05/04 Re: Flink Kubernetes Operator 1.15.0 release planning Ryan van Huuksloot via dev
2026/05/04 Re: [VOTE] Release 1.20.4, release candidate #1 Rui Fan
2026/05/04 Re: [VOTE] Release 2.1.2, release candidate #2 Ramin Gharib
2026/05/04 Re: [VOTE] Release 2.2.1, release candidate #3 Ramin Gharib
2026/05/04 Re: [VOTE] Release 2.1.2, release candidate #2 Gustavo de Morais
2026/05/04 Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Aleksandr Savonin
2026/05/04 [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
2026/05/04 Re: [VOTE] Release 2.2.1, release candidate #3 Gustavo de Morais
2026/05/04 [RESULT] [VOTE] Release 1.20.4, release candidate #1 Sergey Nuyanzin
2026/05/04 Re: [VOTE] Release 1.20.4, release candidate #1 Sergey Nuyanzin
2026/05/04 [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Gyula Fóra
2026/05/03 [jira] [Created] (FLINK-39599) Expose pendingRecords metrics in FLINK Kinesis Connector David (Jira)
2026/05/03 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Jark Wu
2026/05/03 [jira] [Created] (FLINK-39598) Update jline to 3.30.9 Sergey Nuyanzin (Jira)
2026/05/03 [VOTE] Release 2.1.2, release candidate #2 Sergey Nuyanzin
2026/05/03 [jira] [Created] (FLINK-39597) Make consumer-group as required field for connector Samrat Deb (Jira)
2026/05/03 Re: [VOTE] Release 2.1.2, release candidate #1 Sergey Nuyanzin
2026/05/03 Re: [VOTE] Release 2.1.2, release candidate #1 Sergey Nuyanzin
2026/05/03 [jira] [Created] (FLINK-39596) Watermark Strategy for redis-stream source Samrat Deb (Jira)
2026/05/03 [VOTE] Release 2.2.1, release candidate #3 Sergey Nuyanzin
2026/05/03 Re: [VOTE] Release 1.20.4, release candidate #1 Ferenc Csaky
2026/05/03 [jira] [Created] (FLINK-39595) Use GHA cache per branch Sergey Nuyanzin (Jira)
2026/05/03 [jira] [Created] (FLINK-39594) Add MetricGroup support for redis-streams source Samrat Deb (Jira)
2026/05/03 [jira] [Created] (FLINK-39593) Structurally use FetchManager for source Samrat Deb (Jira)
2026/05/03 [jira] [Created] (FLINK-39592) Optimize connection to redis cluster Samrat Deb (Jira)
2026/05/03 [jira] [Created] (FLINK-39591) Bump actions v4 to v5 Sergey Nuyanzin (Jira)
2026/05/03 Re: [VOTE] Release 2.2.1, release candidate #2 Sergey Nuyanzin
2026/05/03 Re: [VOTE] Release 1.20.4, release candidate #1 Sergey Nuyanzin
2026/05/02 Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI Soumitra Kumar
2026/05/02 [DISCUSS] FLIP-XXX: Top-N Job Health Dashboard in the Web UI FeatZhang
2026/05/01 Re: [DISCUSS] Compress file benchmark regression resolution for Flink 2.3 release Zakelly Lan
2026/05/01 [jira] [Created] (FLINK-39590) Connection catalog manager changes Hao Li (Jira)
2026/05/01 [jira] [Created] (FLINK-39589) Window TVF aggregation emits incorrect results with RocksDB state backend Kanchi Masalia (Jira)
2026/05/01 Re: [DISCUSS] Compress file benchmark regression resolution for Flink 2.3 release Hao Li
2026/05/01 [jira] [Created] (FLINK-39588) Migrate the DataGen table connector off deprecated source APIs Dennis-Mircea Ciupitu (Jira)
2026/05/01 Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause Robin Moffatt via dev
2026/05/01 [jira] [Created] (FLINK-39587) [Web dashboard] Prettier rules not enforced in CI; cache hides drift Purushottam Sinha (Jira)
2026/05/01 Re: [VOTE] Release 2.2.1, release candidate #2 Gustavo de Morais
2026/05/01 Re: [VOTE] Release 2.2.1, release candidate #2 Gustavo de Morais
2026/04/30 [jira] [Created] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Chen Zhang (Jira)
2026/04/30 [DISCUSS] Add a parser-aware SQL script splitting endpoint to the REST SQL Gateway Ryan van Huuksloot via dev
2026/04/30 [DISCUSS] Extension to Flip 528 - Support COMPILE PLAN '/p' FOR EXECUTE syntax Ryan van Huuksloot via dev
2026/04/30 Re: [VOTE] Release 2.2.1, release candidate #2 Piotr Przybylski
2026/04/30 [jira] [Created] (FLINK-39585) Log AdaptiveScheduler ExecutionGraph creation failures at ERROR Herbert Wang (Jira)
2026/04/30 [DISCUSS] FLIP-XXX: Filter-Aware Source Reuse in Table Planner Daniel Rossos via dev
2026/04/30 [jira] [Created] (FLINK-39584) Expand filter-merging for source-reuse Daniel Rossos (Jira)
2026/04/30 [jira] [Created] (FLINK-39583) Normalize Calcite correl variables to make subplan reuse by digest more effective Ferenc Csaky (Jira)
2026/04/30 Re: [DISCUSS] Compress file benchmark regression resolution for Flink 2.3 release Piotr Nowojski
2026/04/30 Re: [VOTE] Release 2.0.2, release candidate #4 Gustavo de Morais
2026/04/30 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
2026/04/30 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Zhu Zhu
2026/04/30 Re: [VOTE] Release 1.20.4, release candidate #1 Pedro Mázala
2026/04/30 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Martijn Visser
2026/04/30 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gustavo de Morais
2026/04/30 RE: [VOTE] Release 2.2.1, release candidate #2 wenjin
2026/04/30 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
2026/04/29 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
2026/04/29 Re: 退订 Xiaogang Zhou
2026/04/29 Re: [DISCUSS] FLIP-XXX: Enhancing HistoryServer with Lazy Loading and Pluggable Storage zihao chen
2026/04/29 [jira] [Created] (FLINK-39582) [cdc-connector][postgres] Support emitting pg_logical_emit_message records to deserialization Jira
2026/04/29 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yaroslav Tkachenko
2026/04/29 [DISCUSS] Compress file benchmark regression resolution for Flink 2.3 release Hao Li
2026/04/29 [jira] [Created] (FLINK-39581) Document the available config params in a single place for s3 native connector Gabor Somogyi (Jira)
2026/04/29 [jira] [Created] (FLINK-39580) Bump Flink-controlled Java dependencies to resolve CVEs (log4j, jackson, assertj, netty) Purushottam Sinha (Jira)
2026/04/29 [jira] [Created] (FLINK-39579) Fix s3.sse.kms.encryption-context config in native s3 connector Gabor Somogyi (Jira)
2026/04/29 [VOTE] Release 2.2.1, release candidate #2 Sergey Nuyanzin
2026/04/29 Re: [DISCUSS] Planning Flink CDC 3.7 release Leonard Xu
2026/04/29 [jira] [Created] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy Florian Vazelle (Jira)
2026/04/29 [jira] [Created] (FLINK-39577) Reuse Calcite's COALESCE to apply simplifications from RexSimplify Sergey Nuyanzin (Jira)
2026/04/29 [FLINK-31942] Looking for review — Conditional Writes in DynamoDB connector Tomasz Kaczmarek
2026/04/29 [DISCUSS] Planning Flink CDC 3.7 release Xiqian YU
2026/04/29 [jira] [Created] (FLINK-39576) Add new PTF StaticArgumentTrait#NO_PASS_THROUGH Gustavo de Morais (Jira)
2026/04/29 [jira] [Created] (FLINK-39575) Fix output rowtype in StreamPhysicalProcessTableFunction.toUdfCall when table arg is not first Gustavo de Morais (Jira)
2026/04/29 [jira] [Created] (FLINK-39574) Support TO_CHANGELOG retract stream to retract stream with set semantics Gustavo de Morais (Jira)
2026/04/29 Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
2026/04/29 Re: [VOTE] Release 2.2.1, release candidate #1 Sergey Nuyanzin