dev  

Messages by Thread

• • Re: [RESULT] [VOTE] Release 2.1.0, release candidate #1 Ron Liu
  • Re: [RESULT] [VOTE] Release 2.1.0, release candidate #1 Maximilian Michels
• [jira] [Created] (FLINK-38150) Fail in planning if window boundary is not numeric/interval_day_time Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38149) Convert COLUMN_LIST to DescriptorType Ramin Gharib (Jira)
• [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Timo Walther
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Ramin Gharib
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Jacky Lau
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Timo Walther
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Yash Anand
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Hao Li
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Shengkai Fang
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Natea Eshetu Beshada
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Gustavo de Morais
  • Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz
• [jira] [Created] (FLINK-38148) Failed serialization of JobExceptionsInfoWithHistory in flink-kubernetes-operator Jira
• [jira] [Created] (FLINK-38147) Add Flink 2.1 support to operator Gyula Fora (Jira)
• [jira] [Created] (FLINK-38146) support config for create filesystem jonasjc (Jira)
• [jira] [Created] (FLINK-38145) Fix ReflectiveDiffBuilder config comparison to properly handle deleted configuration entries yuanfenghu (Jira)
• [DISCUSS] FLIP-538: Support Custom Generic Type Serializer Zhanghao Chen
  • Re:[DISCUSS] FLIP-538: Support Custom Generic Type Serializer Yuepeng Pan
• [jira] [Created] (FLINK-38144) Change log state backend is not compatible with the case where the user value of the map state is null Rui Fan (Jira)
• [jira] [Created] (FLINK-38143) Pyflink flat YAML based config support is broken Gabor Somogyi (Jira)
• [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project Joao Boto
  • Re: [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project Tom Cooper
  • Re: [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project Leonard Xu
  • Re: [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project João Boto
  • Re: [Discuss][Proposal] Decouple the Debezium Connector from the Flink CDC Project João Boto
• [jira] [Created] (FLINK-38142) Bump the version of Paimon flink to 1.2.0 Muhammad (Jira)
• Re: Flink Connector Kafka Releases Tom Cooper
  • Re: Flink Connector Kafka Releases Fabian Paul
  • Re: Flink Connector Kafka Releases Tom Cooper
  • Re: Flink Connector Kafka Releases Fabian Paul
  • Re: Flink Connector Kafka Releases Tom Cooper
  • Re: Flink Connector Kafka Releases Weiqing Yang
  • Re: Flink Connector Kafka Releases Fabian Paul
  • Re: Flink Connector Kafka Releases Weiqing Yang
  • Re: Flink Connector Kafka Releases Tom Cooper
  • RE: Flink Connector Kafka Releases David Radley
  • RE: Flink Connector Kafka Releases Tom Cooper
  • RE: Flink Connector Kafka Releases David Radley
  • RE: Flink Connector Kafka Releases Tom Cooper
• [jira] [Created] (FLINK-38141) Iceberg sink has an incorrect type conversion ZhangChao (Jira)
• [jira] [Created] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations Alan Sheinberg (Jira)
• Re: [VOTE] FLIP-400: AsyncScalarFunction for asynchronous scalar function support Alan Sheinberg
  • Re: [VOTE] FLIP-400: AsyncScalarFunction for asynchronous scalar function support Hao Li
• I'm migrating https://github.com/apache/flink-training to 2.0.0 Xeno Amess
  • Re: I'm migrating https://github.com/apache/flink-training to 2.0.0 Xeno Amess
• [jira] [Created] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector Voon Hou (Jira)
• [jira] [Created] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38136) Add restore tests for PTFs Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38135) Non-existent method for RAW type hashing dylanhz (Jira)
• [jira] [Created] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference. yangyu (Jira)
• [jira] [Created] (FLINK-38133) Unable to find checkpoint status analysis during Flink restart on k8s，jobmanager created by deployment， jeremyMu (Jira)
• [jira] [Created] (FLINK-38132) CLONE - Improve the CSV reading process huyuliang (Jira)
• [jira] [Created] (FLINK-38131) Repartition BroadcastState with finished operators Renxiang Zhou (Jira)
• [jira] [Created] (FLINK-38130) The python linux wheel package name is duplicated dalongliu (Jira)
• [jira] [Created] (FLINK-38126) CLONE - Deploy Python artifacts to PyPI dalongliu (Jira)
• [jira] [Created] (FLINK-38129) CLONE - Publish the Dockerfiles for the new release dalongliu (Jira)
• [jira] [Created] (FLINK-38127) CLONE - Deploy artifacts to Maven Central Repository dalongliu (Jira)
• [jira] [Created] (FLINK-38128) CLONE - Create Git tag and mark version as released in Jira dalongliu (Jira)
• [jira] [Created] (FLINK-38125) Finalize release 2.1.0 dalongliu (Jira)
• Re: [DISCUSS] Projection pushdown support in Flink Kafka Table connector Hongshun Wang
  • Re: [DISCUSS] Projection pushdown support in Flink Kafka Table connector Farooq Qaiser
• [jira] [Created] (FLINK-38124) The autoscaling example misses README Andrei Kaigorodov (Jira)
• [jira] [Created] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1. Andrei Kaigorodov (Jira)
• [VOTE] Release 2.1.0, release candidate #1 Ron Liu
  • Re: [VOTE] Release 2.1.0, release candidate #1 Xingbo Huang
  • Re: [VOTE] Release 2.1.0, release candidate #1 Teunissen, F.G.J. (Fred)
  • Re: [VOTE] Release 2.1.0, release candidate #1 Ron Liu
  • Re: [VOTE] Release 2.1.0, release candidate #1 Ron Liu
  • Re: [VOTE] Release 2.1.0, release candidate #1 Lincoln Lee
  • Re: [VOTE] Release 2.1.0, release candidate #1 Lincoln Lee
  • Re: [VOTE] Release 2.1.0, release candidate #1 Lincoln Lee
  • Re:Re: [VOTE] Release 2.1.0, release candidate #1 Xuyang
  • Re: Re: [VOTE] Release 2.1.0, release candidate #1 Xingbo Huang
  • Re: Re: [VOTE] Release 2.1.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 2.1.0, release candidate #1 Xiqian YU
  • Re: [VOTE] Release 2.1.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Release 2.1.0, release candidate #1 Ron Liu
  • Re: [VOTE] Release 2.1.0, release candidate #1 Hongshun Wang
  • Re: [VOTE] Release 2.1.0, release candidate #1 Zakelly Lan
  • Re: [VOTE] Release 2.1.0, release candidate #1 Ron Liu
  • Re: [VOTE] Release 2.1.0, release candidate #1 Zakelly Lan
  • Re: [VOTE] Release 2.1.0, release candidate #1 Hang Ruan
  • Re: [VOTE] Release 2.1.0, release candidate #1 Zhu Zhu
  • Re: [VOTE] Release 2.1.0, release candidate #1 Zexian WU
  • Re: [VOTE] Release 2.1.0, release candidate #1 Zexian WU
  • Re: [VOTE] Release 2.1.0, release candidate #1 Zexian WU
• [jira] [Created] (FLINK-38122) Creating structured types with no fully defining constructor results in wrong results Ramin Gharib (Jira)
• Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Yanquan Lv
  • RE: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Zexian WU
  • RE: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 Zexian WU
  • RE: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 André Diniz
  • RE: Re: [VOTE] Release flink-connector-aws v5.1.0, release candidate #1 André Diniz
• [jira] [Created] (FLINK-38121) Build python wheel on linux failed dalongliu (Jira)
• [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • RE: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Leonard Xu
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Becket Qin
  • Re: [DISCUSS] FLIP-537: Enumerator with Global Split Assignment Distribution for Balanced Split assignment Hongshun Wang
• 2025/07/17 CHI Eastern time zone workgroup meeting minutes David Radley
• [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API David Radley
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Poorvank Bhatia
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Chesnay Schepler
  • Re: [DISCUSS][FLIP-536] Add latest checkpoint details endpoint to Rest API Ahmed Hamdy
• [jira] [Created] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint Ahmed Hamdy (Jira)
• Looking for reviewers and voters for flink-connector-aws v5.1.0 release Daren Wong
• 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-38119) [Unstable test]IcebergWriterTest.testWriteWithAllSupportedTypes:344 Yanquan Lv (Jira)
• [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Leonard Xu
  • RE: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Shengkai Fang
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Jiangang Liu
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Jiangang Liu
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Arvid Heise
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source 魏宪党
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
  • Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Leonard Xu
  • Re: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source 魏宪党
  • RE: Re: [DISCUSS] FLIP-535:Introduce RateLimiter to Source Zexian WU
• [jira] [Created] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode shilei-ly (Jira)
• [jira] [Created] (FLINK-38117) Add anonymous ContextResolvedModel Hao Li (Jira)
• [jira] [Created] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error David Ballano (Jira)
• [jira] [Created] (FLINK-38115) Synchronous the Python JDBC connector with the Java implementation Dian Fu (Jira)
• [jira] [Created] (FLINK-38114) Allow offloading of task restore Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-38112) Change default of yarn.application-attempt-failures-validity-interval to -1 yude (Jira)
• [jira] [Created] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service yuan (Jira)
• [jira] [Created] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters haiqingchen (Jira)
• [jira] [Created] (FLINK-38109) BlobServer isn't associated with the correct bind-host Rosa Seohwa Kang (Jira)
• Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Mayank Juneja
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Austin Cawley-Edwards
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Mayank Juneja
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Timo Walther
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Shengkai Fang
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Leonard Xu
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hao Li
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Yanquan Lv
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hao Li
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Leonard Xu
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hao Li
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hao Li
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Leonard Xu
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Timo Walther
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hao Li
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Leonard Xu
  • [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hongshun Wang
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hao Li
  • Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API Hongshun Wang
• RE: Re: Flink Kubenetes Operator client version Nic Townsend

• Later messages