dev  

Messages by Thread

• • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Piotr Nowojski
  • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Yash Anand
  • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Ron Liu
  • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Hao Li
  • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Hao Li
  • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Timo Walther
  • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Timo Walther
  • Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Hao Li
• [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Shengkai Fang
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Piotr Nowojski
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Yash Anand
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Yunfeng Zhou
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Ron Liu
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Ron Liu
  • Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li
• [jira] [Created] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer David (Jira)
• KinesisStreamSource de-aggregation support via DeserializationSchema Lorenzo Nicora
  • Re: KinesisStreamSource de-aggregation support via DeserializationSchema Ahmed Hamdy
  • Re: KinesisStreamSource de-aggregation support via DeserializationSchema Lorenzo Nicora
• [jira] [Created] (FLINK-37746) Missing serialVersionUID in MapTypeInfo class Pranav Mahajan (Jira)
• [jira] [Created] (FLINK-37745) ChangelogModeJsonSerializer doesn't handle partial deletes Timo Walther (Jira)
• [jira] [Created] (FLINK-37744) [Helm] Add Helm lint and test CI Yi Chen (Jira)
• [jira] [Created] (FLINK-37743) Add benchmark test for Flink CDC Pipeline job Yanquan Lv (Jira)
• [DISCUSS] FLIP-528 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ramin Gharib
• [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ramin Gharib
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL David Radley
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ramin Gharib
  • RE: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL David Radley
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ron Liu
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Martijn Visser
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Gustavo de Morais
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Timo Walther
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Dawid Wysakowicz
  • RE: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL David Radley
  • Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ramin Gharib
  • RE: Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Gustavo de Morais
• [jira] [Created] (FLINK-37742) POJO type expected but was: GenericType when resume from savepoint Youjun Yuan (Jira)
• [jira] [Created] (FLINK-37741) Severe performance regression of transform operator node yux (Jira)
• [jira] [Created] (FLINK-37740) Fix flink-docker snapshots GitHub workflow Muhammet Orazov (Jira)
• [VOTE] Apache Flink CDC Release 3.4.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #2 Hongshun Wang
  • Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #2 Leonard Xu
  • Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #2 Yanquan Lv
• [jira] [Created] (FLINK-37739) flink-conf is not obtained in local mode MOBIN (Jira)
• [VOTE] Apache Flink CDC Release 3.4.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #1 Xiqian YU
  • Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #1 Yanquan Lv
• [jira] [Created] (FLINK-37738) [cdc-connector][postgres] Support read changelog as append only mode Hongshun Wang (Jira)
• [jira] [Created] (FLINK-37737) Add support for GaussDB database type Yong.Tang (Jira)
• [jira] [Created] (FLINK-37736) Introduce Flink CDC metrics doc ouyangwulin (Jira)
• [jira] [Created] (FLINK-37735) Replace class.newInstance with constructor.newInstance Zhanghao Chen (Jira)
• [DISCUSS] Release Flink CDC version 3.4.0 Yanquan Lv
  • Re: [DISCUSS] Release Flink CDC version 3.4.0 Leonard Xu
  • Re: [DISCUSS] Release Flink CDC version 3.4.0 Hang Ruan
  • Re: [DISCUSS] Release Flink CDC version 3.4.0 ConradJam
• [jira] [Created] (FLINK-37734) Update version to 3.5-SNAPSHOT and update related docs Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37733) Externalise DynamoDB IT Test to E2E test package Daren Wong (Jira)
• [jira] [Created] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
• [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Zakelly Lan
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Zakelly Lan
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Hangxiang Yu
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Shengkai Fang
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Shengkai Fang
  • Re: [DISCUSS] State Schema Evolution for RowData Hongshun Wang
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Gabor Somogyi
• [jira] [Created] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket Yanquan Lv (Jira)
• 2025/04/24 CHI Eastern time zone workgroup meeting minutes David Radley
• Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Lincoln Lee
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Xuannan Su
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Timo Walther
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Xuannan Su
  • RE: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing David Radley
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Xuannan Su
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Aihua Xu
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Xuannan Su
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Xuannan Su
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Timo Walther
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Xuannan Su
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Alexey Leonov-Vendrovskiy
  • Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing Xuannan Su
• [jira] [Created] (FLINK-37730) Collect job exceptions as kubernetes events Robert Metzger (Jira)
• [jira] [Created] (FLINK-37729) Implement ResultTypeQueryable for Avro serialization schema Pawel Leszczynski (Jira)
• [jira] [Created] (FLINK-37727) java.lang.UnsatisfiedLinkError error on pemja.core.PythonInterpreter$MainInterpreter.initialize() Shuyi Chen (Jira)
• [jira] [Created] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java Shuyi Chen (Jira)
• [DISCUSS] FLIP-486: Introduce a new DeltaJoin Xuyang
  • Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin weijie guo
  • Re:Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Xuyang
  • Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Ron Liu
  • Re:Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Xuyang
  • Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Feng Jin
  • Re:Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Xuyang
  • Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Ron Liu
  • Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin xiangyu feng
  • Re:Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Xuyang
  • Re:Re:Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Xuyang
  • Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Gustavo de Morais
  • Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Gustavo de Morais
  • Re:Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin Xuyang
• Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode Ron Liu
  • Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode shuai xu
  • Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode shuai xu
• [jira] [Created] (FLINK-37726) Read incremental data for existing tables Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar Alan Sheinberg (Jira)
• [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
  • Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
  • Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Becket Qin
  • Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Guowei Ma
  • Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Sharath
  • Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch weijie guo
  • Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Matt Cuento
  • Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Weiqing Yang
• [jira] [Created] (FLINK-37724) Add AsyncTableFunction as new UDF type Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37721) Fix Janino Bug which resulted in Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37720) Enable table.optimizer.reuse-sink by default xiangyu feng (Jira)
• [jira] [Created] (FLINK-37719) Support Java 25 (LTS) Liam Miller-Cushon (Jira)
• [DISCUSS] FLIP-516: Multi-Way Join Operator Gustavo de Morais
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Arvid Heise
  • RE: [DISCUSS] FLIP-516: Multi-Way Join Operator David Radley
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Gustavo de Morais
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Gustavo de Morais
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Ferenc Csaky
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Gustavo de Morais
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Ron Liu
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Gustavo de Morais
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Arvid Heise
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Gustavo de Morais
  • Re: [DISCUSS] FLIP-516: Multi-Way Join Operator Gustavo de Morais
• [jira] [Created] (FLINK-37718) Refactor ApplicationSubmissionContextReflector tianzhu.wen (Jira)
• [jira] [Created] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data vertern (Jira)
• [ANNOUNCE] Apache flink-connector-kafka 4.0.0 released Arvid Heise
• [RESULT][VOTE] FLIP-522: Add generalized type information to SQL state connector Gabor Somogyi
• Re: [DISCUSS] FlinkSQL support enableObjectReuse to optimize CopyingChainingOutput Zhanghao Chen
  • Re: [DISCUSS] FlinkSQL support enableObjectReuse to optimize CopyingChainingOutput Zhanghao Chen
• [jira] [Created] (FLINK-37716) Simplify YarnClusterDescriptor by removing parameter JobGraph Jiaan Geng (Jira)
• FW: Kryo v2 to v5 migration tool David Radley
  • FW: Kryo v2 to v5 migration tool David Radley
  • FW: Kryo v2 to v5 migration tool Kurt Ostfeld
• Re: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs Shengkai Fang
• [jira] [Created] (FLINK-37715) Flink try use winutils.exe even without hadoop Nick M (Jira)
• Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Doğuşcan Namal
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Gabor Somogyi
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Nicolas Fraison
  • Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal Alex Nitavsky
• [SUMMARY] Flink 2.1 Release Sync 04/23/2025 Ron Liu
• [RESULT][VOTE] Release flink-connector-kafka v4.0.0, release candidate #3 Arvid Heise
• Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #3 Sergey Nuyanzin
  • Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #3 Robert Metzger
  • Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #3 Arvid Heise
• [jira] [Created] (FLINK-37714) KafkaTableITCase generates artifacts in main path Sergey Nuyanzin (Jira)
• Re: [DISCUSS] FLIP-518: Introduce a community review process David Radley
  • Re: [DISCUSS] FLIP-518: Introduce a community review process Robert Metzger
  • [VOTE] FLIP-518: Introduce a community review process David Radley
  • Re: [VOTE] FLIP-518: Introduce a community review process Robert Metzger
  • [VOTE] FLIP-518: Introduce a community review process David Radley
  • FW: [VOTE] FLIP-518: Introduce a community review process David Radley
  • Re: [VOTE] FLIP-518: Introduce a community review process Ferenc Csaky
  • [VOTE] FLIP-518: Introduce a community review process Hong Liang
  • Re: [VOTE] FLIP-518: Introduce a community review process Yuepeng Pan
  • Re: [VOTE] FLIP-518: Introduce a community review process Robert Metzger
  • [DISCUSS] FLIP-518: Introduce a community review process David Radley
  • FW: [DISCUSS] FLIP-518: Introduce a community review process David Radley
  • FW: [DISCUSS] FLIP-518: Introduce a community review process David Radley
• Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Timo Walther
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Timo Walther
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Hao Li
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Timo Walther
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Arvid Heise
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Hao Li
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Timo Walther
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Arvid Heise
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Hao Li
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Timo Walther
  • Re: [DISCUSS] FLIP-520: Simplify StructuredType handling Timo Walther

• Later messages