dev

Messages by Date

2026/08/02 [jira] [Created] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Qilong Wang (Jira)
2026/08/02 [jira] [Created] (FLINK-40300) PyFlink Table API lit does not convert Python values to the required Java literal types Liu Liu (Jira)
2026/08/02 [jira] [Created] (FLINK-40299) Add end-to-end state migration tests for RowData schema evolution Weiqing Yang (Jira)
2026/08/02 [jira] [Created] (FLINK-40298) Opt-in name-based state schema evolution for RowData Weiqing Yang (Jira)
2026/08/02 [jira] [Created] (FLINK-40297) Route TTL-aware value migration through the TypeSerializerSnapshot migrate hook Weiqing Yang (Jira)
2026/08/02 [jira] [Created] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot Weiqing Yang (Jira)
2026/08/02 [jira] [Created] (FLINK-40295) Document UDF metrics Weiqing Yang (Jira)
2026/08/02 [jira] [Created] (FLINK-40294) Instrument async scalar and table UDF calls with metrics Weiqing Yang (Jira)
2026/08/02 [jira] [Created] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Weiqing Yang (Jira)
2026/08/02 [jira] [Created] (FLINK-40292) Add UdfMetrics helper for UDF metrics Weiqing Yang (Jira)
2026/08/02 Re: [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/02 [jira] [Created] (FLINK-40291) instrumentation scope in otel metric adaptor is wrongly hardcoded Kaiqi Dong (Jira)
2026/08/02 [jira] [Created] (FLINK-40290) Histogram summary emits duplicate quantile 1.0 Kaiqi Dong (Jira)
2026/08/02 [jira] [Created] (FLINK-40289) Window Top-N examples are not reproducible in streaming mode Hancheng Deng (Jira)
2026/08/02 Re: [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator P Sinha
2026/08/02 [jira] [Created] (FLINK-40288) Multiple JoinSemanticTests fail Sergey Nuyanzin (Jira)
2026/08/01 Confluence Wiki Access Request - vaquarkhan1 vaquar khan
2026/08/01 [jira] [Created] (FLINK-40287) Provide a first-party, governed MCP server for Apache Flink vaquar khan (Jira)
2026/08/01 Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Vaquar khan
2026/08/01 [RESULT][VOTE] FLIP-485: Add UDF Metrics Weiqing Yang
2026/08/01 Re: [VOTE] FLIP-485: Add UDF Metrics Weiqing Yang
2026/08/01 [jira] [Created] (FLINK-40286) Adapt keyless upsert sink should fall back to retract to MiscSemanticTests Sergey Nuyanzin (Jira)
2026/08/01 [jira] [Created] (FLINK-40285) MLPredictSemanticTests fails because of ON CONFLICT Sergey Nuyanzin (Jira)
2026/08/01 [jira] [Created] (FLINK-40284) A number of tests ending with Tests in class name are skipped from CI/local tests Sergey Nuyanzin (Jira)
2026/08/01 [jira] [Created] (FLINK-40283) CorrelateITCase2 is not executed while running tests locally or via CI Sergey Nuyanzin (Jira)
2026/08/01 [jira] [Created] (FLINK-40282) Expand and correct the concepts Glossary Lorenzo Nicora (Jira)
2026/08/01 [jira] [Created] (FLINK-40281) Improve HTTP sink failure observability Bharath Reddy Gunapati (Jira)
2026/08/01 [jira] [Created] (FLINK-40279) Add HTTP sink parity for OIDC, proxy, and HTTP version configuration Bharath Reddy Gunapati (Jira)
2026/08/01 [jira] [Created] (FLINK-40280) Document HTTP sink retry, error handling, and configuration parity Bharath Reddy Gunapati (Jira)
2026/08/01 [jira] [Created] (FLINK-40278) Define and implement HTTP sink batch retry semantics Bharath Reddy Gunapati (Jira)
2026/08/01 [jira] [Created] (FLINK-40277) Add HTTP sink response classification and retry support Bharath Reddy Gunapati (Jira)
2026/08/01 [jira] [Created] (FLINK-40276) Add HTTP sink response classification and retry support Bharath Reddy Gunapati (Jira)
2026/08/01 [jira] [Created] (FLINK-40275) Improve HTTP sink parity with HTTP lookup source Bharath Reddy Gunapati (Jira)
2026/08/01 [DISCUSS] FLINK-39566: Checkpoint duration timeline view in the Web UI P Sinha
2026/08/01 Re: [VOTE] FLIP-485: Add UDF Metrics P Sinha
2026/08/01 [jira] [Created] (FLINK-40274) Flink CDC Remove unsupported kubernetes-session from target option help message jaejun lee (Jira)
2026/07/31 [jira] [Created] (FLINK-40273) JDBC docs: update for the 4.x module split and Sink V2 API Purushottam Sinha (Jira)
2026/07/31 [jira] [Created] (FLINK-40272) Add cache file for checkstyle Sergey Nuyanzin (Jira)
2026/07/31 Re: [VOTE] FLIP-485: Add UDF Metrics Peter Huang
2026/07/31 Re: [VOTE] FLIP-485: Add UDF Metrics Yuepeng Pan
2026/07/31 [jira] [Created] (FLINK-40271) Group window properties produce invalid SQL in QueryOperation#asSerializableString Timo Theusner (Jira)
2026/07/31 [jira] [Created] (FLINK-40270) Make source fetcher and coordinator threads job-attributable (MDC + thread names) Aleksandr Savonin (Jira)
2026/07/31 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gustavo de Morais
2026/07/31 Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Dennis-Mircea Ciupitu
2026/07/30 Re:[VOTE] FLIP-485: Add UDF Metrics Xuyang
2026/07/30 Re: Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
2026/07/30 [jira] [Created] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream Rui Fan (Jira)
2026/07/30 [jira] [Created] (FLINK-40268) Add new JSON_TYPE built-in function Gustavo de Morais (Jira)
2026/07/30 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
2026/07/30 [jira] [Created] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER Arvid Heise (Jira)
2026/07/30 Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Francis Altomare
2026/07/30 [jira] [Created] (FLINK-40266) MAX_WATERMARK might not be emitted for finished operators Roman Khachatryan (Jira)
2026/07/30 Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Gyula Fóra
2026/07/30 [jira] [Created] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters Shuo Cheng (Jira)
2026/07/30 FLINK-39900 - Change in review Francis Altomare
2026/07/29 [jira] [Created] (FLINK-40264) nested legacyTimestampMapping Pritam Kumar (Jira)
2026/07/29 [jira] [Created] (FLINK-40263) Enum symbol validation Pritam Kumar (Jira)
2026/07/29 [jira] [Created] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters Pritam Kumar (Jira)
2026/07/29 [jira] [Created] (FLINK-40261) Support Set semantics, pass-through columns and ROW Value State for Python PTF Wang Chengyu (Jira)
2026/07/29 [jira] [Created] (FLINK-40260) Support Python PTF definition API and the stateless runtime path Wang Chengyu (Jira)
2026/07/29 [jira] [Created] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
2026/07/29 [jira] [Created] (FLINK-40258) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
2026/07/29 [jira] [Created] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
2026/07/29 [jira] [Created] (FLINK-40256) Docs: config options in sub-packages are silently missing from the configuration reference Purushottam Sinha (Jira)
2026/07/29 [DISCUSS] FLIP-603: [FileSystems] GCS SDK-native filesystem Samrat Deb
2026/07/29 [jira] [Created] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type Ramin Gharib (Jira)
2026/07/29 Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
2026/07/29 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
2026/07/29 Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
2026/07/29 [jira] [Created] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint Aleksandr Savonin (Jira)
2026/07/28 [jira] [Created] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file wenhao.yu (Jira)
2026/07/28 [jira] [Created] (FLINK-40252) Graceful TaskManager termination on Kubernetes Gangadharayya Hiremath (Jira)
2026/07/28 [jira] [Created] (FLINK-40251) Support Process Table Function (PTF) in Python Table API Wang Chengyu (Jira)
2026/07/28 [jira] [Created] (FLINK-40250) Non-comparable types in ORDER BY / GROUP BY throw UnsupportedOperationException instead of a clean ValidationException Gustavo de Morais (Jira)
2026/07/28 [jira] [Created] (FLINK-40249) JDBC Connector: Bump Flink, PostgreSQL driver, and other dependency versions Purushottam Sinha (Jira)
2026/07/28 [jira] [Created] (FLINK-40248) Move publishing nightly snapshots from AZP to GHA Dale Lane (Jira)
2026/07/28 [jira] [Created] (FLINK-40247) Umbrella: FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh (Jira)
2026/07/28 [jira] [Created] (FLINK-40246) flink-kubernetes-operator bundles vulnerable logback-core 1.2.13 (CVE-2024-12798, CVE-2025-11226, CVE-2026-1225) Yishai Greenberg (Jira)
2026/07/28 [jira] [Created] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder Nikita Singhvi (Jira)
2026/07/28 [jira] [Created] (FLINK-40244) Support YashanDB in flink-connector-jdbc Linsert (Jira)
2026/07/28 Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/28 [RESULT][VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/27 [jira] [Created] (FLINK-40243) Bump postgresql jdbc driver from 42.5.6 to 42.7.13 Siddharth R (Jira)
2026/07/27 [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/07/27 [jira] [Created] (FLINK-40242) Support filtered pagination splits using a supporting index for efficient queries Michael (Jira)
2026/07/27 [jira] [Created] (FLINK-40241) Support VARIANT as column type in the 'raw' format Ramin Gharib (Jira)
2026/07/26 [jira] [Created] (FLINK-40240) Support additional Flink SQL regular expression functions in YAML Transform Mao Jiayi (Jira)
2026/07/26 [jira] [Created] (FLINK-40239) Support additional Flink SQL regular expression functions in YAML Transform Mao Jiayi (Jira)
2026/07/26 Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
2026/07/26 [jira] [Created] (FLINK-40238) Expose numberOfConsecutiveFailedCheckpoints as a JobManager-level gauge Yang Li (Jira)
2026/07/26 Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Leonard Xu
2026/07/26 [VOTE] FLIP-485: Add UDF Metrics Weiqing Yang
2026/07/26 Re: Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
2026/07/25 [jira] [Created] (FLINK-40237) CepOperator does not clean up expired NFA state in processing-time timer callbacks YuXiang Zhou (Jira)
2026/07/25 Re: Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Wenhao Ji
2026/07/25 [ANNOUNCE] Apache Flink Agents 0.3.1 released wenjin
2026/07/24 [jira] [Created] (FLINK-40236) _infer_type infers ARRAY<NULL> for a list whose first element is None Nikolaus Schuetz (Jira)
2026/07/24 [RESULT][VOTE] FLIP-527: State Schema Evolution for RowData Weiqing Yang
2026/07/24 Re: [VOTE] FLIP-527: State Schema Evolution for RowData Weiqing Yang
2026/07/24 [jira] [Created] (FLINK-40235) FLIP-27 source subtask stalls the watermark after all its splits finish Jing Hung (Jira)
2026/07/24 Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Sergey Nuyanzin
2026/07/24 Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Sergey Nuyanzin
2026/07/24 Re: [VOTE] FLIP-527: State Schema Evolution for RowData Zakelly Lan
2026/07/24 Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
2026/07/24 [jira] [Created] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Keith Lee (Jira)
2026/07/24 [ANNOUNCE] Apache flink-connector-jdbc 3.4.0 & 4.1.0 released Yuepeng Pan
2026/07/24 [jira] [Created] (FLINK-40233) JSON functions return NULL when sharing a parsed input Gustavo de Morais (Jira)
2026/07/24 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
2026/07/24 [jira] [Created] (FLINK-40231) HistoryServerArchiveFetcherTest.testArchiveStateTransition is flaky in CI Sergey Nuyanzin (Jira)
2026/07/24 [jira] [Created] (FLINK-40232) NullPointerException in OutputConversionOperator.processElement when rowtime attribute is null Fan Deng (Jira)
2026/07/24 Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Yanquan Lv
2026/07/24 Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Rui Fan
2026/07/24 Re: [VOTE] FLIP-527: State Schema Evolution for RowData Leonard Xu
2026/07/24 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Sergey Nuyanzin
2026/07/24 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
2026/07/24 [jira] [Created] (FLINK-40230) StringToBinary and RawToBinary cast rules might generate runtime code with useless array copy Sergey Nuyanzin (Jira)
2026/07/24 [RESULT][VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 wenjin
2026/07/23 Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Zhu Zhu
2026/07/23 Re: Re: Re: [DISCUSS] Add UDF Metrics Yuepeng Pan
2026/07/23 Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Xintong Song
2026/07/23 Re:Re: Re: [DISCUSS] Add UDF Metrics Xuyang
2026/07/23 [jira] [Created] (FLINK-40229) Introduce HttpSinkConfig and wire core sink options via ReadableConfig Bharath Reddy Gunapati (Jira)
2026/07/23 [jira] [Created] (FLINK-40228) Bump frontend-maven-plugin to 2.0.1 Sergey Nuyanzin (Jira)
2026/07/23 [jira] [Created] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore Yuhan Hao (Jira)
2026/07/23 [jira] [Created] (FLINK-40226) Standalone session cluster JM recovery enters infinite MISSING loop and fails with HTTP 409 on TM Deployment when TaskManager pods still exist Aniruddh J (Jira)
2026/07/23 Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Tisya Bhatia via dev
2026/07/23 [jira] [Created] (FLINK-40225) JSON parsing for json functions accepts trailing content after the first value Gustavo de Morais (Jira)
2026/07/23 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gyula Fóra
2026/07/23 Re: Flink operator stuck with "Job not found" Gyula Fóra
2026/07/23 Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Timo Walther
2026/07/23 Flink operator stuck with "Job not found" Filippo Ghibellini
2026/07/23 [jira] [Created] (FLINK-40224) Move CI scripts used by both GHA and AZP out of tools/azure-pipelines Dale Lane (Jira)
2026/07/23 Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Yuepeng Pan
2026/07/23 Re: [DISCUSS] FLIP-XXX Monotonic Counters support Piotr Nowojski
2026/07/23 [jira] [Created] (FLINK-40223) Support additional Flink SQL string functions in YAML Transform Mao Jiayi (Jira)
2026/07/23 [jira] [Created] (FLINK-40222) ValueLiteralExpression.asSerializableString() drops leading-field precision for INTERVAL literals Timo Theusner (Jira)
2026/07/23 Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
2026/07/23 [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/22 Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Dian Fu
2026/07/22 Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
2026/07/22 RE: Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Wenhao Ji
2026/07/22 Re: [VOTE] FLIP-527: State Schema Evolution for RowData Shengkai Fang
2026/07/22 FLINK-38023: PR #28161 code review request Avi Sanwal
2026/07/22 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/22 [jira] [Created] (FLINK-40221) Update weekly.yml of jdbc connector for jdbc-3.4.0 and jdbc-4.1.0 Yuepeng Pan (Jira)
2026/07/22 [jira] [Created] (FLINK-40220) Update the version of JDBC connector docs Yuepeng Pan (Jira)
2026/07/22 Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Ferenc Csaky
2026/07/22 Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
2026/07/22 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
2026/07/22 [jira] [Created] (FLINK-40219) Incorrect output type of LateralSnapshotJoin for build-side time attribute with inconsistent nullability Fabian Hueske (Jira)
2026/07/22 [jira] [Created] (FLINK-40218) Allow building a Variant from a token source, without a String round-trip Ramin Gharib (Jira)
2026/07/22 Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Ferenc Csaky
2026/07/22 [jira] [Created] (FLINK-40217) Variant.toJson() can emit invalid JSON for numbers that overflow to non-finite doubles Ramin Gharib (Jira)
2026/07/22 [jira] [Created] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits kim (Jira)
2026/07/22 FLINK-37686: ForSt consecutive checkpoint failures after JM deletes reused files (production report, 2.2.1) Francis Altomare
2026/07/21 [jira] [Created] (FLINK-40215) AvroSerializer is not adhering to pojo rules of avro generation Taranpreet Kaur (Jira)
2026/07/21 [jira] [Created] (FLINK-40214) JSON_OBJECTAGG produces incorrect keys when key and value use the same column Qilong Wang (Jira)
2026/07/21 [jira] [Created] (FLINK-40213) Preserve JSON_OBJECTAGG key when wrapping value Qilong Wang (Jira)
2026/07/21 Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
2026/07/21 Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
2026/07/21 Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
2026/07/21 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/21 [jira] [Created] (FLINK-40212) Add Regional Checkpoint user documentation raoraoxiong (Jira)
2026/07/21 [jira] [Created] (FLINK-40211) Add Regional Checkpoint metrics, REST API and Web UI support raoraoxiong (Jira)
2026/07/21 [jira] [Created] (FLINK-40210) Add Per-Region timeout handling and bounded source forced global checkpoint raoraoxiong (Jira)
2026/07/21 [jira] [Created] (FLINK-40209) Introduce Regional Checkpoint core mechanism and notification dispatch raoraoxiong (Jira)
2026/07/21 [jira] [Created] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Aleksandr Iushmanov (Jira)
2026/07/21 [jira] [Created] (FLINK-40207) Make NaN and Infinity case-insensitive Ramin Gharib (Jira)
2026/07/21 [jira] [Created] (FLINK-40206) Upgrade pulsar client to latest patch version to address critical vulnerabilities Nikola Stanisavljevic (Jira)
2026/07/21 [jira] [Created] (FLINK-40205) PTF are failing in case of usage multiple PARTITION/ORDER BY Sergey Nuyanzin (Jira)
2026/07/21 [jira] [Created] (FLINK-40204) Introduce statement-level codegen for YAML Transform expressions Mao Jiayi (Jira)
2026/07/21 RE: [DISCUSS] State Schema Evolution for RowData David Radley
2026/07/21 [jira] [Created] (FLINK-40203) Add explicit option for Flink SQL-compatible YAML Transform expression semantics Mao Jiayi (Jira)
2026/07/21 [jira] [Created] (FLINK-40202) HybridSplitAssigner may initialize enumerator metrics concurrently with snapshot split assignment Hongshun Wang (Jira)
2026/07/20 Re: [VOTE] FLIP-527: State Schema Evolution for RowData gyula . fora
2026/07/20 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
2026/07/20 Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Weiqing Yang
2026/07/20 [VOTE] FLIP-527: State Schema Evolution for RowData Weiqing Yang
2026/07/20 Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Jim Hughes via dev
2026/07/20 Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Rich Bowen
2026/07/20 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
2026/07/20 Re: [VOTE] FLIP-581: Support Flexible Watermark Assignment via Built-in Function FeatZhang
2026/07/20 Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
2026/07/20 [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 wenjin
2026/07/20 [jira] [Created] (FLINK-40201) [Oracle CDC] Fix compatibility with Oracle 26ai and Debezium 3.4.2.Final Mohammad Suhel Ksolves Cassandra Experties (Jira)
2026/07/20 [jira] [Created] (FLINK-40200) TaskManager locking up in org.rocksdb.Checkpoint.createCheckpoint Efrat Levitan (Jira)
2026/07/19 [jira] [Created] (FLINK-40199) Add generic connector source and sink APIs to PyFlink DataFrame Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40196) Add missing-value handling to DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40195) Flink kubernetes operator certificate secret name should be configurable Jira
2026/07/19 [jira] [Created] (FLINK-40194) Add drop_duplicates to DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40193) Add join_lateral support to DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40192) Add as-of join support to DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40191) Add aggregation support to DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame Dian Fu (Jira)
2026/07/19 [RESULT][VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Yuepeng Pan
2026/07/19 [RESULT][VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Yuepeng Pan
2026/07/19 Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Yuepeng Pan
2026/07/19 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Yuepeng Pan