dev  

Messages by Thread

• [jira] [Created] (FLINK-37484) unbounded-chunk-first.enabled no use in unevently chunk split Hongshun Wang (Jira)
• [jira] [Created] (FLINK-37483) Native kubernetes clusters losing checkpoint state on FAILED Max Feng (Jira)
• Community review process improvement proposal David Radley
  • RE: Community review process improvement proposal Pedro Mázala
  • RE: Community review process improvement proposal Pedro Mázala
  • RE: Community review process improvement proposal David Radley
  • Re: Community review process improvement proposal Pedro Mázala
  • RE: Community review process improvement proposal David Radley
• [jira] [Created] (FLINK-37482) Simplify the code for PrintSinkOutputWriter Jiaan Geng (Jira)
• [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0 Jiabao Sun
  • Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0 Leonard Xu
  • Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0 Arvid Heise
  • Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0 Jiabao Sun
  • Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0 Leonard Xu
  • Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0 Jiabao Sun
• [VOTE] FLIP-513: Split-level watermark metrics Efrat Levitan
  • Re: [VOTE] FLIP-513: Split-level watermark metrics Piotr Nowojski
  • Re: [VOTE] FLIP-513: Split-level watermark metrics Xiqian YU
  • Re: [VOTE] FLIP-513: Split-level watermark metrics Yuepeng Pan
  • Re: [VOTE] FLIP-513: Split-level watermark metrics Efrat Levitan
  • Re: [VOTE] FLIP-513: Split-level watermark metrics Roman Khachatryan
  • Re: [VOTE] FLIP-513: Split-level watermark metrics Ahmed Hamdy
  • Re: [VOTE] FLIP-513: Split-level watermark metrics Stefan Richter
  • RE: [VOTE] FLIP-513: Split-level watermark metrics Aleksandr Savonin
• [jira] [Created] (FLINK-37481) Multi way join operator Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37480) Jpicmp gives false positive Gabor Somogyi (Jira)
• [RESULT][VOTE] Release 2.0.0, release candidate #2 Xintong Song
• [RESULT][VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Jiabao Sun
• [jira] [Created] (FLINK-37469) ClassCastException in org.apache.flink.table.data.GenericRowData Munir Contractor (Jira)
• [jira] [Created] (FLINK-37458) Forbid enableAsyncState() for synchronous operators Yanfei Lei (Jira)
• [jira] [Created] (FLINK-37476) Update Kafka connector's ChangelogMode Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-37473) Fill in RowKind.DELETE in RowResultRowConverter if possible Marton Greber (Jira)
• [jira] [Created] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Vinh Pham (Jira)
• [jira] [Created] (FLINK-37478) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the service Julian (Jira)
• [jira] [Created] (FLINK-37477) Drop ChangelogNormalize for a StreamJoin Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-37475) Drop ChangelogNormalize for piping from upsert source to sink Dawid Wysakowicz (Jira)
• [RESULT][VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz
• [jira] [Created] (FLINK-37474) FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-37472) flink zh docs bugfix huangyanyan (Jira)
• [jira] [Created] (FLINK-37471) Tag the subclass of SourceFunction with @Deprecated Jiaan Geng (Jira)
• [DISCUSS] FLIP-515: Dynamic Kafka Sink Őrhidi Mátyás
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Arvid Heise
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Őrhidi Mátyás
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Arvid Heise
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Hongshun Wang
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Hongshun Wang
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Yanquan Lv
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Őrhidi Mátyás
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Yanquan Lv
  • Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink Őrhidi Mátyás
• 2025/03/13 CHI Eastern time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-37470) InitContainer errors are not registered correctly Gyula Fora (Jira)
• [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Pradeepta Choudhury
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Gyula Fóra
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Maximilian Michels
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Pradeepta Choudhury
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Venkatakrishnan Sowrirajan
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler gyula . fora
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Rui Fan
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler yuanfeng hu
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Pradeepta Choudhury
  • Re: [DISCUSS] FLIP-514: Custom Evaluator plugin for Flink Autoscaler Pradeepta Choudhury
• [jira] [Created] (FLINK-37468) Flink release-1.19 branch has instructions - Maven 3.8.6 (recommended or later) qihuang (Jira)
• Ask for help Mattia Mori
• [jira] [Created] (FLINK-37467) FlinkSessionJob: possibility to use configmaps and secrets in args parameter Diego Lobba (Jira)
• [jira] [Created] (FLINK-37466) A helper function for DEFAULT in Table API Timo Walther (Jira)
• [jira] [Created] (FLINK-37465) [Docs] Update options for oceanbase connector Xiao Huang (Jira)
• [jira] [Created] (FLINK-37464) Update ZK to v3.9.3 in Flink Kubernetes Operator for TLS v1.3 support Michas Szacillo (Jira)
• [jira] [Created] (FLINK-37463) Make ForStMapState Serializer ThreadLocal Yue Ma (Jira)
• [jira] [Created] (FLINK-37462) Unstable test case in FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37461) Unstable test case in MySqlToPaimonE2eITCase#testSyncWholeDatabase Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2 Poorvank Bhatia (Jira)
• [jira] [Created] (FLINK-37429) Map each original column name to a new name and support column name containing '-' Xiao Huang (Jira)
• [jira] [Created] (FLINK-37448) status.taskManager.replicas to show actual TaskManager count Robert Metzger (Jira)
• [jira] [Created] (FLINK-37434) Incremental checkpoint not configurable for ForSt's sync mode Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37428) Add JDK21 to Docker build matrix Weijie Guo (Jira)
• [jira] [Created] (FLINK-37446) Support asArgument in Table API Timo Walther (Jira)
• [jira] [Created] (FLINK-37447) [Flink CDC] Supports Variant type in YAML API Leonard Xu (Jira)
• [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz
  • Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Timo Walther
  • Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Leonard Xu
  • Re:Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Xuyang
  • Re: Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Sergey Nuyanzin
  • Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Yuepeng Pan
  • Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Martijn Visser
  • Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Jiabao Sun
  • Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it Dawid Wysakowicz
• [jira] [Created] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException Grzegorz Liter (Jira)
• [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Gyula Fóra
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Gyula Fóra
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Őrhidi Mátyás
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Ferenc Csaky
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Thomas Weise
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Alexander Fedulov
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Mate Czagany
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Gyula Fóra
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Andrea Sella
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Poorvank Bhatia
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Pedro Mázala
  • Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Márton Balassi
• [jira] [Created] (FLINK-37455) Create error Event when job goes into FAILED state Gyula Fora (Jira)
• [jira] [Created] (FLINK-37459) Document correction - 1.9.0 Shalini M (Jira)
• [jira] [Created] (FLINK-37457) Support asArgument in Python Table API Timo Walther (Jira)
• [jira] [Created] (FLINK-37456) Stream data for SQL state connector in case of List and Map state Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37454) Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable Leonard Xu (Jira)
• [jira] [Created] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed Leonard Xu (Jira)
• [jira] [Created] (FLINK-37451) Document correction - 1.10.0 Shalini M (Jira)
• [jira] [Created] (FLINK-37452) Add support for writing to Paimon Append only table. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37450) Document correction Shalini M (Jira)
• [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

• Earlier messages
• Later messages