dev

Messages by Date

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
2026/07/19 [jira] [Created] (FLINK-40189) Found Security Vunerability in IndexGeneratorFactory.java Taranpreet Kaur (Jira)
2026/07/19 Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
2026/07/19 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Leonard Xu
2026/07/19 [jira] [Created] (FLINK-40188) Check connection string at the start of job for opensearch distributor Taranpreet Kaur (Jira)
2026/07/19 [jira] [Created] (FLINK-40187) Introduce DataType class in DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40186) Support the basic functionality of DataFrame API Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40185) Introduce DataFrame API in PyFlink Dian Fu (Jira)
2026/07/19 [jira] [Created] (FLINK-40184) Remove inconsistency checks from DynamoDB Connector Abhi Gupta (Jira)
2026/07/19 [jira] [Created] (FLINK-40183) Add regression coverage for CheckpointCoordinator scheduling amirhossein deljouyi (Jira)
2026/07/19 [jira] [Created] (FLINK-40182) ArrayToArray and MapToMap generate code which might fail with NPE Sergey Nuyanzin (Jira)
2026/07/19 [jira] [Created] (FLINK-40181) Make spotless checking changes since last green build in ci Sergey Nuyanzin (Jira)
2026/07/19 [jira] [Created] (FLINK-40180) Non-keyed state support in StateCatalog Gyula Fora (Jira)
2026/07/19 [jira] [Created] (FLINK-40179) Support windowed states in state catalog Gyula Fora (Jira)
2026/07/19 [jira] [Created] (FLINK-40178) Keyed state cataloging integration test Gyula Fora (Jira)
2026/07/19 [jira] [Created] (FLINK-40177) Support reading Keyed and Flattened Keyed states Gyula Fora (Jira)
2026/07/19 [jira] [Created] (FLINK-40176) Introduce basic StateCatalog functionality Gyula Fora (Jira)
2026/07/19 [jira] [Created] (FLINK-40175) FLIP-599: State Catalog Gyula Fora (Jira)
2026/07/19 [RESULT][VOTE] FLIP-599: State Catalog Gyula Fóra
2026/07/19 Re: [VOTE] FLIP-599: State Catalog Gyula Fóra
2026/07/18 [jira] [Created] (FLINK-40173) Add restore coverage for early-fire interval join Weiqing Yang (Jira)
2026/07/18 [jira] [Created] (FLINK-40174) Document the EARLY_FIRE hint for interval joins Weiqing Yang (Jira)
2026/07/18 [jira] [Created] (FLINK-40171) Emit and retract early-fire results in the interval join operator Weiqing Yang (Jira)
2026/07/18 [jira] [Created] (FLINK-40172) Support processing-time early fire on a row-time interval join Weiqing Yang (Jira)
2026/07/18 [jira] [Created] (FLINK-40170) Infer update-producing changelog mode for early-fire interval join Weiqing Yang (Jira)
2026/07/18 [jira] [Created] (FLINK-40169) Add target option to the EARLY_FIRE hint Weiqing Yang (Jira)
2026/07/18 [jira] [Created] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation Weiqing Yang (Jira)
2026/07/18 [jira] [Created] (FLINK-40168) Thread the EARLY_FIRE hint into the interval join Weiqing Yang (Jira)
2026/07/17 [RESULT][VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/17 Re: Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
2026/07/17 [RESULT][VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
2026/07/17 Re: [VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
2026/07/17 [jira] [Created] (FLINK-40166) SQL query parsing fails if current catalog is unreachable Dale Lane (Jira)
2026/07/17 Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava via dev
2026/07/17 [jira] [Created] (FLINK-40165) Add docs check to Github Actions pipeline for pull requests Dale Lane (Jira)
2026/07/17 [jira] [Created] (FLINK-40164) FlinkSessionJob's lifecycleState stays "UPGRADING" even after it's suspended successfully Milind L (Jira)
2026/07/17 [jira] [Created] (FLINK-40163) Add a new baseline nightly build to the Github Actions pipeline Dale Lane (Jira)
2026/07/17 Re: [VOTE] FLIP-599: State Catalog Roman Khachatryan
2026/07/17 Re: Flip-587 gyula . fora
2026/07/17 [jira] [Created] (FLINK-40162) Fast-running FlinkSessionJob does not reflect actual state of the job Milind L (Jira)
2026/07/17 Flip-587 David Radley
2026/07/17 [jira] [Created] (FLINK-40161) Log original MySQL DDL events before parsing Mao Jiayi (Jira)
2026/07/17 [jira] [Created] (FLINK-40160) Casting 'NaN' to Float or Double throws CompileException Ramin Gharib (Jira)
2026/07/16 Re: Re: [DISCUSS] Add UDF Metrics Weiqing Yang
2026/07/16 Re: Reviewers for Kafka Connector Projection Pushdown Farooq Qaiser via dev
2026/07/16 Re: Possible race in MapState#asyncPutAll on ForSt: chained reads see keys but null values Zakelly Lan
2026/07/16 [jira] [Created] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink Bread S (Jira)
2026/07/16 [jira] [Created] (FLINK-40158) Add translation rules for SNAPSHOT function in batch mode Fabian Hueske (Jira)
2026/07/16 [jira] [Created] (FLINK-40157) MapState#asyncPutAll on ForSt: reads chained on the returned StateFuture see the new keys but null values Francis (Jira)
2026/07/15 Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
2026/07/15 Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
2026/07/15 Re: [VOTE] FLIP-599: State Catalog Peter Huang
2026/07/15 Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Yuepeng Pan
2026/07/15 [jira] [Created] (FLINK-40156) FLIP-600: Independent Checkpoint Based On Pipeline Region raoraoxiong (Jira)
2026/07/15 Re: [VOTE] FLIP-599: State Catalog Zakelly Lan
2026/07/15 [jira] [Created] (FLINK-40155) Kubernetes Operator: support and end-to-end test Helm 4 Purushottam Sinha (Jira)
2026/07/15 Re: [VOTE] FLIP-599: State Catalog Vivek Jhaver
2026/07/15 [jira] [Created] (FLINK-40154) Upgrade Parquet dependency to 1.16.0 David Chaava (Jira)
2026/07/15 [jira] [Created] (FLINK-40153) CREATE TABLE LIKE cannot resolve inherited metadata columns in a derived watermark expression lincoln lee (Jira)
2026/07/15 Re: [VOTE] FLIP-599: State Catalog Rui Fan
2026/07/15 Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Fabian Hueske
2026/07/15 [jira] [Created] (FLINK-40152) PostgreSQL CDC connector captures case-variant tables when only one is specified Xin Chen (Jira)