dev  

Messages by Thread

• [jira] [Created] (FLINK-38246) Remove unreachable code in CodeGenUtils morvenhuang (Jira)
• [jira] [Created] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink david radley (Jira)
• Clarification question on stateful upgrades and evolutlion David Radley
• 2025/08/14 CHI Eastern time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-38244) When the table name of mysql supports size sensitive, fix the error that column name not being found Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38243) When the table name of mysql supports size sensitive, fix the error that column name not being found Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38242) Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table Weiqing Yang (Jira)
• [jira] [Created] (FLINK-38241) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
• [jira] [Created] (FLINK-38240) Dispatcher throws FlinkJobNotFoundException when `requestCheckpointStats` for a FINISHED stream job junzhong qin (Jira)
• Backport label David Radley
  • Re: Backport label Tom Cooper
  • Re: Backport label Sebastien Pereira
• [jira] [Created] (FLINK-38239) Enable Disabled OceanBase CDC Integration Tests in GitHub CI yuan (Jira)
• [jira] [Created] (FLINK-38238) Failed to process MySQL table with varchar(0) column Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38237) MongoDB CDC - row_kind virtual column is returning incorrect operation Type Fabrizzio Chavez (Jira)
• [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Lincoln Lee
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Yuepeng Pan
  • Re:[ANNOUNCE] New Apache Flink PMC Member - Ron Liu dylanhz
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Xiqian YU
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Feng Jin
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Leonard Xu
  • Re:Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Xuyang
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Hang Ruan
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Shengkai Fang
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Jacky Lau
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Weiqing Yang
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Zhanghao Chen
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Zakelly Lan
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Geng Biao
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Hongshun Wang
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu yunhong Zheng
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu David Radley
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Jingsong Li
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Sergey Nuyanzin
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Hao Li
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Ramin Gharib
  • Re: [ANNOUNCE] New Apache Flink PMC Member - Ron Liu Ron Liu
• [jira] [Created] (FLINK-38236) MongoDB CDC - Include Full Document as Metadata Field Fabrizzio Chavez (Jira)
• [jira] [Created] (FLINK-38235) Unable to reliably detect newly added tables with MySQL CDC Max Feng (Jira)
• [jira] [Created] (FLINK-38234) Enable nondeterministic update strategy by default in SemanticTestBase Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38233) Implement visitProcessTableFunction for StreamNonDeterministicUpdatePlanVisitor Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38232) [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres, Fluss suhwan (Jira)
• [jira] [Created] (FLINK-38231) Standardise use of uv for PyFlink building/testing/tooling Mika Naylor (Jira)
• [jira] [Created] (FLINK-38230) Implement visitMultiJoin for StreamNonDeterministicUpdatePlanVisitor Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ RocMarshal (Jira)
• [jira] [Created] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. Jacky Lau (Jira)
• [jira] [Created] (FLINK-38227) Flink-CDC Postgres with Incremental Change does not work Harish Sharma (Jira)
• [jira] [Created] (FLINK-38226) Kafka Sink Improvement: Add failOnError to Control Exception Behavio Ejaskhan (Jira)
• Proposal: Add failOnError option in KafkaSinkBuilder to suppress job restarts when DeliveryGuarantee.NONE is used Ejaskhan S
  • Re: Proposal: Add failOnError option in KafkaSinkBuilder to suppress job restarts when DeliveryGuarantee.NONE is used Martijn Visser
• [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Poorvank Bhatia
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Danny Cranmer
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Gyula Fóra
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Poorvank Bhatia
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Poorvank Bhatia
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Rui Fan
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Poorvank Bhatia
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Rui Fan
  • Re: [DISCUSS] Proposal: Enabling Flamegraph via UI (Dynamic) Roman Khachatryan
• [jira] [Created] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Xi Zhang (Jira)
• [jira] [Created] (FLINK-38224) Retract sink should not accept duplicate changes produced by delta join Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38223) testConstraintsAfterRestart is flaky on master Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38222) Upgrade HBase client version to 2.6 Mate Czagany (Jira)
• [jira] [Created] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names tchivs (Jira)
• [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Ryan van Huuksloot
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Allison
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Becket Qin
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Becket Qin
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
  • 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
• 退订 赵一帆
  • 退订 陈佳豪
  • 退订 289108257
• [jira] [Created] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Gustavo de Morais (Jira)
• Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Matthias Pohl
  • Re: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 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 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
• [jira] [Created] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
• [jira] [Created] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer Rui Fan (Jira)
• [KINDLY REMINDER] Flink CDC 3.5.0 Feature Freeze Yanquan Lv
  • Re: [KINDLY REMINDER] Flink CDC 3.5.0 Feature Freeze Leonard Xu
• [jira] [Created] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed junzhong qin (Jira)
• [jira] [Created] (FLINK-38214) Support Kinesis streams source in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38213) Failed Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p:// Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator Jira
• [jira] [Created] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2 Jira
• [jira] [Created] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38205) Discard unknown fields for Protobuf format Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38203) Failed case: FlussPipelineITCase.testInsertExistTableWithMoreColumns Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks Timo Walther (Jira)
• [jira] [Created] (FLINK-38200) Allow to use LAST_VALUE and FIRST_VALUE for temporal and other types Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38199) Add a benchmark for SinkUpsertMaterializer Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38198) Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz (Jira)
• [RESULT][VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz
• [jira] [Created] (FLINK-38197) Data Errors Caused by Default Added Columns at End Position JunboWang (Jira)
• [jira] [Created] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC tchivs (Jira)
• [jira] [Created] (FLINK-38195) Some markdown syntax errors in tableApi page cuiyanxiang (Jira)
• [jira] [Created] (FLINK-38194) Iceberg connector supports auto-creating namespace ZhangChao (Jira)
• [RESULT][VOTE] FLIP-529: Connections in Flink SQL and TableAPI Hao Li
  • 回复：[RESULT][VOTE] FLIP-529: Connections in Flink SQL and TableAPI 魏宪党
  • Re: [RESULT][VOTE] FLIP-529: Connections in Flink SQL and TableAPI Hao Li
  • Re: [RESULT][VOTE] FLIP-529: Connections in Flink SQL and TableAPI Hao Li
• [jira] [Created] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924 Jakub Stejskal (Jira)
• [jira] [Created] (FLINK-38192) Improve DynamicSourceUtils exception msg Cai Liuyang (Jira)
• [jira] [Created] (FLINK-38191) [Document] Add document for Fluss pipeline connector Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38190) Support async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink Dian Fu (Jira)
• [jira] [Created] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method tchivs (Jira)
• [jira] [Created] (FLINK-38187) Add metrics to KuduSource Marton Greber (Jira)
• [jira] [Created] (FLINK-38186) Failed case: NewlyAddedTableITCase.testJobManagerFailoverForNewlyAddedTableWithAheadBinlog Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes Yanquan Lv (Jira)
• Update `flink-connector-hive` for 2.0 and 2.1 version Xiaolong Wang
  • Re: Update `flink-connector-hive` for 2.0 and 2.1 version Ron Liu
  • Re: Update `flink-connector-hive` for 2.0 and 2.1 version Xiaolong Wang
  • Re: Update `flink-connector-hive` for 2.0 and 2.1 version Ron Liu
  • Re: Update `flink-connector-hive` for 2.0 and 2.1 version Xiaolong Wang
• [jira] [Created] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID LiuZeshan (Jira)
• [jira] [Created] (FLINK-38182) lastCheckpointDuration is not right. richard_zhulh (Jira)
• [jira] [Created] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal Ramin Gharib (Jira)
• [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz
  • Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Gustavo de Morais
  • Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Ramin Gharib
  • Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Sergey Nuyanzin
  • Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Hao Li
  • Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Jacky Lau
  • Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Timo Walther
  • Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz
• [jira] [Created] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support Gong Xiaofei (Jira)
• [jira] [Created] (FLINK-38178) [RISC-V Support] - Comprehensive Tracking of RISC-V Architecture Support in Apache Flink Gong Xiaofei (Jira)
• [DISCUSS] Planning Flink 2.2 Hang Ruan
  • Re: [DISCUSS] Planning Flink 2.2 Leonard Xu
  • Re: [DISCUSS] Planning Flink 2.2 Jark Wu
  • Re: [DISCUSS] Planning Flink 2.2 Zakelly Lan
  • Re: [DISCUSS] Planning Flink 2.2 Lincoln Lee
  • Re: [DISCUSS] Planning Flink 2.2 Ron Liu
  • Re: [DISCUSS] Planning Flink 2.2 Weiqing Yang
  • Re: [DISCUSS] Planning Flink 2.2 Hongshun Wang
  • Re: [DISCUSS] Planning Flink 2.2 Gustavo de Morais
  • Re: [DISCUSS] Planning Flink 2.2 Hang Ruan
• Updating HBase connector Mate Czagany
  • Re: Updating HBase connector Ferenc Csaky
  • Re: Updating HBase connector Leonard Xu
• [jira] [Created] (FLINK-38177) ALTER TABLE .. MODIFY WATERMARK might reset current distribution Sergey Nuyanzin (Jira)
• [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Paul
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Arvid Heise
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Robert Metzger
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Zexian WU
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Hongshun Wang
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Paul
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Hueske
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Martijn Visser
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Sergey Nuyanzin
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Paul
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Weiqing Yang
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Sergey Nuyanzin
  • Re: [VOTE] Release flink-connector-kafka v4.0.1, release candidate #2 Fabian Paul
• [jira] [Created] (FLINK-38176) Release kafka connector 4.0.1 Fabian Paul (Jira)
• [jira] [Created] (FLINK-38169) CLONE - Updates the docs stable version dalongliu (Jira)
• [jira] [Created] (FLINK-38174) CLONE - Remove outdated versions dalongliu (Jira)
• [jira] [Created] (FLINK-38171) CLONE - Add 2.0 to PreviousDocs list dalongliu (Jira)
• [jira] [Created] (FLINK-38173) CLONE - Update reference data for Migration Tests dalongliu (Jira)
• [jira] [Created] (FLINK-38170) CLONE - Build 2.0 docs in GitHub Action and mark 2.0 as stable in docs dalongliu (Jira)
• [jira] [Created] (FLINK-38172) CLONE - Update japicmp configuration dalongliu (Jira)
• [jira] [Created] (FLINK-38175) CLONE - Start End of Life discussion thread for now outdated Flink minor version dalongliu (Jira)
• [jira] [Created] (FLINK-38167) CLONE - Apache mailing lists announcements dalongliu (Jira)
• [jira] [Created] (FLINK-38168) CLONE - Other announcements dalongliu (Jira)
• [jira] [Created] (FLINK-38166) CLONE - Merge website pull request dalongliu (Jira)
• [jira] [Created] (FLINK-38165) Promote release 2.1 dalongliu (Jira)
• [jira] [Created] (FLINK-38164) MySQL connector supportLONG and LONG VARCHAR type ZhangChao (Jira)
• [jira] [Created] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry. RocMarshal (Jira)

• Earlier messages
• Later messages