dev

Messages by Date

2025/10/18 Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Leonard Xu
2025/10/18 [DISCUSS] Flink 2.1.1 release Gabor Somogyi
2025/10/18 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
2025/10/18 [Discussion] JDBC Connector SplitReader pass ResultSet with cursor at the first row clara xiong
2025/10/18 [jira] [Created] (FLINK-38416) Wrong constructor argument order for NestedMapConstraint Ryan Murray (Jira)
2025/10/18 [jira] [Created] (FLINK-38478) There may be a risk of data loss when two jobs write to the same Paimon table concurrently Yanquan Lv (Jira)
2025/10/18 Re: [DISCUSS] Deprecation plan for Scala usage in connectors (e.g., Cassandra) Etienne Chauchot
2025/10/18 [jira] [Created] (FLINK-38472) can not install apache-flink with python3.13 pemja==0.5.3 cannot be built nicolas debeissat (Jira)
2025/10/18 [jira] [Created] (FLINK-38451) KafkaCommitter logs ERRORs unnecessarily during cancellation Arvid Heise (Jira)
2025/10/18 Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
2025/10/18 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Gustavo de Morais
2025/10/18 Re: Permanent CI issues Gabor Somogyi
2025/10/18 [jira] [Created] (FLINK-38468) Performance drops when the coalesce parameter includes functions Jie Cheng (Jira)
2025/10/18 Re: [VOTE] Release 1.20.3, release candidate #1 Dian Fu
2025/10/18 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li
2025/10/18 Re: [VOTE] Release 2.0.1, release candidate #1 Mate Czagany
2025/10/18 [jira] [Created] (FLINK-38424) Support to parse VECTOR_SEARCH table function Shengkai Fang (Jira)
2025/10/18 [SUMMARY] Flink 2.2 Release Sync 10/01/2025 Hang Ruan
2025/10/18 [jira] [Created] (FLINK-38484) community review github action stopped working david radley (Jira)
2025/10/18 Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
2025/10/18 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
2025/10/18 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
2025/10/18 FLINK-30975 - Flink Filesystem support for AWS SDK V2 ctrlaltdilj
2025/10/18 [jira] [Created] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Biao Geng (Jira)
2025/10/18 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Etienne Chauchot
2025/10/18 [jira] [Created] (FLINK-38519) Custom Message Keys with PyFlink Kafka Sink Sebastian YEPES FERNANDEZ (Jira)
2025/10/18 [VOTE] Release 2.0.1, release candidate #1 Zakelly Lan
2025/10/18 Re: [DISCUSS] FLIP-549: Support Application Management Shengkai Fang
2025/10/18 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
2025/10/18 Request to review FLIP-490 contribution Yuepeng Pan
2025/10/18 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Ferenc Csaky
2025/10/18 Re: Request for slack invite Gustavo de Morais
2025/10/18 Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
2025/10/18 Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Yunfeng Zhou
2025/10/18 Re: [DISCUSS] FLIP-XXX: Add ARTIFACT keyword option in CREATE FUNCTION's USING JAR clause Martijn Visser
2025/10/18 [jira] [Created] (FLINK-38437) Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator Jira
2025/10/18 [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
2025/10/18 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Gyula Fora
2025/10/18 Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Arvid Heise
2025/10/18 [ANNOUNCE] Apache Flink 1.20.3 released Xuannan Su
2025/10/18 [jira] [Created] (FLINK-38509) Dynamic Credentials in Flink for Google Cloud Storage Royston Tauro (Jira)
2025/10/18 [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Yanquan Lv
2025/10/18 [jira] [Created] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots Xiqian Yu (Jira)
2025/10/18 [jira] [Created] (FLINK-38474) Add java25-target profile Sergey Nuyanzin (Jira)
2025/10/18 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
2025/10/18 [jira] [Created] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support Poorvank Bhatia (Jira)
2025/10/18 Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
2025/10/18 Community review git action failing David Radley
2025/10/18 [jira] [Created] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for Database connections which require SSL. John Watson (Jira)
2025/10/18 Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ramin Gharib
2025/10/18 [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xuannan Su
2025/10/18 Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Timo Walther
2025/10/18 [jira] [Created] (FLINK-38493) Port Calcite's fix for LITERAL is lost while validation Sergey Nuyanzin (Jira)
2025/10/17 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
2025/10/17 [jira] [Created] (FLINK-38464) Introduce OrderedMultiSetState (view) Roman Khachatryan (Jira)
2025/10/17 [jira] [Created] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator Arvid Heise (Jira)
2025/10/17 [jira] [Created] (FLINK-38445) Create test plans to validate upsert keys Gustavo de Morais (Jira)
2025/10/17 Community Health Initiative update David Radley
2025/10/17 [jira] [Created] (FLINK-38512) Postgres YAML CDC support database name with middlescore Hongshun Wang (Jira)
2025/10/17 Re: [VOTE] FLIP-547: Support checkpoint during recovery Gabor Somogyi
2025/10/17 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Feng Jin
2025/10/17 Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
2025/10/17 JIRA account unigogyk
2025/10/17 RE: FLINK-30975 - Flink Filesystem support for AWS SDK V2 ctrlaltdilj
2025/10/17 [jira] [Created] (FLINK-38496) Icerberg yaml sink need extra hadoop jar Hongshun Wang (Jira)
2025/10/17 [jira] [Created] (FLINK-38494) Add Chinese docs david radley (Jira)
2025/10/17 Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
2025/10/17 [jira] [Created] (FLINK-38524) Can not use python udtf with literal input Shengkai Fang (Jira)
2025/10/17 [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Aleksandr Iushmanov
2025/10/17 [jira] [Created] (FLINK-38465) Continue on error and metadata column support for HTTP connector david radley (Jira)
2025/10/17 Managing state in DataStream V2 watermark handlers Gunnar Morling
2025/10/17 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
2025/10/17 [jira] [Created] (FLINK-38487) Flink e2e ci failed Ruan Hang (Jira)
2025/10/17 Re: [VOTE] FLIP-547: Support checkpoint during recovery Yuepeng Pan
2025/10/17 [jira] [Created] (FLINK-38495) Introduce cache in delta join Xuyang Zhong (Jira)
2025/10/17 Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
2025/10/17 Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #2 Xiqian YU
2025/10/17 Re: Community Health Initiative update Robert Metzger
2025/10/17 Re: [VOTE] FLIP-549: Support Application Management Shengkai Fang
2025/10/17 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
2025/10/17 Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
2025/10/17 [VOTE] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment Hongshun Wang
2025/10/17 Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Dian Fu
2025/10/17 [jira] [Created] (FLINK-38482) Knit in http connector into Flink docs david radley (Jira)
2025/10/17 [VOTE] FLIP-549: Support Application Management Yi Zhang
2025/10/17 [jira] [Created] (FLINK-38505) RegionToRestartInStreamingJobBenchmarkTest failed in test_cron_jdk21 core Ruan Hang (Jira)
2025/10/17 [DISCUSS] Deprecation plan for Scala usage in connectors (e.g., Cassandra) Poorvank Bhatia
2025/10/17 Re: [DISCUSS] Flink 2.1.1 release Zakelly Lan
2025/10/17 Re: Support LIMIT syntax with SHOW queries Sriram Ganesh
2025/10/17 [jira] [Created] (FLINK-38499) Limit max sleep time in Curator for Zookeeper HA Mingliang Liu (Jira)
2025/10/17 Re: slack Gustavo de Morais
2025/10/17 [jira] [Created] (FLINK-38483) Job cannot be recovered from unaligned checkpoint , exception: Cannot get old subtasks from a descriptor that represents no state Rui Fan (Jira)
2025/10/17 [jira] [Created] (FLINK-38473) Upgrade Archunit to 1.4.1 Sergey Nuyanzin (Jira)
2025/10/17 [RESULT][VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xuannan Su
2025/10/17 [jira] [Created] (FLINK-38454) Inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus Timo Walther (Jira)
2025/10/17 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
2025/10/17 [ANNOUNCE] Apache Flink Kubernetes Operator 1.13.0 released Ferenc Csaky
2025/10/17 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
2025/10/17 [jira] [Created] (FLINK-38513) Github workflow of building python wheels on linux fails Zakelly Lan (Jira)
2025/10/17 slack Kosta Sovaridis
2025/10/17 [jira] [Created] (FLINK-38520) Postgres YAML CDC support array with null element Hongshun Wang (Jira)
2025/10/17 Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Gustavo de Morais
2025/10/17 [jira] [Created] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect Ruan Hang (Jira)
2025/10/17 Re: Missing CommittableSummary fix in release 1.20.0 Arvid Heise
2025/10/17 Re: [DISCUSS] Flink 2.0.1 release Ferenc Csaky
2025/10/17 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
2025/10/17 Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
2025/10/17 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
2025/10/17 [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Tejansh Rana
2025/10/17 Permanent CI issues Gabor Somogyi
2025/10/17 [jira] [Created] (FLINK-38517) Unable to Transition to Green for FlinkBlueGreenDeployment with "Ignored Fields" Daniel Rossos (Jira)
2025/10/17 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
2025/10/17 [jira] [Created] (FLINK-38525) Python udf doesn't handle TIMESTAMP_LTZ correctly Shengkai Fang (Jira)
2025/10/17 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
2025/10/17 [jira] [Created] (FLINK-38481) Remove http header and responses from logging in HTTP connector david radley (Jira)
2025/10/17 [jira] [Created] (FLINK-38518) RestoreTestBase should deduplicate data based on pk rather than simply concatenating expectedBeforeRestore and expectedAfterRestore Xuyang Zhong (Jira)
2025/10/17 Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Ferenc Csaky
2025/10/17 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
2025/10/17 [jira] [Created] (FLINK-38480) Continue on error and metadata column support for the HTTP connector david radley (Jira)
2025/10/17 [ANNOUNCE] Apache Flink Agents 0.1.0 released Xuannan Su
2025/10/17 Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Dawid Wysakowicz
2025/10/17 [jira] [Created] (FLINK-38516) Add Configuration Option to Enable Read-Only Mode for Flink SQL Gateway Rosa Seohwa Kang (Jira)
2025/10/17 Re: [DISCUSS] Flink 2.1.1 release Ron Liu
2025/10/17 Re: [VOTE] Release 2.0.1, release candidate #1 Gabor Somogyi
2025/10/17 Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Tom Cooper
2025/10/17 [jira] [Created] (FLINK-38508) Fix can not using python udf in SQL if decorator uses string as input or output types Shengkai Fang (Jira)
2025/10/17 Re: Request to review FLIP-490 contribution Yuepeng Pan
2025/10/17 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
2025/10/17 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
2025/10/17 Re: [VOTE] FLIP-549: Support Application Management Junrui Lee
2025/10/17 Re: [VOTE] Release 2.1.1, release candidate #1 Zakelly Lan
2025/10/16 [jira] [Created] (FLINK-38529) Silent record dropping when exceeding Kafka max.request.size Barak Ben-Nathan (Jira)
2025/10/16 Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Gustavo de Morais
2025/10/16 Re: Community Health Initiative update Xeno Amess
2025/10/15 [jira] [Created] (FLINK-38511) Join that consumes cdc record without delete can be converted to delta join Xuyang Zhong (Jira)
2025/10/15 [jira] [Created] (FLINK-38467) Caused by: java.lang.ClassCastException terrence (Jira)
2025/10/15 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
2025/10/15 Can Flink HA update the savepoint restorePath in the SubmittedJobGraph file on a regular basis? Qian, Gangling (LNG-CON)
2025/10/15 [SUMMARY] Flink 2.2 Release Sync 10/15/2025 Hang Ruan
2025/10/14 [jira] [Created] (FLINK-38527) Upgrade Netty version to 4.1.127.Final for Flink LTS 1.20 Mate Czagany (Jira)
2025/10/14 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
2025/10/14 Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Feng Jin
2025/10/14 [jira] [Created] (FLINK-38523) Upgrade Pekko to 1.2.0 Mate Czagany (Jira)
2025/10/14 [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
2025/10/14 is there a uber-jar solution in flink? I hate shade abusing. Xeno Amess
2025/10/14 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
2025/10/14 Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
2025/10/14 [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
2025/10/14 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
2025/10/14 [jira] [Created] (FLINK-38514) Postgres YAML CDC support UUID_ARRAY Hongshun Wang (Jira)
2025/10/13 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
2025/10/13 Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Alan Zhang
2025/10/13 Re: Permanent CI issues Gabor Somogyi
2025/10/13 Re: Permanent CI issues Hang Ruan
2025/10/13 FW: RE: [ANNOUNCE] Apache flink-connector-jdbc 3.3.0 & 4.0.0 released David Radley
2025/10/13 Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xuannan Su
2025/10/13 [jira] [Created] (FLINK-38510) Remove targetColumns in SinkReuser xiangyu feng (Jira)
2025/10/13 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
2025/10/12 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
2025/10/12 [jira] [Created] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests Ruan Hang (Jira)
2025/10/12 [jira] [Created] (FLINK-38504) Add restore test for delta join Xuyang Zhong (Jira)
2025/10/12 [Discuss] JDBC Connector SplitReader pass ResultSet with cursor at the first row-resend with the right tag clara xiong
2025/10/11 [jira] [Created] (FLINK-38488) Use 'throws Exception' instead of try-catch-fail in tests in flink-tests Mingliang Liu (Jira)
2025/10/11 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
2025/10/10 Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Feng Jin
2025/10/10 [jira] [Created] (FLINK-38497) FLIP-535:Introduce RateLimiter to Source Yanquan Lv (Jira)
2025/10/10 Re: DEFAULT values for columns Gustavo de Morais
2025/10/10 Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
2025/10/09 Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Zhu Zhu
2025/10/09 Re: Permanent CI issues Gabor Somogyi
2025/10/09 Re: [ANNOUNCE] Apache flink-connector-jdbc 3.3.0 & 4.0.0 released Leonard Xu
2025/10/09 Re: RE: [ANNOUNCE] Apache flink-connector-jdbc 3.3.0 & 4.0.0 released Teunissen, F.G.J. (Fred)
2025/10/08 [jira] [Created] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound Etienne Chauchot (Jira)
2025/10/06 Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
2025/10/06 [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
2025/10/05 [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
2025/10/05 [jira] [Created] (FLINK-38477) Add FINISHED watermark status to support proper watermark aggregation Weiqing Yang (Jira)
2025/10/05 [jira] [Created] (FLINK-38476) Add FINISHED watermark status to support proper watermark aggregation Weiqing Yang (Jira)
2025/10/02 Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #2 Yanquan Lv
2025/10/02 [jira] [Created] (FLINK-38415) IndexOutOfBoundsException occasionally occursIndexOutOfBoundsException in rocksdb.use-ingest-db-restore-mode after rocksdb.use-ingest-db-restore-mode is enabled Rui Fan (Jira)
2025/10/02 Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
2025/10/02 [jira] [Created] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector Fabian Paul (Jira)
2025/10/02 Re: Managing state in DataStream V2 watermark handlers Xintong Song
2025/10/01 [jira] [Created] (FLINK-38470) Make CreateMaterializedTableOperation return ResolvedCatalogMaterializedTable Ramin Gharib (Jira)
2025/10/01 [jira] [Created] (FLINK-38469) Bump apache-beam for PyFlink to >= 2.66 to address CVE-2024-52338 for pyarrow Wren (Jira)
2025/10/01 DEFAULT values for columns David Anderson
2025/10/01 Re: [DISCUSS] FLIP-549: Support Application Management Kartikey Pant
2025/09/30 Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
2025/09/30 Re: [DISCUSS] FLIP-549: Support Application Management Venkatakrishnan Sowrirajan
2025/09/30 [jira] [Created] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 Roman Khachatryan (Jira)
2025/09/30 [jira] [Created] (FLINK-38458) Extract SchemaConverter and ReferenceManager to make them reusable Sergey Nuyanzin (Jira)
2025/09/29 [jira] [Created] (FLINK-38455) MySQL CDC to ES8 pipeline connector cannot work li yong (Jira)
2025/09/29 Re: [DISCUSS] Flink 2.1.1 release Ferenc Csaky
2025/09/29 Re: [DISCUSS] FLIP-549: Support Application Management Ryan van Huuksloot
2025/09/29 [DISCUSS] Flink 2.0.1 release Zakelly Lan
2025/09/29 Re: Request for Apache Flink Slack Invite Gustavo de Morais
2025/09/29 Missing CommittableSummary fix in release 1.20.0 Chibaev, Ilia
2025/09/27 [jira] [Created] (FLINK-38450) flink-cdc sink to iceberg table record duplication ChaoFang (Jira)
2025/09/27 Re: [DISCUSS] FLIP-549: Support Application Management Lei Yang
2025/09/27 Re: Support LIMIT syntax with SHOW queries Shengkai Fang