You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-40273) JDBC docs: update for the 4.x module split and Sink V2 API - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/01 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40274) Flink CDC Remove unsupported kubernetes-session from target option help message - posted by "jaejun lee (Jira)" <ji...@apache.org> on 2026/08/01 08:32:00 UTC, 0 replies.
- Re: [VOTE] FLIP-485: Add UDF Metrics - posted by P Sinha <si...@gmail.com> on 2026/08/01 08:36:38 UTC, 1 replies.
- [DISCUSS] FLINK-39566: Checkpoint duration timeline view in the Web UI - posted by P Sinha <si...@gmail.com> on 2026/08/01 10:37:46 UTC, 2 replies.
- [jira] [Created] (FLINK-40275) Improve HTTP sink parity with HTTP lookup source - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/08/01 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40276) Add HTTP sink response classification and retry support - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/08/01 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40277) Add HTTP sink response classification and retry support - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/08/01 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40278) Define and implement HTTP sink batch retry semantics - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/08/01 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40279) Add HTTP sink parity for OIDC, proxy, and HTTP version configuration - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/08/01 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40280) Document HTTP sink retry, error handling, and configuration parity - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/08/01 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40281) Improve HTTP sink failure observability - posted by "Bharath Reddy Gunapati (Jira)" <ji...@apache.org> on 2026/08/01 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40282) Expand and correct the concepts Glossary - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2026/08/01 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40283) CorrelateITCase2 is not executed while running tests locally or via CI - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/01 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40284) A number of tests ending with Tests in class name are skipped from CI/local tests - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/01 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40285) MLPredictSemanticTests fails because of ON CONFLICT - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/01 18:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40286) Adapt keyless upsert sink should fall back to retract to MiscSemanticTests - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/01 19:30:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-485: Add UDF Metrics - posted by Weiqing Yang <ya...@gmail.com> on 2026/08/02 03:57:16 UTC, 0 replies.
- Re: [VOTE] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing - posted by Vaquar khan <kh...@gmail.com> on 2026/08/02 04:36:48 UTC, 0 replies.
- [jira] [Created] (FLINK-40287) Provide a first-party, governed MCP server for Apache Flink - posted by "vaquar khan (Jira)" <ji...@apache.org> on 2026/08/02 06:08:00 UTC, 0 replies.
- Confluence Wiki Access Request - vaquarkhan1 - posted by vaquar khan <va...@gmail.com> on 2026/08/02 06:17:54 UTC, 0 replies.
- [jira] [Created] (FLINK-40288) Multiple JoinSemanticTests fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/02 07:36:00 UTC, 0 replies.
- Re: [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator - posted by P Sinha <si...@gmail.com> on 2026/08/02 09:40:21 UTC, 2 replies.
- [jira] [Created] (FLINK-40289) Window Top-N examples are not reproducible in streaming mode - posted by "Hancheng Deng (Jira)" <ji...@apache.org> on 2026/08/02 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40290) Histogram summary emits duplicate quantile 1.0 - posted by "Kaiqi Dong (Jira)" <ji...@apache.org> on 2026/08/02 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40291) instrumentation scope in otel metric adaptor is wrongly hardcoded - posted by "Kaiqi Dong (Jira)" <ji...@apache.org> on 2026/08/02 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40292) Add UdfMetrics helper for UDF metrics - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/02 22:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/02 22:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40294) Instrument async scalar and table UDF calls with metrics - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/02 22:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40295) Document UDF metrics - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/02 22:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/02 23:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40297) Route TTL-aware value migration through the TypeSerializerSnapshot migrate hook - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/02 23:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40298) Opt-in name-based state schema evolution for RowData - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/03 00:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40299) Add end-to-end state migration tests for RowData schema evolution - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/08/03 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40300) PyFlink Table API lit does not convert Python values to the required Java literal types - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/03 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2026/08/03 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40302) Periodic materialization permanently stops after taking a native-format savepoint when the changelog state backend is enabled - posted by "최원용 (Jira)" <ji...@apache.org> on 2026/08/03 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2026/08/03 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40304) Incorrect upsert key inference for PTFs with multiple table arguments - posted by "Qilong Wang (Jira)" <ji...@apache.org> on 2026/08/03 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40305) VARIANT string and object key decoding ignores the UTF-8 charset - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/03 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40306) Restore tests are absent for BatchExecHashAggregate and BatchExecNestedLoopJoin - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/03 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40307) RestoreTestCompleteness was never executed in CI - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/03 09:33:00 UTC, 0 replies.
- Re: FLINK-38023: PR #28161 code review request - posted by Avi Sanwal <av...@gmail.com> on 2026/08/03 09:33:39 UTC, 0 replies.
- [jira] [Created] (FLINK-40308) Table planner: 14 test classes named *Tests never execute in CI or locally - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/03 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40309) ML_PREDICT streaming semantic tests fail upsert-key validation - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/03 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40310) Rename CsvBulkWriterIT to CsvBulkWriterTest as it is not executed in CI - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/03 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40311) Rename EndiannessAccessChecks to EndiannessAccessChecksTest as it is not executed in CI - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/03 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40312) Support EXTRACT, date-part functions, and interval arithmetic in YAML Transform - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/08/03 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40313) Support collection constructors and functions in YAML Transform - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/08/03 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40314) Introduce a MariaDB CDC connector - posted by "sanqingleo (Jira)" <ji...@apache.org> on 2026/08/03 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40315) Add MariaDB CDC DataStream source - posted by "sanqingleo (Jira)" <ji...@apache.org> on 2026/08/03 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40316) Add MariaDB CDC SQL connector - posted by "sanqingleo (Jira)" <ji...@apache.org> on 2026/08/03 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40317) DeletesByKeySemanticTests is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/03 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40318) Add a validation entry point for a VARIANT binary - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/03 15:18:00 UTC, 0 replies.
- [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 - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/03 15:21:00 UTC, 0 replies.
- Hackathon task list needed - 10 weeks out - posted by "Bowen, Rich" <rb...@apache.org> on 2026/08/03 18:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-40320) CI: community review labeling counts the PR author's and co-authors' own reviews - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/03 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40321) [Flink CDC][Postgres] Table-level DDL metrics are not updated for schema change records - posted by "牛一凡 (Jira)" <ji...@apache.org> on 2026/08/04 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40322) PyFlink ArrayType/MultisetType.from_sql_type calls to_sql_type instead - posted by "Nikolaus Schuetz (Jira)" <ji...@apache.org> on 2026/08/04 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40323) [cdc-common] Support JSON Data Type in Flink CDC - posted by "Thorne (Jira)" <ji...@apache.org> on 2026/08/04 08:01:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign - posted by Maximilian Michels <mx...@apache.org> on 2026/08/04 08:24:42 UTC, 3 replies.
- [jira] [Created] (FLINK-40324) Append-only should stay unmaterialized without an ON CONFLICT clause - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/04 08:59:00 UTC, 0 replies.
- [DISCUSS] Operational Agent Skills for Apache Flink : provider-agnostic troubleshooting & debugging guides - posted by Jim Pizagno <jp...@gmail.com> on 2026/08/04 09:39:11 UTC, 0 replies.
- [jira] [Created] (FLINK-40325) Support Kafka as a CDC Source Connector in Flink CDC Pipeline - posted by "Gopal Dirisala (Jira)" <ji...@apache.org> on 2026/08/04 10:21:00 UTC, 0 replies.
- [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps - posted by Ramin Gharib <ra...@gmail.com> on 2026/08/04 10:28:49 UTC, 7 replies.
- [jira] [Created] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/08/04 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch - posted by "Yordan Pavlov (Jira)" <ji...@apache.org> on 2026/08/04 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40328) Add MariaDB-cdc connector docs - posted by "sanqingleo (Jira)" <ji...@apache.org> on 2026/08/04 12:17:01 UTC, 0 replies.
- [jira] [Created] (FLINK-40329) Support Single EKU certificates for server and client TLS authentication - posted by "Gyula Komlossi (Jira)" <ji...@apache.org> on 2026/08/04 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40330) [Kubernetes HA] Orphaned per-job leader entries accumulate in the cluster ConfigMap after interrupted cleanup or leadership loss - posted by "Chaitanya Waikar (Jira)" <ji...@apache.org> on 2026/08/04 19:49:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode - posted by archit goyal <go...@gmail.com> on 2026/08/05 04:28:54 UTC, 3 replies.
- [jira] [Created] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/08/05 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40332) FileCatalogStore is not validating catalog names - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/08/05 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40333) Move setLastReconciledSpec to after successful transition start for BG deployments - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/08/05 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40334) Insert-only input should not be materialized under upsert-materialize FORCE - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/05 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/08/05 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40336) Avoid full state scans in event-time temporal join on sorted state backends - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/08/05 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40337) Preserve operator precedence in generated Janino expressions - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/08/05 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40338) ELT() throws ClassCastException when the index argument is not INT - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/08/05 13:47:00 UTC, 0 replies.
- Kubernetes Operator 1.16.0 release planning - posted by Gyula Fóra <gy...@gmail.com> on 2026/08/05 13:47:35 UTC, 4 replies.
- [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator - posted by Dale Lane <da...@proton.me> on 2026/08/05 15:02:55 UTC, 15 replies.
- [jira] [Created] (FLINK-40339) WatermarkCompactingSinkMaterializer reads MapState entries after removing them - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/05 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40340) UnsupportedOperationException for MySQL ZEROFILL types without UNSIGNED - posted by "Zhuojun Jiang (Jira)" <ji...@apache.org> on 2026/08/05 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40341) flink-kubernetes-operator: Bump jackson-bom to 2.21.5 to retire 11 advisories - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/05 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40342) Support schema event listener - posted by "melin (Jira)" <ji...@apache.org> on 2026/08/06 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40343) Support row‑level precise batch incremental update for Materialized Table with Left Join support - posted by "colagy wang (Jira)" <ji...@apache.org> on 2026/08/06 03:11:00 UTC, 0 replies.
- [FLINK-40143] Request for review and assignment - posted by "RL.93 c" <cs...@gmail.com> on 2026/08/06 11:52:07 UTC, 0 replies.
- [jira] [Created] (FLINK-40344) Computed grouping expressions cannot be selected in Table API aggregations - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/06 12:12:00 UTC, 0 replies.
- Re: Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage - posted by Zakelly Lan <za...@gmail.com> on 2026/08/06 16:32:07 UTC, 1 replies.
- Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY , GROUP BY ALL, and ORDER BY ALL - posted by Tisya Bhatia via dev <de...@flink.apache.org> on 2026/08/06 20:33:55 UTC, 0 replies.
- [jira] [Created] (FLINK-40345) Buffer is recycled twice in FilteringHandler#recoverWithFiltering when delivery fails - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/06 21:53:00 UTC, 0 replies.
- Reopening FLIP-505 (Flink History Server Remote Fetch) - posted by archit goyal <go...@gmail.com> on 2026/08/06 23:25:42 UTC, 1 replies.
- [jira] [Created] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null" - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/08/07 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40347) Introduce scan.partition.boundary-query and scan.partition.use-physical-id config options - posted by "Chanhae Oh (Jira)" <ji...@apache.org> on 2026/08/07 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40348) ZSTD fails at runtime with the SQL Kafka Connector - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2026/08/07 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/08/07 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40350) LPAD/RPAD split supplementary-plane characters into unpaired surrogates - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/08/07 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40351) Reduce heap footprint of RocksDBMapState's iterator - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/08/07 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40352) Add CloseableIterator support to MapState - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/08/07 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40353) Leverage RocksDB ordered MapState TemporalRowTimeJoinOperator - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2026/08/07 08:20:00 UTC, 0 replies.
- Fwd: [DISCUSS] FIP-49: Fluss Gateway REST API - posted by Hongshun Wang <lo...@gmail.com> on 2026/08/07 08:57:34 UTC, 1 replies.
- Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) - posted by Do...@swisscom.com on 2026/08/07 09:31:25 UTC, 4 replies.
- [jira] [Created] (FLINK-40354) StateTtlConfig background cleanup does not work for async State v2 MapState on ForSt state backend - posted by "Mykola Lukashchuk (Jira)" <ji...@apache.org> on 2026/08/07 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40355) Add MAP_CONTAINS_KEY function - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/07 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40356) Add MAP_FROM_ENTRIES function - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/07 13:13:00 UTC, 0 replies.
- [DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode - posted by Piotr Nowojski <pn...@apache.org> on 2026/08/07 13:53:16 UTC, 6 replies.
- [DISCUSS] Flink Kubernetes Operator: One-shot statelessRestartNonce - posted by Luca Castelli via dev <de...@flink.apache.org> on 2026/08/07 19:27:41 UTC, 2 replies.
- 退订 - posted by 黄新儿 <hx...@126.com> on 2026/08/08 08:19:09 UTC, 8 replies.
- [jira] [Created] (FLINK-40357) Add ARRAY_FLATTEN function - posted by "Shengyao He (Jira)" <ji...@apache.org> on 2026/08/08 14:03:00 UTC, 0 replies.
- [DISCUSS] Long-term recommendation for durable checkpoint storage - posted by Ordencia Wu <or...@gmail.com> on 2026/08/08 19:00:12 UTC, 4 replies.
- [jira] [Created] (FLINK-40358) Use native S3 filesystem for all S3 end-to-end tests - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2026/08/09 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40359) Split FetchedChannelStateReader into drain-side and checkpoint-side interfaces - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/09 23:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40360) Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/08/10 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40361) Extract license check into a separate job in Azure - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/10 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update - posted by "Sylwester Lachiewicz (Jira)" <ji...@apache.org> on 2026/08/10 16:15:00 UTC, 0 replies.
- Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) - posted by Ryan van Huuksloot via dev <de...@flink.apache.org> on 2026/08/10 17:12:07 UTC, 1 replies.
- [jira] [Created] (FLINK-40363) MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/10 17:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40364) flink-connector-pulsar Flink 2.x support - posted by "Hongbo Miao (Jira)" <ji...@apache.org> on 2026/08/11 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/08/11 10:48:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX Monotonic Counters support - posted by Efrat Levitan <ef...@gmail.com> on 2026/08/11 14:44:29 UTC, 2 replies.
- [jira] [Created] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/11 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40367) Make Kafka consumer poll timeout configurable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/08/11 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute - posted by "David Anderson (Jira)" <ji...@apache.org> on 2026/08/11 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40369) ARRAY functions might lead to wrong results - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/11 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization - posted by "Joey Pereira (Jira)" <ji...@apache.org> on 2026/08/11 21:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint - posted by "Kushagra Tyagi (Jira)" <ji...@apache.org> on 2026/08/12 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup - posted by "liting liu (Jira)" <ji...@apache.org> on 2026/08/12 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40373) JSON_VALUE might fail on code generation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/12 08:04:00 UTC, 0 replies.
- [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 - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/08/12 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40375) Operator API tests: kube-API-server tests silently skipped in CI (Tests run: 0) - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/12 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40376) Integrate VARIANT type to the flink-json format - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/08/12 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40377) MatchRecognize fails with Unsupported RelDataType: UNKNOWN while json plan generation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/12 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40378) Support GROUP BY position, ORDER BY ALL, and GROUP BY ALL in Flink SQL - posted by "Tisya Bhatia (Jira)" <ji...@apache.org> on 2026/08/12 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40379) AdaptiveScheduler is in restart loop when task cancellation consistently times out - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2026/08/12 15:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems - posted by Aleksandr Iushmanov <iz...@gmail.com> on 2026/08/12 16:40:24 UTC, 1 replies.
- [jira] [Created] (FLINK-40380) Document the runtime configuration and stop jobs from overriding operator config through it - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/08/12 18:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40381) Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close - posted by "nadav fux (Jira)" <ji...@apache.org> on 2026/08/12 18:34:00 UTC, 0 replies.
- [VOTE] FLIP-606: Flink SQL Ergonomics: GROUP BY , GROUP BY ALL, and ORDER BY ALL - posted by Tisya Bhatia via dev <de...@flink.apache.org> on 2026/08/12 18:59:45 UTC, 0 replies.
- [jira] [Created] (FLINK-40382) Serializer test variants in flink-table-type-utils are never executed - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/13 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40383) Concept Glossary should be ordered alphabetically - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2026/08/13 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40384) Periodic FlinkStateSnapshot cleanup causes repeated SavepointError events - posted by "liting liu (Jira)" <ji...@apache.org> on 2026/08/13 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40385) Optimize efficiency issues of PostgreSQL during the full snapshot phase.- #4506 - posted by "hql0312 (Jira)" <ji...@apache.org> on 2026/08/13 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40386) Log the enablement and state transitions of checkpointing during recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/13 10:55:00 UTC, 0 replies.
- [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 - posted by "Michael (Jira)" <ji...@apache.org> on 2026/08/13 14:04:00 UTC, 0 replies.
- [DISCUSS] Race condition in JobManager final savepoint could cause data duplication or incorrect job state, with Flink Kubernetes Operator - posted by Han You via dev <de...@flink.apache.org> on 2026/08/13 17:54:32 UTC, 1 replies.
- [jira] [Created] (FLINK-40388) FlinkDeployment deletion can remain stuck when savepoint-on-deletion is enabled and the job is not running - posted by "Avi Sanwal (Jira)" <ji...@apache.org> on 2026/08/14 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40389) Source parallelism is not capped at the partition count - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/08/14 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40390) Validate JSON_LENGTH path prefixes at plan time and reuse the shared JSON codegen - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/14 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40391) PTF table argument with a non-default conversion class might fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/14 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40392) Add AbstractDynamicSplitterEnumerator and BoundaryQuerySplitterEnumerator - posted by "Chanhae Oh (Jira)" <ji...@apache.org> on 2026/08/14 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40393) Add PhysicalIdSplitterEnumerator and PhysicalIdPartitionDialect with PostgreSQL and Oracle implementations - posted by "Chanhae Oh (Jira)" <ji...@apache.org> on 2026/08/14 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40395) Add documentation for extended scan partitioning modes - posted by "Chanhae Oh (Jira)" <ji...@apache.org> on 2026/08/14 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40394) Support extended scan partitioning modes in JdbcDynamicTableSource - posted by "Chanhae Oh (Jira)" <ji...@apache.org> on 2026/08/14 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40396) Create SplitReaders on the split fetcher thread instead of the caller thread - posted by "Edson Wang (Jira)" <ji...@apache.org> on 2026/08/14 15:16:00 UTC, 0 replies.
- [DISCUSS] Release flink-shaded 22.0 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/08/14 20:08:06 UTC, 3 replies.
- [jira] [Created] (FLINK-40397) Add currentBinlogPositionLag metric for MySQL binlog reader - posted by "wangkang (Jira)" <ji...@apache.org> on 2026/08/16 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/08/16 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40399) Separate the SavepointKeyFilter runtime contract from push-down planning - posted by "Ilya Soin (Jira)" <ji...@apache.org> on 2026/08/16 20:42:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #1 - posted by Gyula Fóra <gy...@gmail.com> on 2026/08/17 07:13:49 UTC, 3 replies.
- [jira] [Created] (FLINK-40400) Harden job artifact fetching in kubernetes operator - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/08/17 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40401) Protect against large autoscaler config maps - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/08/17 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40402) Add connect / read timeout to K8s operator artifact fetcher - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/08/17 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40403) MetricStore.TaskMetricStore recompiles subtask-index regexes on every metric fetch, starving the REST thread pool on high-parallelism jobs - posted by "Tim Steinbach (Jira)" <ji...@apache.org> on 2026/08/17 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40404) Split Python wheel releases for connector (e.g. kafka) - posted by "Joey Pereira (Jira)" <ji...@apache.org> on 2026/08/17 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling - posted by "Kaustubh Butte (Jira)" <ji...@apache.org> on 2026/08/17 18:20:00 UTC, 0 replies.
- [flink-connector-kafka] CI rerun and merge permissions for PR #267 Hi, - posted by jigar bhati <ji...@gmail.com> on 2026/08/17 23:25:31 UTC, 1 replies.
- [jira] [Created] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/18 06:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered - posted by "Kaustubh Butte (Jira)" <ji...@apache.org> on 2026/08/18 08:58:03 UTC, 0 replies.
- [jira] [Created] (FLINK-40408) Fix NOTICE files to match dependencies for Flink Kubernetes Operator - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/08/18 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/08/18 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40410) ClassCastException when constant-folding a VARIANT expression before another constant expression - posted by "Moritz Manner (Jira)" <ji...@apache.org> on 2026/08/18 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/08/18 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40412) Autoscaler: unfiltered configOverrides merge lets tenants set arbitrary Flink config - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/18 11:22:00 UTC, 0 replies.
- [DISCUSS] Bump the build/enforced Maven version from 3.8.6 to 3.9.x - posted by Martijn Visser <ma...@apache.org> on 2026/08/18 12:25:05 UTC, 7 replies.
- [jira] [Created] (FLINK-40413) Autoscaling example classes leak into the operator javadoc site - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/08/18 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40414) Autoscaler state ConfigMap is treated as trusted input - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/08/18 15:34:00 UTC, 0 replies.
- [DISCUSS] Use Project Lombok in Flink beyond tests - posted by Samrat Deb <de...@gmail.com> on 2026/08/18 18:33:57 UTC, 9 replies.
- [jira] [Created] (FLINK-40415) PyFlink tests failed on Python 3.9 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2026/08/19 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40416) Add built-in text AI functions to Pipeline transforms - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/08/19 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40417) Add remaining basic functionality to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40418) Support attribute-based column access on DataFrame - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40419) Add regular join support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40421) Support sorting in DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40420) Add set operations to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40422) Add slicing APIs to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40423) Add Top-N support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40425) Add OVER window aggregation support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40424) Add windowing TVF support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40426) Add Parquet and JSON filesystem I/O APIs to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40428) Remove Calcite's LogicalSnapshot - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/19 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40430) Add configuration support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40431) Add UDF support to PyFlink DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40433) Add map and map_batches support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40432) Parallel snapshot/CDC split by long handle space is skewed for AUTO_INCREMENT PKs and can OOM - posted by "lifulong (Jira)" <ji...@apache.org> on 2026/08/19 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40434) Add flat_map support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40436) Add UDAF support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40435) Add explode support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40437) Add iteration and bounded retrieval to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40438) Add DataFrame inspection and rich display APIs - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40439) Add model provider management to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40440) Add LLM prediction support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/19 06:24:00 UTC, 0 replies.
- [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath - posted by Martijn Visser <ma...@apache.org> on 2026/08/19 07:59:50 UTC, 4 replies.
- [jira] [Created] (FLINK-40441) Shade com.zaxxer (HikariCP) for pg pipeline connector to avoid cross-connector conflicts - posted by "Zhuojun Jiang (Jira)" <ji...@apache.org> on 2026/08/19 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40442) State Processor API re-derives a key's key-group from hashCode() instead of reusing the one it read the key from — breaks reading old state after any hashCode() change - posted by "Grzegorz Liter (Jira)" <ji...@apache.org> on 2026/08/19 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40443) Harden autoscaler metrics name parsing against complex regex - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/08/19 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40444) OBJECT_UPDATE returns incorrect results for some structured types - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/08/19 18:04:00 UTC, 0 replies.
- [DISCUSS] Splitting FLINK-37357 / PR #26201 into smaller migration tasks - posted by Hirson Zhang <mi...@163.com> on 2026/08/20 07:44:16 UTC, 0 replies.
- [jira] [Created] (FLINK-40445) Autoscaler: integration test for Kafka/Pulsar source partition-metric detection - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/20 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/20 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40447) Keyless upsert sink can silently drop retract semantics when upsert-key metadata is empty or mixed - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/20 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40448) Pin resolved address during operator artifact fetch to prevent DNS rebinding - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/08/20 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40449) Reject non-temporal streaming sort during planning instead of at job submission - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/20 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40450) Planner tests miss direct flink-table-code-splitter test dependency - posted by "Shekhar Prasad Rajak (Jira)" <ji...@apache.org> on 2026/08/20 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/21 05:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40452) Cap exception fetching by size, not line count - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/08/21 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter - posted by "YangyangHu (Jira)" <ji...@apache.org> on 2026/08/21 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40454) java.lang.NoSuchMethodError: '...Configuration.getInteger(..)' in FlinkConfigManager - posted by "Vladislav Keda (Jira)" <ji...@apache.org> on 2026/08/21 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40455) Decoupling Autotuning from the Autoscaling logic - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/08/21 15:30:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 - posted by Gyula Fóra <gy...@apache.org> on 2026/08/21 16:21:22 UTC, 5 replies.
- [jira] [Created] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/21 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40457) Bump pekko to 1.7.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/22 05:54:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX : Remote Artifact Fetch for Session-Mode Job Submission - posted by Dale Lane <da...@proton.me> on 2026/08/23 22:40:19 UTC, 0 replies.
- [jira] [Created] (FLINK-40458) Shade commons-lang and commons-lang3 in flink-sql-connector-hive - posted by "liting liu (Jira)" <ji...@apache.org> on 2026/08/24 06:04:00 UTC, 0 replies.
- [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps - posted by Ramin Gharib <ra...@gmail.com> on 2026/08/24 07:10:42 UTC, 9 replies.
- [jira] [Created] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/24 09:19:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 22.0, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/08/24 09:44:34 UTC, 7 replies.
- [jira] [Created] (FLINK-40460) Upgrade archive-producing Maven plugins to reproducible-capable versions - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/24 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40461) Add config option for labels on operator generated events - posted by "Attila Mészáros (Jira)" <ji...@apache.org> on 2026/08/24 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/24 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support - posted by "Chris Johnson (Jira)" <ji...@apache.org> on 2026/08/24 19:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014 - posted by "Florian Vazelle (Jira)" <ji...@apache.org> on 2026/08/25 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/08/25 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2026/08/25 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy - posted by "Josh Keegan (Jira)" <ji...@apache.org> on 2026/08/25 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/08/25 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/08/25 16:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails - posted by "hyeon kim (Jira)" <ji...@apache.org> on 2026/08/26 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40471) Add per-UDF concurrency and batch size support - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/26 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40472) Add Arrow-native vectorized UDF support to DataFrame API - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/08/26 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40473) YARN application mode fails to locate flink-cdc-dist jar when the jar name carries a Flink version suffix - posted by "XiaodongHuan (Jira)" <ji...@apache.org> on 2026/08/26 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40474) Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/08/26 08:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions - posted by Mika Naylor <ma...@autophagy.io> on 2026/08/26 10:42:30 UTC, 2 replies.
- [VOTE] FLIP-595: Differentiate monotonic and non-monotonic counters in Flink metrics - posted by Efrat Levitan <ef...@gmail.com> on 2026/08/26 12:21:53 UTC, 1 replies.
- [jira] [Created] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/26 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40476) Clarify that the Changelog state backend requires CLAIM restore mode (NO_CLAIM unsupported) - posted by "Santwana Verma (Jira)" <ji...@apache.org> on 2026/08/26 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/08/26 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40478) HistoryServer should log its effective configuration at startup - posted by "Archit Goyal (Jira)" <ji...@apache.org> on 2026/08/26 19:10:00 UTC, 0 replies.
- [DISCUSS] Cluster overhead/waste in large shared Flink clusters - posted by Yanis Djeridi via dev <de...@flink.apache.org> on 2026/08/26 23:13:57 UTC, 2 replies.
- [ANNOUNCE] New Apache Flink Committer - Weiqing Yang - posted by Xintong Song <to...@gmail.com> on 2026/08/27 01:32:57 UTC, 15 replies.
- [jira] [Created] (FLINK-40479) FROM_CHANGELOG accepts error_handling but still fails the job on unmapped op codes - posted by "Rango (Jira)" <ji...@apache.org> on 2026/08/27 05:44:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps - posted by Ramin Gharib <ra...@gmail.com> on 2026/08/27 08:30:44 UTC, 0 replies.
- [jira] [Created] (FLINK-40480) [doc] CDC Yaml supports fluss source. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/08/27 10:02:00 UTC, 0 replies.
- [DISCUSS] Planning Flink 2.4 - posted by Mika Naylor <ma...@autophagy.io> on 2026/08/27 12:01:57 UTC, 4 replies.
- [jira] [Created] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW() instead of past - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/08/27 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/27 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() - posted by "Timo Theusner (Jira)" <ji...@apache.org> on 2026/08/27 13:49:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #3 - posted by Gyula Fóra <gy...@gmail.com> on 2026/08/27 14:34:56 UTC, 0 replies.
- [jira] [Created] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/27 18:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 20:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40486) Introduce the UUID logical type - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40487) CAST between UUID and STRING / BINARY(16) - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 20:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40488) Comparison and ordering for UUID - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 20:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40489) Add UUID_V4() & UUID_V7() functions - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 20:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40490) Runtime serialization and codegen for UUID - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 20:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40491) Decode/accessor support in BinaryVariant for codes 17-20 - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 20:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19) - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 21:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40493) VARIANT CAST for UUID (code 20) - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 21:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40494) Document UUID and extended VARIANT type - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/27 21:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40495) Limit concurrent shared-state disposal to prevent JobManager I/O starvation - posted by "Tianji Li (Jira)" <ji...@apache.org> on 2026/08/27 22:08:00 UTC, 0 replies.
- Re: [DISCUSS] Model routing for ML_PREDICT (FLINK-39961) - posted by Purshotam Shah via dev <de...@flink.apache.org> on 2026/08/28 06:50:38 UTC, 0 replies.
- [jira] [Created] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct) - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/08/28 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/08/28 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/08/28 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/28 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/28 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40501) WatermarkStatus overtakes queued watermarks in AsyncWaitOperator, causing watermark loss downstream - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/28 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40502) scan.watermark.idle-timeout is silently ignored for connectors without watermark pushdown; SOURCE_WATERMARK() ignores idle-timeout entirely - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/28 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 2× the periodic probe interval, contradicting the withIdleness documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/28 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/28 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/08/28 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/08/28 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40507) upgrade paimon to 2.0.0 - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/08/28 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40508) Support DB2 pipeline connector - posted by "suntectec (Jira)" <ji...@apache.org> on 2026/08/29 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40509) Move operator defaults out of the Helm chart so config.yaml carries only user-supplied content - posted by "Gerk Elznik (Jira)" <ji...@apache.org> on 2026/08/29 22:42:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer: Samrat Deb - posted by Robert Metzger <me...@gmail.com> on 2026/08/30 05:29:29 UTC, 10 replies.
- [jira] [Created] (FLINK-40510) Use Apache Parent POM 39 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/30 19:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40511) Track and speed up slow integration tests (KafkaSinkITCase and friends) - posted by "Sylwester Lachiewicz (Jira)" <ji...@apache.org> on 2026/08/30 21:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40512) PostgreSQL source emits relation schema events for tables outside the configured table list - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/08/31 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40513) Validate forward routing and optimize Fluss sink writer with bucket affinity - posted by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/08/31 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation - posted by "Rango (Jira)" <ji...@apache.org> on 2026/08/31 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/08/31 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager - posted by "Taranpreet Kaur (Jira)" <ji...@apache.org> on 2026/08/31 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40526) Checkpointing-during-recovery crashes a recovering RemoteInputChannel when announcing a stashed timeoutable-aligned barrier - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/08/31 18:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40527) Update flink-shaded to 22.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/31 21:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40528) Codegen should be tolerate to partial deletes - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/08/31 22:02:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-shaded 22.0, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/08/31 22:20:21 UTC, 0 replies.