user  

Messages by Thread

• • Re: Flink CDC operational questions Xiqian YU
• Flink Kubernetes Operator with Flink 1.20 Nikola Milutinovic
  • Re: Flink Kubernetes Operator with Flink 1.20 Gyula Fóra
• How to programatically register a 3rd party serializer (Flink 1.20) Jean-Marc Paulin
  • Re: How to programatically register a 3rd party serializer (Flink 1.20) Zhanghao Chen
• Flink 流式写入 Hive 报错：without providing a commit policy. Make sure to set a proper value for sink.partition-commit.policy.kind LakeShen
• Pure python SinkFunction? chris snow
• Joining Streams: "One operator with N inputs" vs "N-1 co-processors" Salva Alcántara
  • Re: Joining Streams: "One operator with N inputs" vs "N-1 co-processors" Yaroslav Tkachenko
  • Re: Joining Streams: "One operator with N inputs" vs "N-1 co-processors" Salva Alcántara
  • RE: [External] Joining Streams: "One operator with N inputs" vs "N-1 co-processors" Schwalbe Matthias
  • Re: [External] Joining Streams: "One operator with N inputs" vs "N-1 co-processors" Salva Alcántara
• [ANNOUNCE] Apache flink-connector-hbase 4.0.0 released Ferenc Csaky
• Kafka connector and Python Stefano Braga
  • Re: [External] Kafka connector and Python 闵中元
• Elastic Scaling in Apache Flink and minimum parallelism Pavel Dmitriev
• Slot count and Flink 1.20 Lauri Mäkinen
• [Flink CDC] What's the difference between Pipeline connectors and Flink Source connectors? Robin Moffatt via user
  • Re: [Flink CDC] What's the difference between Pipeline connectors and Flink Source connectors? Andrew Otto
  • Re: [Flink CDC] What's the difference between Pipeline connectors and Flink Source connectors? Shengkai Fang
  • Re: [Flink CDC] What's the difference between Pipeline connectors and Flink Source connectors? Shengkai Fang
  • Re: [Flink CDC] What's the difference between Pipeline connectors and Flink Source connectors? Robin Moffatt via user
  • unsubscribe simon money via user
• Flink state statistics Christian Lorenz via user
  • Re: Flink state statistics Zakelly Lan
• State Migration flink sql Lasse Nedergaard
• Late data stream is not progressing after re-watermarking Sachin Mittal
• Flink breaking changes in 2.0 Kamal Mittal via user
• Inquiry: Kryo 5 Support in Apache Flink 2.0 Dhruv Patel
• [ANNOUNCE] Apache Flink CDC 3.2.1 released Hang Ruan
• [ANNOUNCE] Apache flink-connector-kafka 3.4.0 released Arvid Heise
• S3 Timeout waiting for connection from pool wangye...@yeah.net
  • S3 Timeout waiting for connection from pool William Wallace
  • Re: S3 Timeout waiting for connection from pool 王业楼
  • Re: S3 Timeout waiting for connection from pool William Wallace
• [ANNOUNCE] Apache Celeborn 0.5.2 available Nicholas Jiang
• How the Async Exuecution Model improved the throughtput Enric Ott
  • Re: How the Async Exuecution Model improved the throughtput Zakelly Lan
  • ?????? How the Async Exuecution Model improved the throughtput Enric Ott
  • Re: How the Async Exuecution Model improved the throughtput Zakelly Lan
• How the Async Exuecution Model improvement the throughput Enric Ott
• Fwd: Flink application with statsd failing transiently Shubham Badkur
• Flink StatefulFunctions - Is it actively maintained ? santosh techie
  • Re:Flink StatefulFunctions - Is it actively maintained ? Xuyang
  • Re: Flink StatefulFunctions - Is it actively maintained ? santosh techie
• Issue while migrating to flink 1.20.0 with Java 17 & Scala 2.12 Nitin Saini
  • Re: Issue while migrating to flink 1.20.0 with Java 17 & Scala 2.12 Prasanna kumar
• Cdc on HA postgresql Lasse Nedergaard
  • Re: Cdc on HA postgresql Shengkai Fang
  • Re: Cdc on HA postgresql Hongshun Wang
  • Re: Cdc on HA postgresql Gunnar Morling
  • Re: Cdc on HA postgresql Leonard Xu
  • Re: Cdc on HA postgresql Lasse Nedergaard
  • Re: Cdc on HA postgresql Gunnar Morling
• No operators defined in streaming topology. Cannot execute. Nadia Mujeeb
  • Re: No operators defined in streaming topology. Cannot execute. Feng Jin
• Questions about using Flink MongoDB CDC wangye...@yeah.net
  • Re: Questions about using Flink MongoDB CDC Jiabao Sun
• Clarification on Flink Pipeline and Cluster Termination with Operator v1.9 Sigalit Eliazov
• [Discuss] FLIP-485: Flink UDF metrics Linda Li
  • Re:[Discuss] FLIP-485: Flink UDF metrics Xuyang
  • Re: [Discuss] FLIP-485: Flink UDF metrics Linda Li
• Unittesting ProcessWindowFunction in Scala Burak Dursunlar
  • Re: Unittesting ProcessWindowFunction in Scala Alexey Novakov via user
• Trying to connect to HBase from FlinkSql Guillermo
  • Re: Trying to connect to HBase from FlinkSql Guillermo
  • Re: Trying to connect to HBase from FlinkSql Shengkai Fang
  • Re: Trying to connect to HBase from FlinkSql Guillermo
• Job Opportunities in India,USA,Singapore,Australia,UAE or UK sri hari kali charan Tummala
• Order data with OVER AGGREGATION functions. Guillermo
  • Re: Order data with OVER AGGREGATION functions. Feng Jin
  • Re:Re: Order data with OVER AGGREGATION functions. Xuyang
• Flink 1.20 Sink API relies on deprecated InitContext Adrien Merat via user
  • Re: Flink 1.20 Sink API relies on deprecated InitContext Yanquan Lv
• A bug in upsert Kafka 3.3.0 & Flink 1.20? Daniele Parmeggiani
• java.lang.Object serialization by Kryo Kamal Mittal via user
  • Re: java.lang.Object serialization by Kryo Kirill Ternovsky
• Flink table materialization Jacob Rollings
  • RE: [External] Re: Flink table materialization Schwalbe Matthias
  • Re: [External] Re: Flink table materialization Feng Jin
• What would be the best serialization mechanism in flink Sachin Mittal
• flink connector hive support collect metrics 李 琳
  • Re: flink connector hive support collect metrics Feng Jin
• Flink BigQuery Connector Public Preview Jayant Jain via user
• Calling 3rd party JARs from Pyflink Akos Barabas
• Java 21 support and apache/flink docker images Bjarke Tornager
• Java 17 Support Flink 1.20 patricia lee
• [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Gyula Fóra
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? yuanfeng hu
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Rui Fan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Matthias Pohl
• Planned release dates for 1.19.2 and 1.20.1 Prasanna kumar
  • Re: Planned release dates for 1.19.2 and 1.20.1 NGH Flink
  • Re: Planned release dates for 1.19.2 and 1.20.1 Prasanna kumar
  • Re: Planned release dates for 1.19.2 and 1.20.1 Robert Metzger
• FlinkSQL Hints - Boradcast table. Guillermo Ortiz Fernández
  • Re:FlinkSQL Hints - Boradcast table. Xuyang
  • Re:Re:FlinkSQL Hints - Boradcast table. Xuyang
  • Re: Re:FlinkSQL Hints - Boradcast table. Guillermo Ortiz Fernández
  • Re: Re:FlinkSQL Hints - Boradcast table. Guillermo Ortiz Fernández
  • Re:Re: Re:FlinkSQL Hints - Boradcast table. Xuyang
  • Re:Re:Re: Re:FlinkSQL Hints - Boradcast table. Xuyang
  • Re: Re:FlinkSQL Hints - Boradcast table. Shengkai Fang
• Request performance advice on simple statistics Smokeriu
• Enable GC dump/logging on TMs on kube session Vararu, Vadim
• Re: Unittesting async functions with mocked fields Alexey Novakov via user
• Trying to understand watermark in join with FlinkSQL and late events Guillermo
  • Re: Trying to understand watermark in join with FlinkSQL and late events Alexey Novakov via user
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.10.0 released Őrhidi Mátyás
• "Not all slot managed memory is freed" Jad Naous
  • Re: "Not all slot managed memory is freed" Gabor Somogyi
  • Re: "Not all slot managed memory is freed" Jad Naous
• Flink Kubernetes Operator questions louis lau
• Critical CVE-2024-47561 on Apache Avro Chirag Dewan via user
  • Re: Critical CVE-2024-47561 on Apache Avro Chirag Dewan via user
  • Re: Critical CVE-2024-47561 on Apache Avro Jim Hughes via user
  • Re: Critical CVE-2024-47561 on Apache Avro Chirag Dewan via user
• Flink CDC -> Kafka -> Paimon? Andrew Otto
  • Re: Flink CDC -> Kafka -> Paimon? Yanquan Lv
  • Re: Flink CDC -> Kafka -> Paimon? Yanquan Lv
  • Re: Flink CDC -> Kafka -> Paimon? Andrew Otto
  • Re: Flink CDC -> Kafka -> Paimon? Yanquan Lv
  • Re: Flink CDC -> Kafka -> Paimon? Jingsong Li
• Task manager has no more allocated slots for job John Smith
  • Re: Task manager has no more allocated slots for job John Smith
• Kafka sink producing record at event timestamp Sachin Mittal
  • Re: Kafka sink producing record at event timestamp Sebastian Zapata
• Mysql CDC: support for parallelism Michael Marino
  • Re: Mysql CDC: support for parallelism Michael Marino
  • Re: Mysql CDC: support for parallelism Hang Ruan
  • Re: Mysql CDC: support for parallelism Michael Marino
• RE: https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw Hanyu (Peter) Zheng via user
  • https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw Hanyu (Peter) Zheng via user
• java.lang.SecurityException: setContextClassLoader Tony Chen
• [ANNOUNCE] Apache Flink 2.0 Preview released Xintong Song
  • ??????[ANNOUNCE] Apache Flink 2.0 Preview released Enric Ott
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released weijie guo
  • ??????[ANNOUNCE] Apache Flink 2.0 Preview released Enric Ott
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released Benoit Tailhades
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released Zakelly Lan
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released Benoit Tailhades
• Opensearch Connector for Flink 1.18+ Kirti Dhar Upadhyay K via user
  • Re: Opensearch Connector for Flink 1.18+ Yanquan Lv
• Tenantive Flink 2.0 release date? Anil Dasari
  • Re: Tenantive Flink 2.0 release date? Yanquan Lv
  • Re: Tenantive Flink 2.0 release date? Anil Dasari
  • Re: Tenantive Flink 2.0 release date? Yanquan Lv
  • Re: Tenantive Flink 2.0 release date? Anil Dasari
  • Re:Re: Tenantive Flink 2.0 release date? Xuyang
• Backpressure causing operators to stop ingestion completely Raihan Sunny via user
  • Re:Backpressure causing operators to stop ingestion completely Jake.zhang
  • Re: Re:Backpressure causing operators to stop ingestion completely Raihan Sunny via user
• Backporting array_agg from 1.20 to 1.18 Daniele Parmeggiani
  • RE: Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng via user
  • Re: Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng via user
  • Backporting array_agg from 1.20 to 1.18 Hanyu (Peter) Zheng via user
  • Re: Backporting array_agg from 1.20 to 1.18 Daniele Parmeggiani
  • Re: Backporting array_agg from 1.20 to 1.18 Jiabao Sun
  • Re: Backporting array_agg from 1.20 to 1.18 Daniele Parmeggiani
• [ANNOUNCE] Apache flink-connector-kafka 3.3.0 released Arvid Heise
• Terrible bug related to serialization of Pojos in keystate. Ammon Diether
  • RE: [External] Terrible bug related to serialization of Pojos in keystate. Schwalbe Matthias
• Flink custom sink Anil Dasari
  • Re: Flink custom sink Yanquan Lv
  • Re: Flink custom sink Anil Dasari
  • Re: Flink custom sink Yanquan Lv
  • Re: Flink custom sink Anil Dasari
  • Re: Flink custom sink Yanquan Lv
  • Re: Flink custom sink Anil Dasari
  • Re: Flink custom sink Yanquan Lv
  • Re: Flink custom sink Anil Dasari
  • Re: Flink custom sink Anil Dasari
  • Re: Flink custom sink Anil Dasari
• Stopping the flink 1.18 program with savepoint seems to fail with timeout Sachin Mittal
  • Re: Stopping the flink 1.18 program with savepoint seems to fail with timeout Mate Czagany
• Request to joining Apache Flink community on Slack Ken CHUAN YU
  • Re: Request to joining Apache Flink community on Slack Leonard Xu
  • Re: Request to joining Apache Flink community on Slack Anil Dasari
  • Re: Request to joining Apache Flink community on Slack Leonard Xu
• Flink SQL CDC connector do nothing to the setting "debizum.*" when create the source table Ken CHUAN YU
  • Re: Flink SQL CDC connector do nothing to the setting "debizum.*" when create the source table Yaroslav Tkachenko
  • Re: Flink SQL CDC connector do nothing to the setting "debizum.*" when create the source table Ken CHUAN YU
  • Re: Flink SQL CDC connector do nothing to the setting "debizum.*" when create the source table Leonard Xu
• Job fails with exception (uncommitted transactions) at stop with savepoint but savepoint is created Vararu, Vadim
• Re: Kafka SQL Connector loses data if deserialization error occures Ilya Karpov
  • Re: Kafka SQL Connector loses data if deserialization error occures Ilya Karpov
• We found a deadlock problem when a single piece of data is too large on Flink1.13.2, do not continue to process the data, which more understand the data transmission piece, welcome to comment. rui chen
  • Re: We found a deadlock problem when a single piece of data is too large on Flink1.13.2, do not continue to process the data, which more understand the data transmission piece, welcome to comment. rui chen
• HTTP call to Flink Nitin Chauhan
• Using futures within co-process function Salva Alcántara
• Flink custom source Anil Dasari
  • Re: Flink custom source Ahmed Hamdy
  • Re: Flink custom source Anil Dasari
  • Re: Flink custom source Ahmed Hamdy
  • Re: Flink custom source Anil Dasari
• Flink 1.20 and Flink Kafka Connector 3.2.0-1.19 patricia lee
  • Re: Flink 1.20 and Flink Kafka Connector 3.2.0-1.19 Dominik.Buenzli
• Meaning behind the pekko.framesize configuration property and how to reduce it's size Jean-Marc Paulin
• Flink SQL Kafka Upsert connector produce intermittent Tombstones Qing Lim

• Earlier messages
• Later messages