dev  

Messages by Thread

• [VOTE] FLIP-509 Pluggable Batching For Async Sink Poorvank Bhatia
  • Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink Doğuşcan Namal
  • Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink Ahmed Hamdy
  • Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink Danny Cranmer
  • Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink Hong Liang
  • Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink Arvid Heise
  • Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink Poorvank Bhatia
• [jira] [Created] (FLINK-37449) Postgres don't commit lsn when taskmanager failover Xin Gong (Jira)
• [RESULT][VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
• [jira] [Created] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API Poorvank Bhatia (Jira)
• [VOTE] Release 2.0.0, release candidate #2 Xintong Song
  • Re: [VOTE] Release 2.0.0, release candidate #2 Zakelly Lan
  • Re: [VOTE] Release 2.0.0, release candidate #2 weijie guo
  • Re: [VOTE] Release 2.0.0, release candidate #2 Yuepeng Pan
  • Re: [VOTE] Release 2.0.0, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release 2.0.0, release candidate #2 Jark Wu
  • Re: [VOTE] Release 2.0.0, release candidate #2 Dian Fu
  • Re: [VOTE] Release 2.0.0, release candidate #2 Lincoln Lee
  • Re: [VOTE] Release 2.0.0, release candidate #2 Leonard Xu
  • Re: [VOTE] Release 2.0.0, release candidate #2 Xiqian YU
  • Re: [VOTE] Release 2.0.0, release candidate #2 Xuannan Su
  • Re: [VOTE] Release 2.0.0, release candidate #2 Yuan Mei
  • Re: [VOTE] Release 2.0.0, release candidate #2 Yunfeng Zhou
  • Re: [VOTE] Release 2.0.0, release candidate #2 Xintong Song
  • Re: [VOTE] Release 2.0.0, release candidate #2 Yanquan Lv
• [jira] [Created] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions Nil Madhab (Jira)
• [DISCUSS] - Ongoing development of Flink Statefun frans.king
• [jira] [Created] (FLINK-37442) Properly delete the directories for ForSt remote storage Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37441) Improve the code for TypeExtractor Jiaan Geng (Jira)
• [jira] [Created] (FLINK-37440) Fix the bug that parallelism.default do not always adopts 1 as the default value. Jiaan Geng (Jira)
• [jira] [Created] (FLINK-37439) Missing file creation with overwrite semantic in ForSt wrapped file system Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37438) Improve the createLocalEnvironment by reduce duplicate create of Configuration Jiaan Geng (Jira)
• [DISCUSS] Optimizing metrics refresh: fetch metrics by name Francesco D
  • Re: [DISCUSS] Optimizing metrics refresh: fetch metrics by name Gyula Fóra
• [jira] [Created] (FLINK-37437) ForSt checkpoint failure due to file not visible when writing Zakelly Lan (Jira)
• 2025/03/06 CHI Western time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-37436) flink-connector-pulsar used a incorrect API when dynamically creating topics by DynamicTopicRouter Yubiao Feng (Jira)
• [jira] [Created] (FLINK-37435) Kryo related perf regression since March 5th Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37433) Schema Registry is busy now, waiting for next request... vertern (Jira)
• [jira] [Created] (FLINK-37432) Add release note for release 2.0 Weijie Guo (Jira)
• upgrade DebeziumJsonDeserializationSchema Semen Pavelko
  • Re: upgrade DebeziumJsonDeserializationSchema David Radley
• [jira] [Created] (FLINK-37431) We should use guava Lists instead of curator shade Lists to avoid unnecessary error zlzhang0122 (Jira)
• [jira] [Created] (FLINK-37430) Operator hides the actual error on deployment issues Gyula Fora (Jira)
• [jira] [Created] (FLINK-37427) incorrect NPE message in StandaloneHaServices constructor LuJiang (Jira)
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released Gyula Fóra
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released Gyula Fóra
• [jira] [Created] (FLINK-37426) FLIP-481: Introduce Event Reporting Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-37425) Sanity check before ForSt cache created Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37424) Using JDK17 for the binary convenience release Weijie Guo (Jira)
• [jira] [Created] (FLINK-37423) Add support for PTFs in Table API Timo Walther (Jira)
• [SUMMARY] Flink 2.0 Release Sync 03/05/2025 Xintong Song
• Question on usage of SQL Gateway with a remote Flink cluster Ammu P
  • Re: Question on usage of SQL Gateway with a remote Flink cluster Shengkai Fang
  • Re: Question on usage of SQL Gateway with a remote Flink cluster Ammu P
  • Re: Question on usage of SQL Gateway with a remote Flink cluster Shengkai Fang
  • Re: Question on usage of SQL Gateway with a remote Flink cluster Ammu P
  • Re: Question on usage of SQL Gateway with a remote Flink cluster Shengkai Fang
• [jira] [Created] (FLINK-37422) Typo in streaming analytics zh document ronghangye (Jira)
• [jira] [Created] (FLINK-37421) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the deployment Julian (Jira)
• [jira] [Created] (FLINK-37420) AbstractAggregatingState add may return wrong result Yue Ma (Jira)
• [jira] [Created] (FLINK-37419) ForStMapState serializeValue may get wrong result Yue Ma (Jira)
• [jira] [Created] (FLINK-37418) caugth array out of index exception while using RowData.getArray method Spongebob (Jira)
• [jira] [Created] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-37416) DDB Streams connector flink state inconsistency issue Abhi Gupta (Jira)
• [KINDLY REMINDER] Flink 2.0 Release Sync 03/05/2025 Xintong Song
• [jira] [Created] (FLINK-37415) [Release-2.0] Prepare RC1 release Xintong Song (Jira)
• [jira] [Created] (FLINK-37414) Java heap space OOM in test_cron_azure core Weijie Guo (Jira)
• [jira] [Created] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API Piotr Nowojski (Jira)
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned Matthias Pohl (Jira)
• [jira] [Created] (FLINK-37411) Introduce the rollback mechanism for Autoscaler Rui Fan (Jira)
• [DISCUSS] Split-level Watermark Metrics אפרת לויטן
  • Re: [DISCUSS] Split-level Watermark Metrics Piotr Nowojski
  • Re: [DISCUSS] Split-level Watermark Metrics Efrat Levitan
• [jira] [Created] (FLINK-37410) Split-level Watermark Metrics Efrat Levitan (Jira)
• [jira] [Created] (FLINK-37409) Catch throwable in BinlogSplitReader to exit reading binlog when error occurs Xiao Huang (Jira)
• Flink vs beam-flink-runner benchmark Taher Koitawala
  • Re: Flink vs beam-flink-runner benchmark Taher Koitawala
  • Re: Flink vs beam-flink-runner benchmark XQ Hu
• [jira] [Created] (FLINK-37408) Update all docker-compose references to docker compose in documentation Nil Madhab (Jira)
• [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Zakelly Lan
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Zakelly Lan
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gyula Fóra
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Zakelly Lan
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gyula Fóra
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Zakelly Lan
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gyula Fóra
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Zakelly Lan
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gyula Fóra
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Leonard Xu
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gyula Fóra
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Lincoln Lee
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Shengkai Fang
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Zakelly Lan
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Zakelly Lan
  • Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector Gabor Somogyi
• [jira] [Created] (FLINK-37407) Add meta information to SQL state connector Gabor Somogyi (Jira)
• Minutes of the 2025/02/27 CHI Eastern time zone workgroup meeting David Radley
• [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector Arvid Heise
  • Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector Hongshun Wang
  • Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector Arvid Heise
  • RE: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector David Radley
  • Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector Arvid Heise
  • Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector Hongshun Wang
  • Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector Arvid Heise
  • Re: [DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector Hongshun Wang
• [jira] [Created] (FLINK-37406) Add support for structured YAML config in FlinkDeployment CRD Gyula Fora (Jira)
• [jira] [Created] (FLINK-37405) Perform upstream YAML config validation for Flink 2.x Gyula Fora (Jira)
• [jira] [Created] (FLINK-37404) Reenable Migration Tests for Filnk 2.x Kurt Ostfeld (Jira)
• [jira] [Created] (FLINK-37403) Support retractions/updates for IntervalJoin operator Bonnie Varghese (Jira)
• [jira] [Created] (FLINK-37402) SQL testing sources produce incorrect watermarks Timo Walther (Jira)
• [jira] [Created] (FLINK-37401) Add Job ID to logging context of slotmanager classes Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-37398) State processor API blows up with cryptic error when changelog used Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37397) Python wheel builds broken in nightly Mika Naylor (Jira)
• [jira] [Created] (FLINK-37396) Kafka connector python test fail Hongshun Wang (Jira)
• [jira] [Created] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered zexin gong (Jira)
• [RESULT][VOTE] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
• [jira] [Created] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-37393) Abnormally Long Checkpoint Duration After Full Checkpoint Completion Rafael Zimmermann (Jira)
• [jira] [Created] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state junzhong qin (Jira)
• [jira] [Created] (FLINK-37391) Change watchNamespace config in operator is not respected while running Fabian Paul (Jira)
• [jira] [Created] (FLINK-37388) [BUG] Field names must be unique. zexin gong (Jira)
• [jira] [Created] (FLINK-37390) Push filter into ChangelogNormalize Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-37389) Add "flink-sql-connector-kudu" module Ferenc Csaky (Jira)
• [SUMMARY] Flink 2.0 Release Sync 02/26/2025 Xintong Song
• [jira] [Created] (FLINK-37387) License check behaves differently for different jdk versions Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37386) Avoid sending too much CreateTableEvents when job failover Yanquan Lv (Jira)
• Kubernetes operator questions santhosh venkat
• [jira] [Created] (FLINK-37385) Add support for smile format in flink main repo Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios Lei Yang (Jira)
• [jira] [Created] (FLINK-37383) ThrottleIterator from examples/utils does not properly throttle on next window after throttle is applied Rafael Zimmermann (Jira)
• [jira] [Created] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold xingbe (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1 Tom Cooper
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1 Rui Fan
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1 Maximilian Michels
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-37381) Typo in Join document cnsky1103 (Jira)
• [ANNOUNCE] Apache Flink-shaded 20.0 released Sergey Nuyanzin
• [KINDLY REMINDER] Flink 2.0 Release Sync 02/25/2025 Xintong Song
• [jira] [Created] (FLINK-37380) Change TransactionalIdPrefix to a required option if Exactly once in Kafka Connector Hongshun Wang (Jira)
• [jira] [Created] (FLINK-37379) Lack of state cache load for ForSt after recovery Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues slankka (Jira)
• [jira] [Created] (FLINK-37377) Sync guava with guava in flink-shaded Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37376) Bump flink-shaded to 20.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37375) Checkpoint supports the Operator to customize asynchronous snapshot state Jufang He (Jira)
• FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz
  • Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Sergey Nuyanzin
  • Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Martijn Visser
  • Re:Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Xuyang
  • Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz
  • Re:Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Xuyang
  • Re: Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz
  • Re:Re: Re: Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Xuyang
  • Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Timo Walther
  • Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Leonard Xu
  • Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz
• [jira] [Created] (FLINK-37374) Support JSON built-in function for JSON_ARRAY Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37373) SplitFetcherManagerTest.testCloseFetcherWithException keeps constantly failing Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37372) Savepoint error can cause operator to hang Gyula Fora (Jira)
• Integrating LLMs into apache flink pipelines Ganesh
  • Re: Integrating LLMs into apache flink pipelines Shengkai Fang
• [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner Zhanghao Chen
  • Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner weijie guo
  • Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner Leonard Xu
  • Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner Lincoln Lee
  • Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner Jingsong Li

• Earlier messages
• Later messages