dev

Messages by Date

2026/08/18 [jira] [Created] (FLINK-40426) Add Parquet and JSON filesystem I/O APIs to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40424) Add windowing TVF support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40425) Add OVER window aggregation support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40423) Add Top-N support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40422) Add slicing APIs to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40421) Support sorting in DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40420) Add set operations to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40419) Add regular join support to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40418) Support attribute-based column access on DataFrame Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40417) Add remaining basic functionality to DataFrame API Liu Liu (Jira)
2026/08/18 [jira] [Created] (FLINK-40416) Add built-in text AI functions to Pipeline transforms Mao Jiayi (Jira)
2026/08/18 [jira] [Created] (FLINK-40415) PyFlink tests failed on Python 3.9 Dian Fu (Jira)
2026/08/18 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x David Anderson
2026/08/18 [DISCUSS] Use Project Lombok in Flink beyond tests Samrat Deb
2026/08/18 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
2026/08/18 [jira] [Created] (FLINK-40414) Autoscaler state ConfigMap is treated as trusted input Dennis-Mircea Ciupitu (Jira)
2026/08/18 [jira] [Created] (FLINK-40413) Autoscaling example classes leak into the operator javadoc site Dennis-Mircea Ciupitu (Jira)
2026/08/18 Re: [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Gabor Somogyi
2026/08/18 Re: [DISCUSS] Flink Kubernetes Operator: One-shot statelessRestartNonce Luca Castelli via dev
2026/08/18 [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser
2026/08/18 Re: [DISCUSS] Release flink-shaded 22.0 Mate Czagany
2026/08/18 [jira] [Created] (FLINK-40412) Autoscaler: unfiltered configOverrides merge lets tenants set arbitrary Flink config Purushottam Sinha (Jira)
2026/08/18 [jira] [Created] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Mao Jiayi (Jira)
2026/08/18 [jira] [Created] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression Moritz Manner (Jira)
2026/08/18 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/18 [jira] [Created] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline Xiqian Yu (Jira)
2026/08/18 [jira] [Created] (FLINK-40408) Fix NOTICE files to match dependencies for Flink Kubernetes Operator Mate Czagany (Jira)
2026/08/18 [jira] [Created] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered Kaustubh Butte (Jira)
2026/08/17 [jira] [Created] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Purushottam Sinha (Jira)
2026/08/17 [jira] [Created] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling Kaustubh Butte (Jira)
2026/08/17 [jira] [Created] (FLINK-40404) Split Python wheel releases for connector (e.g. kafka) Joey Pereira (Jira)
2026/08/17 Re: [DISCUSS] Release flink-shaded 22.0 P Sinha
2026/08/17 Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #1 Mate Czagany
2026/08/17 [jira] [Created] (FLINK-40403) MetricStore.TaskMetricStore recompiles subtask-index regexes on every metric fetch, starving the REST thread pool on high-parallelism jobs Tim Steinbach (Jira)
2026/08/17 [jira] [Created] (FLINK-40402) Add connect / read timeout to K8s operator artifact fetcher Robert Metzger (Jira)
2026/08/17 [jira] [Created] (FLINK-40401) Protect against large autoscaler config maps Robert Metzger (Jira)
2026/08/17 [jira] [Created] (FLINK-40400) Harden job artifact fetching in kubernetes operator Robert Metzger (Jira)
2026/08/17 [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #1 Gyula Fóra
2026/08/16 退订 arctan(∞)
2026/08/16 [jira] [Created] (FLINK-40399) Separate the SavepointKeyFilter runtime contract from push-down planning Ilya Soin (Jira)
2026/08/16 Re: [DISCUSS] Release flink-shaded 22.0 Ferenc Csaky
2026/08/16 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/16 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/16 退订 18524655605
2026/08/16 [jira] [Created] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness Efrat Levitan (Jira)
2026/08/16 [jira] [Created] (FLINK-40397) Add currentBinlogPositionLag metric for MySQL binlog reader wangkang (Jira)
2026/08/14 Re: Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Mate Czagany
2026/08/14 [DISCUSS] Release flink-shaded 22.0 Sergey Nuyanzin
2026/08/14 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger
2026/08/14 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
2026/08/14 [jira] [Created] (FLINK-40396) Create SplitReaders on the split fetcher thread instead of the caller thread Edson Wang (Jira)
2026/08/14 [jira] [Created] (FLINK-40395) Add documentation for extended scan partitioning modes Chanhae Oh (Jira)
2026/08/14 [jira] [Created] (FLINK-40394) Support extended scan partitioning modes in JdbcDynamicTableSource Chanhae Oh (Jira)
2026/08/14 [jira] [Created] (FLINK-40393) Add PhysicalIdSplitterEnumerator and PhysicalIdPartitionDialect with PostgreSQL and Oracle implementations Chanhae Oh (Jira)
2026/08/14 [jira] [Created] (FLINK-40392) Add AbstractDynamicSplitterEnumerator and BoundaryQuerySplitterEnumerator Chanhae Oh (Jira)
2026/08/14 Re: Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Roman Khachatryan
2026/08/14 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Gyula Fóra
2026/08/14 [jira] [Created] (FLINK-40391) PTF table argument with a non-default conversion class might fail Sergey Nuyanzin (Jira)
2026/08/14 [jira] [Created] (FLINK-40390) Validate JSON_LENGTH path prefixes at plan time and reuse the shared JSON codegen Gustavo de Morais (Jira)
2026/08/14 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Gyula Fóra
2026/08/14 [jira] [Created] (FLINK-40389) Source parallelism is not capped at the partition count Dennis-Mircea Ciupitu (Jira)
2026/08/14 [jira] [Created] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running Avi Sanwal (Jira)
2026/08/13 [DISCUSS] Race condition in JobManager final savepoint could cause data duplication or incorrect job state, with Flink Kubernetes Operator Han You
2026/08/13 [DISCUSS] Race condition in JobManager final savepoint could cause data duplication or incorrect job state, with Flink Kubernetes Operator Han You via dev
2026/08/13 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dennis-Mircea Ciupitu
2026/08/13 [jira] [Created] (FLINK-40387) NativeS3 - configured retry/throttle backoff is ignored due to AWS SDK retry circuit breaker enabled by default - failing checkpoints under S3 503 throttling Michael (Jira)
2026/08/13 [jira] [Created] (FLINK-40386) Log the enablement and state transitions of checkpointing during recovery Rui Fan (Jira)
2026/08/13 [jira] [Created] (FLINK-40385) Optimize efficiency issues of PostgreSQL during the full snapshot phase.- #4506 hql0312 (Jira)
2026/08/13 [jira] [Created] (FLINK-40384) Periodic FlinkStateSnapshot cleanup causes repeated SavepointError events liting liu (Jira)
2026/08/13 Re: [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger
2026/08/13 [jira] [Created] (FLINK-40383) Concept Glossary should be ordered alphabetically Lorenzo Nicora (Jira)
2026/08/12 [jira] [Created] (FLINK-40382) Serializer test variants in flink-table-type-utils are never executed Purushottam Sinha (Jira)
2026/08/12 Re:Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Xuyang
2026/08/12 Re: [DISCUSS] Long-term recommendation for durable checkpoint storage Samrat Deb
2026/08/12 Re: [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode Samrat Deb
2026/08/12 [VOTE] FLIP-606: Flink SQL Ergonomics: GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Tisya Bhatia via dev
2026/08/12 [jira] [Created] (FLINK-40381) Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close nadav fux (Jira)
2026/08/12 [jira] [Created] (FLINK-40380) Document the runtime configuration and stop jobs from overriding operator config through it Dennis-Mircea Ciupitu (Jira)
2026/08/12 Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
2026/08/12 [jira] [Created] (FLINK-40379) AdaptiveScheduler is in restart loop when task cancellation consistently times out Anton Kalashnikov (Jira)
2026/08/12 [jira] [Created] (FLINK-40378) Support GROUP BY position, ORDER BY ALL, and GROUP BY ALL in Flink SQL Tisya Bhatia (Jira)
2026/08/12 [jira] [Created] (FLINK-40377) MatchRecognize fails with Unsupported RelDataType: UNKNOWN while json plan generation Sergey Nuyanzin (Jira)
2026/08/12 Re: [DISCUSS] FLIP-XXX Monotonic Counters support Piotr Nowojski
2026/08/12 [jira] [Created] (FLINK-40376) Integrate VARIANT type to the flink-json format Ferenc Csaky (Jira)
2026/08/12 [jira] [Created] (FLINK-40375) Operator API tests: kube-API-server tests silently skipped in CI (Tests run: 0) Purushottam Sinha (Jira)
2026/08/12 [jira] [Created] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails with IllegalArgumentException: Cannot parse JobID from "null" if the job was previously suspended Dale Lane (Jira)
2026/08/12 [jira] [Created] (FLINK-40373) JSON_VALUE might fail on code generation Sergey Nuyanzin (Jira)
2026/08/12 Re: [DISCUSS] Long-term recommendation for durable checkpoint storage Gabor Somogyi
2026/08/12 [jira] [Created] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
2026/08/11 Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Xuyang
2026/08/11 [jira] [Created] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
2026/08/11 RE: [DISCUSS] Long-term recommendation for durable checkpoint storage Ordencia Wu
2026/08/11 [jira] [Created] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
2026/08/11 [jira] [Created] (FLINK-40369) ARRAY functions might lead to wrong results Sergey Nuyanzin (Jira)
2026/08/11 [jira] [Created] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute David Anderson (Jira)
2026/08/11 [jira] [Created] (FLINK-40367) Make Kafka consumer poll timeout configurable Robert Metzger (Jira)
2026/08/11 [jira] [Created] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs Gustavo de Morais (Jira)
2026/08/11 Re: [DISCUSS] FLIP-XXX Monotonic Counters support Efrat Levitan
2026/08/11 [jira] [Created] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect Dale Lane (Jira)
2026/08/10 [jira] [Created] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
2026/08/10 [jira] [Created] (FLINK-40363) MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN is unstable Sergey Nuyanzin (Jira)
2026/08/10 [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode archit goyal
2026/08/10 Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Ryan van Huuksloot via dev
2026/08/10 [jira] [Created] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Sylwester Lachiewicz (Jira)
2026/08/10 [jira] [Created] (FLINK-40361) Extract license check into a separate job in Azure Sergey Nuyanzin (Jira)
2026/08/10 [jira] [Created] (FLINK-40360) Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits Mao Jiayi (Jira)
2026/08/09 退订 xh
2026/08/09 [jira] [Created] (FLINK-40359) Split FetchedChannelStateReader into drain-side and checkpoint-side interfaces Rui Fan (Jira)
2026/08/09 [jira] [Created] (FLINK-40358) Use native S3 filesystem for all S3 end-to-end tests Samrat Deb (Jira)
2026/08/09 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Michal Stutzmann
2026/08/08 退订 18524655605
2026/08/08 Re: Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
2026/08/08 退订 Yanko24
2026/08/08 退订博-阿哥
2026/08/08 [DISCUSS] Long-term recommendation for durable checkpoint storage Ordencia Wu
2026/08/08 [jira] [Created] (FLINK-40357) Add ARRAY_FLATTEN function Shengyao He (Jira)
2026/08/08 退订黄新儿
2026/08/07 Re: [DISCUSS] Flink Kubernetes Operator: One-shot statelessRestartNonce Gyula Fóra
2026/08/07 [DISCUSS] Flink Kubernetes Operator: One-shot statelessRestartNonce Luca Castelli via dev
2026/08/07 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gustavo de Morais
2026/08/07 [DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Piotr Nowojski
2026/08/07 [jira] [Created] (FLINK-40356) Add MAP_FROM_ENTRIES function Gustavo de Morais (Jira)
2026/08/07 [jira] [Created] (FLINK-40355) Add MAP_CONTAINS_KEY function Gustavo de Morais (Jira)
2026/08/07 Re: [DISCUSS] FIP-49: Fluss Gateway REST API Junbo Wang
2026/08/07 [jira] [Created] (FLINK-40354) StateTtlConfig background cleanup does not work for async State v2 MapState on ForSt state backend Mykola Lukashchuk (Jira)
2026/08/07 Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
2026/08/07 Fwd: [DISCUSS] FIP-49: Fluss Gateway REST API Hongshun Wang
2026/08/07 [jira] [Created] (FLINK-40353) Leverage RocksDB ordered MapState TemporalRowTimeJoinOperator Piotr Nowojski (Jira)
2026/08/07 [jira] [Created] (FLINK-40352) Add CloseableIterator support to MapState Piotr Nowojski (Jira)
2026/08/07 [jira] [Created] (FLINK-40351) Reduce heap footprint of RocksDBMapState's iterator Piotr Nowojski (Jira)
2026/08/07 [jira] [Created] (FLINK-40350) LPAD/RPAD split supplementary-plane characters into unpaired surrogates sepuri sai krishna (Jira)
2026/08/06 [jira] [Created] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss Hongshun Wang (Jira)
2026/08/06 Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
2026/08/06 [jira] [Created] (FLINK-40348) ZSTD fails at runtime with the SQL Kafka Connector Kumar Mallikarjuna (Jira)
2026/08/06 [jira] [Created] (FLINK-40347) Introduce scan.partition.boundary-query and scan.partition.use-physical-id config options Chanhae Oh (Jira)
2026/08/06 [jira] [Created] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null" sepuri sai krishna (Jira)
2026/08/06 Reopening FLIP-505 (Flink History Server Remote Fetch) archit goyal
2026/08/06 [jira] [Created] (FLINK-40345) Buffer is recycled twice in FilteringHandler#recoverWithFiltering when delivery fails Rui Fan (Jira)
2026/08/06 Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Tisya Bhatia via dev
2026/08/06 Re: Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
2026/08/06 [jira] [Created] (FLINK-40344) Computed grouping expressions cannot be selected in Table API aggregations Liu Liu (Jira)
2026/08/06 [FLINK-40143] Request for review and assignment RL.93 c
2026/08/05 [jira] [Created] (FLINK-40343) Support row‑level precise batch incremental update for Materialized Table with Left Join support colagy wang (Jira)
2026/08/05 [jira] [Created] (FLINK-40342) Support schema event listener melin (Jira)
2026/08/05 Re: Kubernetes Operator 1.16.0 release planning Weiqing Yang
2026/08/05 [jira] [Created] (FLINK-40341) flink-kubernetes-operator: Bump jackson-bom to 2.21.5 to retire 11 advisories Purushottam Sinha (Jira)
2026/08/05 [jira] [Created] (FLINK-40340) UnsupportedOperationException for MySQL ZEROFILL types without UNSIGNED Zhuojun Jiang (Jira)
2026/08/05 [jira] [Created] (FLINK-40339) WatermarkCompactingSinkMaterializer reads MapState entries after removing them Gustavo de Morais (Jira)
2026/08/05 Re: Kubernetes Operator 1.16.0 release planning P Sinha
2026/08/05 [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
2026/08/05 Re: Kubernetes Operator 1.16.0 release planning Dennis-Mircea Ciupitu
2026/08/05 Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Dennis-Mircea Ciupitu
2026/08/05 Re: [DISCUSS] FLINK-39566: Checkpoint duration timeline view in the Web UI Ferenc Csaky
2026/08/05 Re: Kubernetes Operator 1.16.0 release planning Ferenc Csaky
2026/08/05 Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Gustavo de Morais
2026/08/05 Kubernetes Operator 1.16.0 release planning Gyula Fóra
2026/08/05 [jira] [Created] (FLINK-40338) ELT() throws ClassCastException when the index argument is not INT sepuri sai krishna (Jira)
2026/08/05 Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Mate Czagany
2026/08/05 [jira] [Created] (FLINK-40337) Preserve operator precedence in generated Janino expressions Mao Jiayi (Jira)
2026/08/05 [jira] [Created] (FLINK-40336) Avoid full state scans in event-time temporal join on sorted state backends Mate Czagany (Jira)
2026/08/05 [jira] [Created] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Mate Czagany (Jira)
2026/08/05 [jira] [Created] (FLINK-40334) Insert-only input should not be materialized under upsert-materialize FORCE Gustavo de Morais (Jira)
2026/08/05 [jira] [Created] (FLINK-40333) Move setLastReconciledSpec to after successful transition start for BG deployments Gyula Fora (Jira)
2026/08/05 [jira] [Created] (FLINK-40332) FileCatalogStore is not validating catalog names Gabor Somogyi (Jira)
2026/08/05 [jira] [Created] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink Hongshun Wang (Jira)
2026/08/04 Re: [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode archit goyal
2026/08/04 Re: [DISCUSS] FLINK-39566: Checkpoint duration timeline view in the Web UI Yuepeng Pan
2026/08/04 [jira] [Created] (FLINK-40330) [Kubernetes HA] Orphaned per-job leader entries accumulate in the cluster ConfigMap after interrupted cleanup or leadership loss Chaitanya Waikar (Jira)
2026/08/04 [jira] [Created] (FLINK-40329) Support Single EKU certificates for server and client TLS authentication Gyula Komlossi (Jira)
2026/08/04 Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Timo Walther
2026/08/04 Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
2026/08/04 [jira] [Created] (FLINK-40328) Add MariaDB-cdc connector docs sanqingleo (Jira)
2026/08/04 [jira] [Created] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch Yordan Pavlov (Jira)
2026/08/04 Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Timo Walther
2026/08/04 [jira] [Created] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Aleksandr Savonin (Jira)
2026/08/04 [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
2026/08/04 [jira] [Created] (FLINK-40325) Support Kafka as a CDC Source Connector in Flink CDC Pipeline Gopal Dirisala (Jira)
2026/08/04 [DISCUSS] Operational Agent Skills for Apache Flink : provider-agnostic troubleshooting & debugging guides Jim Pizagno
2026/08/04 [jira] [Created] (FLINK-40324) Append-only should stay unmaterialized without an ON CONFLICT clause Gustavo de Morais (Jira)
2026/08/04 Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Maximilian Michels
2026/08/04 [jira] [Created] (FLINK-40323) [cdc-common] Support JSON Data Type in Flink CDC Thorne (Jira)
2026/08/03 [jira] [Created] (FLINK-40322) PyFlink ArrayType/MultisetType.from_sql_type calls to_sql_type instead Nikolaus Schuetz (Jira)
2026/08/03 [jira] [Created] (FLINK-40321) [Flink CDC][Postgres] Table-level DDL metrics are not updated for schema change records Jira
2026/08/03 [jira] [Created] (FLINK-40320) CI: community review labeling counts the PR author's and co-authors' own reviews Purushottam Sinha (Jira)
2026/08/03 Hackathon task list needed - 10 weeks out Bowen, Rich
2026/08/03 [jira] [Created] (FLINK-40319) Add a raw-bytes accessor for VARIANT string values, and use it to validate UTF-8 on the character-string cast and to let a string variant reach a binary target Ramin Gharib (Jira)
2026/08/03 [jira] [Created] (FLINK-40318) Add a validation entry point for a VARIANT binary Ramin Gharib (Jira)
2026/08/03 [jira] [Created] (FLINK-40317) DeletesByKeySemanticTests is unstable Sergey Nuyanzin (Jira)
2026/08/03 [jira] [Created] (FLINK-40316) Add MariaDB CDC SQL connector sanqingleo (Jira)
2026/08/03 [jira] [Created] (FLINK-40315) Add MariaDB CDC DataStream source sanqingleo (Jira)
2026/08/03 [jira] [Created] (FLINK-40314) Introduce a MariaDB CDC connector sanqingleo (Jira)
2026/08/03 [jira] [Created] (FLINK-40313) Support collection constructors and functions in YAML Transform Mao Jiayi (Jira)
2026/08/03 [jira] [Created] (FLINK-40312) Support EXTRACT, date-part functions, and interval arithmetic in YAML Transform Mao Jiayi (Jira)
2026/08/03 [jira] [Created] (FLINK-40311) Rename EndiannessAccessChecks to EndiannessAccessChecksTest as it is not executed in CI Sergey Nuyanzin (Jira)
2026/08/03 [jira] [Created] (FLINK-40310) Rename CsvBulkWriterIT to CsvBulkWriterTest as it is not executed in CI Sergey Nuyanzin (Jira)
2026/08/03 [jira] [Created] (FLINK-40309) ML_PREDICT streaming semantic tests fail upsert-key validation Purushottam Sinha (Jira)
2026/08/03 [jira] [Created] (FLINK-40308) Table planner: 14 test classes named *Tests never execute in CI or locally Purushottam Sinha (Jira)
2026/08/03 Re: FLINK-38023: PR #28161 code review request Avi Sanwal
2026/08/03 [jira] [Created] (FLINK-40307) RestoreTestCompleteness was never executed in CI Sergey Nuyanzin (Jira)
2026/08/03 [jira] [Created] (FLINK-40306) Restore tests are absent for BatchExecHashAggregate and BatchExecNestedLoopJoin Sergey Nuyanzin (Jira)