dev  

Messages by Thread

• Re: [VOTE] Release 1.20.3, release candidate #1 Dian Fu
  • Re: [VOTE] Release 1.20.3, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.20.3, release candidate #1 Maximilian Michels
  • ???? ????
• [jira] [Created] (FLINK-38424) Support to parse VECTOR_SEARCH table function Shengkai Fang (Jira)
• [SUMMARY] Flink 2.2 Release Sync 10/01/2025 Hang Ruan
• [jira] [Created] (FLINK-38484) community review github action stopped working david radley (Jira)
• [jira] [Created] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Biao Geng (Jira)
• Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Etienne Chauchot
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Gustavo de Morais
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Gyula Fora
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Ferenc Csaky
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Ferenc Csaky
• [jira] [Created] (FLINK-38519) Custom Message Keys with PyFlink Kafka Sink Sebastian YEPES FERNANDEZ (Jira)
• [VOTE] Release 2.0.1, release candidate #1 Zakelly Lan
  • Re: [VOTE] Release 2.0.1, release candidate #1 Mate Czagany
  • Re: [VOTE] Release 2.0.1, release candidate #1 Rui Fan
  • Re: [VOTE] Release 2.0.1, release candidate #1 Han Yin
  • Re: [VOTE] Release 2.0.1, release candidate #1 Leonard Xu
  • Re: [VOTE] Release 2.0.1, release candidate #1 Yuan Mei
  • Re: [VOTE] Release 2.0.1, release candidate #1 Hongshun Wang
  • Re: [VOTE] Release 2.0.1, release candidate #1 Hang Ruan
  • Re: [VOTE] Release 2.0.1, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 2.0.1, release candidate #1 Zakelly Lan
• Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Őrhidi Mátyás
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Hao Li via dev
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Geng Biao
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Shengkai Fang
  • Re: [Question] use ML_PREDICT/ML_EVALUATE with python model provider in Flink Swapna Marru
• Request to review FLIP-490 contribution Yuepeng Pan
• Re: Request for slack invite Gustavo de Morais
• [jira] [Created] (FLINK-38437) Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator Jira
• [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Lincoln Lee
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Timo Walther
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Timo Walther
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
• [ANNOUNCE] Apache Flink 1.20.3 released Xuannan Su
• [jira] [Created] (FLINK-38509) Dynamic Credentials in Flink for Google Cloud Storage Royston Tauro (Jira)
• [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Leonard Xu
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Yanquan Lv
• [jira] [Created] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38474) Add java25-target profile Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support Poorvank Bhatia (Jira)
• Community review git action failing David Radley
• [jira] [Created] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for Database connections which require SSL. John Watson (Jira)
• [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xuannan Su
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Yunfeng Zhou
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xintong Song
  • RE: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 wenjin
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Dian Fu
• Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Timo Walther
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ramin Gharib
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Gustavo de Morais
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Lincoln Lee
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Arvid Heise
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Feng Jin
  • Re: [VOTE] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
• [jira] [Created] (FLINK-38493) Port Calcite's fix for LITERAL is lost while validation Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38464) Introduce OrderedMultiSetState (view) Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator Arvid Heise (Jira)
• [jira] [Created] (FLINK-38445) Create test plans to validate upsert keys Gustavo de Morais (Jira)
• Community Health Initiative update David Radley
  • Re: Community Health Initiative update Robert Metzger
  • Re: Community Health Initiative update Pedro Mázala
• [jira] [Created] (FLINK-38512) Postgres YAML CDC support database name with middlescore Hongshun Wang (Jira)
• Re: [VOTE] FLIP-547: Support checkpoint during recovery Gabor Somogyi
  • Re: [VOTE] FLIP-547: Support checkpoint during recovery Yuepeng Pan
• JIRA account unigogyk
• RE: FLINK-30975 - Flink Filesystem support for AWS SDK V2 ctrlaltdilj
  • FLINK-30975 - Flink Filesystem support for AWS SDK V2 ctrlaltdilj
• [jira] [Created] (FLINK-38496) Icerberg yaml sink need extra hadoop jar Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38494) Add Chinese docs david radley (Jira)
• [jira] [Created] (FLINK-38524) Can not use python udtf with literal input Shengkai Fang (Jira)
• [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Piotr Nowojski
  • Re: [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Rui Fan
  • Re: [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Efrat Levitan
  • Re: [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Kartikey Pant
• [jira] [Created] (FLINK-38465) Continue on error and metadata column support for HTTP connector david radley (Jira)
• Managing state in DataStream V2 watermark handlers Gunnar Morling
  • Re: Managing state in DataStream V2 watermark handlers Gunnar Morling
• [jira] [Created] (FLINK-38487) Flink e2e ci failed Ruan Hang (Jira)
• [jira] [Created] (FLINK-38495) Introduce cache in delta join Xuyang Zhong (Jira)
• Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #2 Xiqian YU
• Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Shengkai Fang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
  • Re: [DISCUSS] FLIP-549: Support Application Management Yi Zhang
• [VOTE] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment Hongshun Wang
  • Re: [VOTE] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment Leonard Xu
  • Re: [VOTE] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment Hang Ruan
  • Re: [VOTE] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment Xiqian YU
• [jira] [Created] (FLINK-38482) Knit in http connector into Flink docs david radley (Jira)
• [VOTE] FLIP-549: Support Application Management Yi Zhang
  • Re: [VOTE] FLIP-549: Support Application Management Zhu Zhu
  • Re: [VOTE] FLIP-549: Support Application Management Shengkai Fang
  • Re: [VOTE] FLIP-549: Support Application Management Yi Zhang
• [jira] [Created] (FLINK-38505) RegionToRestartInStreamingJobBenchmarkTest failed in test_cron_jdk21 core Ruan Hang (Jira)
• [DISCUSS] Deprecation plan for Scala usage in connectors (e.g., Cassandra) Poorvank Bhatia
  • Re: [DISCUSS] Deprecation plan for Scala usage in connectors (e.g., Cassandra) Etienne Chauchot
• Re: Support LIMIT syntax with SHOW queries Sriram Ganesh
• [jira] [Created] (FLINK-38499) Limit max sleep time in Curator for Zookeeper HA Mingliang Liu (Jira)
• [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)
• [jira] [Created] (FLINK-38473) Upgrade Archunit to 1.4.1 Sergey Nuyanzin (Jira)
• [RESULT][VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xuannan Su
• [jira] [Created] (FLINK-38454) Inconsistent idle behavior between StatusWatermarkValve and CombinedWatermarkStatus Timo Walther (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.13.0 released Ferenc Csaky
• [jira] [Created] (FLINK-38513) Github workflow of building python wheels on linux fails Zakelly Lan (Jira)
• slack Kosta Sovaridis
  • Re: slack Gustavo de Morais
• [jira] [Created] (FLINK-38520) Postgres YAML CDC support array with null element Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38507) OpenTelemetryTraceReporterITCase failed in Test - connect Ruan Hang (Jira)
• Re: Missing CommittableSummary fix in release 1.20.0 Arvid Heise
• Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Feng Jin
  • Re: [DISCUSS] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib
• [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Tejansh Rana
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Tejansh Rana
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Gunnar Morling
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Tejansh Rana
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Tejansh Rana
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Hang Ruan
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Leonard Xu
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Tejansh Rana
  • Re: [PROPOSAL] Support for MySQL Transaction Boundary Events in Flink CDC Connector Tejansh Rana
• Permanent CI issues Gabor Somogyi
  • Re: Permanent CI issues Gabor Somogyi
• [jira] [Created] (FLINK-38517) Unable to Transition to Green for FlinkBlueGreenDeployment with "Ignored Fields" Daniel Rossos (Jira)
• [jira] [Created] (FLINK-38525) Python udf doesn't handle TIMESTAMP_LTZ correctly Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38481) Remove http header and responses from logging in HTTP connector david radley (Jira)
• [jira] [Created] (FLINK-38518) RestoreTestBase should deduplicate data based on pk rather than simply concatenating expectedBeforeRestore and expectedAfterRestore Xuyang Zhong (Jira)
• Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Ferenc Csaky
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Piotr Nowojski
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Gabor Somogyi
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Piotr Nowojski
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Martijn Visser
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Ferenc Csaky
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Mate Czagany
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Gabor Somogyi
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Ferenc Csaky
  • Re: [DISCUSSION] Native S3 Filesystem in Apache Flink Samrat Deb
• [jira] [Created] (FLINK-38480) Continue on error and metadata column support for the HTTP connector david radley (Jira)
• [ANNOUNCE] Apache Flink Agents 0.1.0 released Xuannan Su
• Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Dawid Wysakowicz
  • Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Arvid Heise
  • Re: [VOTE] FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib

• Later messages