dev  

Messages by Thread

• Slack Invitation Expired Arnav Kulkarni
  • Re: Slack Invitation Expired Natea Eshetu Beshada
• 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
• [jira] [Created] (FLINK-38316) Clarify on some of the names in the source Marton Greber (Jira)
• [SUMMARY] Flink 2.2 Release Sync 09/03/2025 Hang Ruan
• [jira] [Created] (FLINK-38315) Performance regression since August 21 Ruan Hang (Jira)
• [jira] [Created] (FLINK-38309) Add Basic Authentication Support to OpenTelemetry HTTP Metrics Reporter Kumar Mallikarjuna (Jira)
• Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Xiqian YU
  • Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Jiangang Liu
  • Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Yanquan Lv
  • Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Hongshun Wang
  • Re: [VOTE] FLIP-535: Introduce RateLimiter to Source Yanquan Lv
• Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl via dev
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
• [jira] [Created] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed Sergei Morozov (Jira)
• [RESULT][VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin
• [jira] [Created] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin (Jira)
• [Discuss] Pre/Post Scaling Hooks during Autoscaling Diljeet Singh
• Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Becket Qin
  • Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Wei Zhong
  • Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Rui Fan
  • Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Zhanghao Chen
  • [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
• [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Mate Czagany
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
  • RE: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables David Radley
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
  • RE: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables David Radley
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ron Liu
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Timo Walther
  • Re: [DISCUSS] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
• Re: [Discuss] Improving Autoscaler Behavior for Jobs with Large Number of Tasks Gyula Fóra
  • Re: [Discuss] Improving Autoscaler Behavior for Jobs with Large Number of Tasks Sharath
  • Re: [Discuss] Improving Autoscaler Behavior for Jobs with Large Number of Tasks Gyula Fóra
  • Re: [Discuss] Improving Autoscaler Behavior for Jobs with Large Number of Tasks Sharath
• [jira] [Created] (FLINK-38308) Prevent excessive logging from parsing SQL timestamps/dates Roman Khachatryan (Jira)
• Kafka 4.x Queue Semantics in Flink Connector Kafka RShekhar Prasad
  • Re: Kafka 4.x Queue Semantics in Flink Connector Kafka Gyula Fóra
  • Re: Kafka 4.x Queue Semantics in Flink Connector Kafka RShekhar Prasad
  • RE: Kafka 4.x Queue Semantics in Flink Connector Kafka David Radley
  • Re: Kafka 4.x Queue Semantics in Flink Connector Kafka RShekhar Prasad
• [jira] [Created] (FLINK-38307) Resuming from both savepoints and checkpoints is NOT supported for Changelog State Backend Naci Simsek (Jira)
• [jira] [Created] (FLINK-38296) Do documentation david radley (Jira)
• [jira] [Created] (FLINK-38302) change the config to use Flink config parameter names and gid fallback keys david radley (Jira)
• [DISCUSS] FLIP-XXX Make JAR keyword optional in CREATE FUNCTION's USING clause Zander Matheson
• [jira] [Created] (FLINK-38304) Re write README david radley (Jira)
• [jira] [Created] (FLINK-38306) knit in the http connector docs into the Flink docs david radley (Jira)
• [jira] [Created] (FLINK-38305) amend the prefix to not include gid and move to Flink david radley (Jira)
• [jira] [Created] (FLINK-38303) default to use query-creator generic-json-url david radley (Jira)
• [jira] [Created] (FLINK-38301) confirm Maven snapshot is working david radley (Jira)
• [jira] [Created] (FLINK-38300) work out Flink v2 support (should work) david radley (Jira)
• [jira] [Created] (FLINK-38299) amend push github action to go against v1 snapsort david radley (Jira)
• [jira] [Created] (FLINK-38297) wiremock version is very old - migrate to a later level david radley (Jira)
• [jira] [Created] (FLINK-38298) Remove mockito dependancy so we do not need to exclude from banned checklist david radley (Jira)
• [jira] [Created] (FLINK-38295) Amend parent connector pom version to 1.1.0 david radley (Jira)
• Slack invite David Geraghty
• http connector Jira component required David Radley
• 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-38294) Hbase connector misclassifies failed task as successful Chu Xue (Jira)
• 2025/08/28 CHI Eastern time zone workgroup meeting minutes David Radley
• [VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin
  • Re: [VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Ron Liu
  • Re: [VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Feng Jin
  • Re: [VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Ramin Gharib
  • Re: [VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Timo Walther
  • Re: [VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin
• [jira] [Created] (FLINK-38291) Reduce thread lock overhead for Flink UI REST handlers Yunfeng Zhou (Jira)
• [jira] [Created] (FLINK-38293) Update Checkstyle version and related rules in Kubernetes Operator Jira
• [jira] [Created] (FLINK-38292) Flink CDC doesn't support altering table properties for Paimon Sinks Muhammad (Jira)
• Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Timo Walther
  • Re: [DISCUSS] FLIP-542: Support DISTRIBUTED BY/INTO for Materialized tables Sergey Nuyanzin
• [DISCUSS] FLIP-430: Remote Compaction For Disaggregated State Han Yin
  • Re: [DISCUSS] FLIP-430: Remote Compaction For Disaggregated State Zakelly Lan
  • Re: [DISCUSS] FLIP-430: Remote Compaction For Disaggregated State Han Yin
  • Re: [DISCUSS] FLIP-430: Remote Compaction For Disaggregated State Zakelly Lan
• [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Roman Khachatryan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Zakelly Lan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Roman Khachatryan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Zakelly Lan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Roman Khachatryan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Piotr Nowojski
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Rui Fan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Roman Khachatryan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Rui Fan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Zakelly Lan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Roman Khachatryan
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Lincoln Lee
  • Re: [DISCUSS] FLIP - 544 SinkUpsertMaterializer V2 Roman Khachatryan
• [jira] [Created] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM restarts Urs Schoenenberger (Jira)
• [jira] [Created] (FLINK-38289) Update Flink Connector Kafka to use Flink 2.1 Thomas Cooper (Jira)
• [jira] [Created] (FLINK-38288) Improve BlobWriter logging to include TaskRestore offloading duration Aleksandr Iushmanov (Jira)
• Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
  • Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Piotr Nowojski
  • Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
  • Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Li Wang
  • RE: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core David Radley
  • Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
  • Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
• [RESULT][VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Zander Matheson
• [jira] [Created] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka Shekhar Prasad Rajak (Jira)
• [jira] [Created] (FLINK-38286) MAP function with duplicate keys produces non-deterministic results Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38285) Allow to overrride config options with environment variables Jira
• [jira] [Created] (FLINK-38284) Prepare to upgrade hadoop version to 3.4.2 across Flink's Hadoop-based FS connectors for OpenSSL 3 and Java 17 compatibility Jaehyun Kim (Jira)
• [jira] [Created] (FLINK-38283) Support customized autoscaling algorithm Zhenqiu Huang (Jira)
• [jira] [Created] (FLINK-38282) K8S operator : S3 jarURI raphaelauv (Jira)
• [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Peter Huang
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Peter Huang
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Peter Huang
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Gyula Fóra
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Maximilian Michels
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Peter Huang
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Gyula Fóra
  • [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Diljeet Singh
  • RE: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Diljeet Singh
  • RE: Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm ctrlaltdilj
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm ctrlaltdilj
  • RE: Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm ctrlaltdilj
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Pradeepta Choudhury
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Rui Fan
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Peter Huang
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Gyula Fóra
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm Peter Huang
  • RE: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm ctrlaltdilj
• Re: Proposal: Add failOnError option in KafkaSinkBuilder to suppress job restarts when DeliveryGuarantee.NONE is used Martijn Visser
• Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Rui Fan
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Roman Khachatryan
• Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Matthias Pohl
  • Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Roc Marshal
  • Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Matthias Pohl
  • Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
  • Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
  • Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
  • RE: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history David Radley
  • Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
• [jira] [Created] (FLINK-38281) Schema changes still caused column size does not match the data size after enabling scan.parse.online.schema.changes.enabled TemiChan (Jira)
• [Discuss] Support Flink Kubernetes Operator Autoscaler Implementation override Diljeet Singh
  • Re: [Discuss] Support Flink Kubernetes Operator Autoscaler Implementation override Gyula Fóra
  • Re: [Discuss] Support Flink Kubernetes Operator Autoscaler Implementation override Diljeet Singh
  • Re: [Discuss] Support Flink Kubernetes Operator Autoscaler Implementation override Diljeet Singh
  • Re: [Discuss] Support Flink Kubernetes Operator Autoscaler Implementation override Diljeet Singh
  • Re: [DISCUSS] FLIP-543: Support Customized Autoscale Algorithm ctrlaltdilj
• [jira] [Created] (FLINK-38280) Bump ASM 9.8 to support Java 25 bytecode Zhanghao Chen (Jira)
• Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Gustavo de Morais
  • Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Ramin Gharib
  • Re: [VOTE] FLIP-541 Making PyFlink more Pythonic (Phase-1) Zander Matheson
• [jira] [Created] (FLINK-38279) Failed to restore job when using MySQL Source with scan.startup.mode=snapshot in streaming mode Yanquan Lv (Jira)
• Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Becket Qin
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Roc Marshal
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
• [ANNOUNCE] Apache flink-connector-kafka 4.0.1 release Fabian Paul

• Later messages