Messages by Date
-
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
-
2026/04/29
[jira] [Created] (FLINK-39573) Build documentation CI workflow fails with startup_failure due to burnett01/rsync-deployments action not allowed
yuan (Jira)
-
2026/04/29
[jira] [Created] (FLINK-39571) Improve Flink Kubernetes Operator documentation coverage
Dennis-Mircea Ciupitu (Jira)
-
2026/04/29
[jira] [Created] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed
Biao Geng (Jira)
-
2026/04/29
[jira] [Created] (FLINK-39570) Update Flink Shaded dependencies
Mate Czagany (Jira)
-
2026/04/29
[jira] [Created] (FLINK-39568) Decouple YAML built-in AI Function and model providers
Xiqian Yu (Jira)
-
2026/04/29
[jira] [Created] (FLINK-39569) YAML pipeline supports HLS live-streaming video source
Xiqian Yu (Jira)
-
2026/04/28
[jira] [Created] (FLINK-39567) Add blob support in Paimon pipeline sink
Yanquan Lv (Jira)
-
2026/04/28
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Weiqing Yang
-
2026/04/28
Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
Guowei Ma
-
2026/04/28
Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
Dian Fu
-
2026/04/28
[jira] [Created] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view
Purushottam Sinha (Jira)
-
2026/04/28
[jira] [Created] (FLINK-39565) Eliminate maven build warnings across all modules
Dennis-Mircea Ciupitu (Jira)
-
2026/04/28
[jira] [Created] (FLINK-39564) Make ScalingRealizer overrides idempotent
Dennis-Mircea Ciupitu (Jira)
-
2026/04/28
[jira] [Created] (FLINK-39563) upgrade paimon to 1.4.1
peiyu (Jira)
-
2026/04/28
[jira] [Created] (FLINK-39562) Upgrade Netty to 4.2.12.Final
Mate Czagany (Jira)
-
2026/04/28
Re: [VOTE] Release 2.0.2, release candidate #4
Mate Czagany
-
2026/04/28
RE: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
David Radley
-
2026/04/28
[VOTE] Release 2.0.2, release candidate #4
Sergey Nuyanzin
-
2026/04/28
[jira] [Created] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys
Gabor Somogyi (Jira)
-
2026/04/28
[jira] [Created] (FLINK-39560) [PROPOSAL] Allow custom, pre-configured AWS S3 clients to be injected into new Native S3 filesystem
Badma Ochirov (Jira)
-
2026/04/28
Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
Leonard Xu
-
2026/04/28
Re: [VOTE] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler
Peter Huang
-
2026/04/28
Re: Flink Kubernetes Operator 1.15.0 release planning
Peter Huang
-
2026/04/28
[jira] [Created] (FLINK-39559) SessionReconciler.recoverSession() creates JobManager Deployment without ownerReferences, causing unrecoverable MISSING / AlreadyExists loop
Krzysztof Palka (Jira)
-
2026/04/28
Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
Gustavo de Morais
-
2026/04/28
Re: Flink Kubernetes Operator 1.15.0 release planning
Ferenc Csaky
-
2026/04/28
Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
zl z
-
2026/04/28
Re: [DISCUSS] FLIP-545: Hardening the Event Reporter with an Asynchronous Core
Kartikey Pant
-
2026/04/28
Re: [DISCUSS] FLIP-XXX: Enhancing HistoryServer with Lazy Loading and Pluggable Storage
zihao chen
-
2026/04/27
Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
Robert Metzger
-
2026/04/27
Re: Flink Kubernetes Operator 1.15.0 release planning
Gabor Somogyi
-
2026/04/27
Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI 
Soumitra Kumar
-
2026/04/27
[DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing
Guowei Ma
-
2026/04/27
Re: [QUESTION] How to enable Azure nightly jobs for 1.20?
Sergey Nuyanzin
-
2026/04/27
[VOTE] Release 2.2.1, release candidate #1
Sergey Nuyanzin
-
2026/04/27
[jira] [Created] (FLINK-39558) LogicalUnnestRule produces incorrect TableFunctionScan rowType, masking nullability and breaking LEFT JOIN UNNEST
Jim Hughes (Jira)
-
2026/04/27
[jira] [Created] (FLINK-39557) Invalid multi-release JAR for flink-shaded-jackson
Piotr Przybylski (Jira)
-
2026/04/27
[DISCUSS] Make file path optional in COMPILE PLAN
Luca Castelli via dev
-
2026/04/27
[jira] [Created] (FLINK-39556) Make file path optional in COMPILE PLAN to return plan inline as a result set
Luca Castelli (Jira)
-
2026/04/27
[DISCUSS] Hive 4 support for Flink Hive connector (FLINK-35515)
Lalwani, Jayesh
-
2026/04/27
Re: [DISCUSS] FLIP-XXX: Enhancing HistoryServer with Lazy Loading and Pluggable Storage
Jim Hughes via dev
-
2026/04/27
Flink Kubernetes Operator 1.15.0 release planning
Gyula Fóra
-
2026/04/27
Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause
Ryan van Huuksloot via dev
-
2026/04/27
[jira] [Created] (FLINK-39555) FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler
Dennis-Mircea Ciupitu (Jira)
-
2026/04/27
[jira] [Created] (FLINK-39554) Support multiple custom autoscaler evaluators with deterministic ordering
Dennis-Mircea Ciupitu (Jira)
-
2026/04/27
Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause
Timo Walther
-
2026/04/27
[jira] [Created] (FLINK-39553) Support OpenTelemetry metric reporter
Dennis-Mircea Ciupitu (Jira)
-
2026/04/26
Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI 
Zakelly Lan
-
2026/04/26
[jira] [Created] (FLINK-39552) Add native-s3-fs in DIRECTLY_SUPPORTED_FILESYSTEM
Samrat Deb (Jira)
-
2026/04/26
[jira] [Created] (FLINK-39551) Fix the styling of the ignored badge in the rescale history subpage
Chanhae Oh (Jira)
-
2026/04/26
Re: [DISCUSS] FLIP-XXX: Enhancing HistoryServer with Lazy Loading and Pluggable Storage
zihao chen
-
2026/04/26
[jira] [Created] (FLINK-39550) Fix the tab order on the job page
Chanhae Oh (Jira)
-
2026/04/26
[jira] [Created] (FLINK-39549) Compute OBSERVED_TPR for non-source vertices behind a feature flag for Operator Autoscaler
Dennis-Mircea Ciupitu (Jira)
-
2026/04/26
[jira] [Created] (FLINK-39548) CommonExecTableSourceScan uses physical row type instead of output type for upsert source key partitioning
JingWei Li (Jira)
-
2026/04/26
Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI 
Soumitra Kumar
-
2026/04/26
[jira] [Created] (FLINK-39547) User-provided Scala library breaks table-planner
Piotr Przybylski (Jira)
-
2026/04/25
[jira] [Created] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
-
2026/04/25
[jira] [Created] (FLINK-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
-
2026/04/25
[jira] [Created] (FLINK-39544) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
-
2026/04/25
[jira] [Created] (FLINK-39545) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
-
2026/04/25
[jira] [Created] (FLINK-39542) Upgrade to avro 1.11.5
Samrat Deb (Jira)
-
2026/04/25
Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI 
Zakelly Lan
-
2026/04/24
[jira] [Created] (FLINK-39541) Improve operator metrics documentation and bundle additional metric reporters
Dennis-Mircea Ciupitu (Jira)
-
2026/04/24
[jira] [Created] (FLINK-39540) Kinesis Connector - EFO Issue when resharding - IllegalArgumentException
Ryan Pelaez (Jira)
-
2026/04/24
Re: [DISCUSS] FLIP: Streaming-native AI Inference Runtime for Flink
FeatZhang
-
2026/04/24
[jira] [Created] (FLINK-39539) Extend planner's Agents.md with more detailed information for our internal table module CDC processing
Gustavo de Morais (Jira)
-
2026/04/24
[jira] [Created] (FLINK-39537) Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG
Ramin Gharib (Jira)
-
2026/04/24
[jira] [Created] (FLINK-39538) Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG
Ramin Gharib (Jira)
-
2026/04/24
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Yanquan Lv
-
2026/04/24
[DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause
FeatZhang
-
2026/04/24
Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool
Aleksandr Savonin
-
2026/04/24
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Aleksandr Savonin
-
2026/04/24
[jira] [Created] (FLINK-39536) HTTP Connector Deprecated method HttpSinkWriter
David Radley (Jira)
-
2026/04/24
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Sergey Nuyanzin
-
2026/04/24
[jira] [Created] (FLINK-39535) Improve Unit Test & coverage
Samrat Deb (Jira)
-
2026/04/24
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Yuepeng Pan
-
2026/04/23
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Jark Wu
-
2026/04/23
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Hang Ruan
-
2026/04/23
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Sharath
-
2026/04/23
Re: Help Needed - About 2.3 Release: S3 Missing flink‑2.4‑SNAPSHOT Binaries Causing flink-docker CI Failure
Yuepeng Pan
-
2026/04/23
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
吴晓军
-
2026/04/23
[jira] [Created] (FLINK-39534) Upgrade pemja to 0.5.7
Wenjin Xie (Jira)
-
2026/04/23
Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang
Swapnal Varma
-
2026/04/23
Re: Help Needed - About 2.3 Release: S3 Missing flink‑2.4‑SNAPSHOT Binaries Causing flink-docker CI Failure
Sergey Nuyanzin
-
2026/04/23
Re: [Discuss] FLIP-314: Behavioral Expectation of JobStatusChangedListener Instantiation in Application Mode
Swapna Marru
-
2026/04/23
[DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric
Dennis-Mircea Ciupitu
-
2026/04/23
Re: [VOTE] Release 1.20.4, release candidate #1
Martijn Visser
-
2026/04/23
Re: [VOTE] Release 2.1.2, release candidate #1
Martijn Visser
-
2026/04/23
Jira Account Request
Han Li