user

Messages by Date

2025/10/17 [ANNOUNCE] Apache Flink 1.20.3 released Xuannan Su
2025/10/17 Re: Flink CDC: Random but persistent communications link failure Leonard Xu
2025/10/17 RE: Flink kafka source with Avro Generic Record Kamal Mittal via user
2025/10/17 unsubscribe 范超
2025/10/16 Re: unsubscribe Yan Zhou
2025/10/14 Flink BlueGreen Deployment Issue Maheep Myneni via user
2025/10/10 Re: CVE-2025-62228: Apache Flink CDC, Apache Flink CDC, Apache Flink CDC, Apache Flink CDC, Apache Flink CDC: SQL injection via maliciously crafted identifiers saksham sapra
2025/10/06 using State Object in Flink 2.1 (Encrypted Delivery) Tarafder, Anirban (Employee Benefits CIO) via user
2025/10/03 Re: Checkpoint timeouting [SOLVED] Nikola Milutinovic
2025/09/30 Re: DataStreamV2 API: Looking for join with watermark example Gunnar Morling
2025/09/29 unsubscribe Meet Chandarana
2025/09/28 RE: Flink kafka source with Avro Generic Record Kamal Mittal via user
2025/09/27 Re: UDF with constant arguments performance Shengkai Fang
2025/09/27 Re: [Flink 2.0.0] SQL job fails with ClassNotFoundException: org.apache.flink.api.connector.sink2.StatefulSink Shengkai Fang
2025/09/27 Inconsistent HistoryServer behavior under different job shutdown methods in Flink lec ssmi
2025/09/27 RE: Flink kafka source with Avro Generic Record Schwalbe Matthias
2025/09/26 unsubscribe Meet Chandarana
2025/09/26 Unsubscribe Sourabh Mokhasi
2025/09/26 UDF with constant arguments performance Alexey Sanko via user
2025/09/26 [ANNOUNCE] Apache Flink CDC 3.5.0 released Yanquan Lv
2025/09/26 Flink Kubernetes Operator, 1.13 Release timeline Francis Altomare
2025/09/26 Re: Flink Kubernetes Operator, 1.13 Release timeline Gabor Somogyi
2025/09/25 Re: Flink CDC: Random but persistent communications link failure Peter Muller
2025/09/24 Re: DeclaringAsyncKeyedProcessFunction's and Flink 2 async state APIs Zakelly Lan
2025/09/24 toChangelogStream() / fromChangelogStream() for DataStream V2 API Gunnar Morling
2025/09/24 DeclaringAsyncKeyedProcessFunction's and Flink 2 async state APIs Francis Altomare
2025/09/24 RE: Flink kafka source with Avro Generic Record Schwalbe Matthias
2025/09/23 Too much archive log generated with oracle CDC oh_sei
2025/09/23 Flink CDC: Random but persistent communications link failure Peter Muller
2025/09/22 RE: Flink kafka source with Avro Generic Record Kamal Mittal via user
2025/09/22 Re: Record size is too large for CollectSinkFunction, but collect-sink.batch-size.max has no effect. Gabor Somogyi
2025/09/22 Re: Record size is too large for CollectSinkFunction, but collect-sink.batch-size.max has no effect. Jean-Marc Paulin
2025/09/22 Re: [External] A random checkpoint failure creates an avalanche of restarts Sachin Mittal
2025/09/22 Flink kafka source with Avro Generic Record Kamal Mittal via user
2025/09/20 Re: Is there a Confluent Cloud Kafka connector for Protobuf with Schema Registry support when using the Flink SQL API? George Leonard
2025/09/20 Re: Flink datatype utils - safe to use? Tom Cooper
2025/09/20 Checkpoint timeouting Nikola Milutinovic
2025/09/20 Re: Checkpoint timeouting Nikola Milutinovic
2025/09/20 A random checkpoint failure creates an avalanche of restarts Sachin Mittal
2025/09/19 Unsubscribe Jeremy
2025/09/19 Re: Checkpoint timeouting Gabor Somogyi
2025/09/18 Re: Postgresql cdc for Flink 2.0 George
2025/09/18 Re: Uneven Task Distribution Across TaskManagers with Different Parallelism Levels arjun s
2025/09/18 Re: NullPointerException after enabling checkpoint file merging Zakelly Lan
2025/09/18 FlinkSessionJob do not take my pyFiles input Aurelio Marin ARANZANA
2025/09/18 Re: Postgresql cdc for Flink 2.0 George
2025/09/18 Re: Record size is too large for CollectSinkFunction, but collect-sink.batch-size.max has no effect. Gabor Somogyi
2025/09/18 Re: Record size is too large for CollectSinkFunction, but collect-sink.batch-size.max has no effect. Jean-Marc Paulin
2025/09/18 Re: Record size is too large for CollectSinkFunction, but collect-sink.batch-size.max has no effect. Gabor Somogyi
2025/09/18 Record size is too large for CollectSinkFunction, but collect-sink.batch-size.max has no effect. Jean-Marc Paulin
2025/09/18 [Flink 2.0.0] SQL job fails with ClassNotFoundException: org.apache.flink.api.connector.sink2.StatefulSink tomi nader
2025/09/17 Re: Postgresql cdc for Flink 2.0 George
2025/09/17 Flink autoscaler is not working Sachin Mittal
2025/09/17 Re: Postgresql cdc for Flink 2.0 George
2025/09/17 Re: Postgresql cdc for Flink 2.0 George Leonard
2025/09/17 Re: Postgresql cdc for Flink 2.0 Hongshun Wang
2025/09/17 Re: Re: Cast error and battling to get around it. George
2025/09/17 Re: NullPointerException after enabling checkpoint file merging Kevin Kim
2025/09/17 Migrating savepoints from Flink 1.20.2 to Flink 2.0 nick toker
2025/09/16 Uneven Task Distribution Across TaskManagers with Different Parallelism Levels arjun s
2025/09/16 Re: Help writing a Count with timeout trigger for windows with enableAsyncState Zakelly Lan
2025/09/16 Re: Help writing a Count with timeout trigger for windows with enableAsyncState Pablo Flores Hernández
2025/09/16 Re: Re: Cast error and battling to get around it. George
2025/09/16 Re:Re: Cast error and battling to get around it. dylanhz
2025/09/15 Re: Cast error and battling to get around it. dylanhz
2025/09/15 Help writing a Count with timeout trigger for windows with enableAsyncState Pablo Flores Hernández
2025/09/15 Cast error and battling to get around it. George
2025/09/15 Target date for Flink Kubernetes Operator release (1.12.3) Andrea Sella
2025/09/14 Postgresql cdc for Flink 2.0 George
2025/09/13 Re: NullPointerException after enabling checkpoint file merging Kevin Kim
2025/09/13 Re: Is there a Confluent Cloud Kafka connector for Protobuf with Schema Registry support when using the Flink SQL API? George Leonard
2025/09/13 Flink Kubernetes Operator problems Nikola Milutinovic
2025/09/12 Is there a Confluent Cloud Kafka connector for Protobuf with Schema Registry support when using the Flink SQL API? Javad Saljooghi
2025/09/12 Flink datatype utils - safe to use? Nic Townsend
2025/09/11 from_json calling error George
2025/09/11 [ANNOUNCE] Apache Celeborn 0.6.1 available Nicholas
2025/09/11 Flink OpenSearch Connector Support OpenSearch Serverless muhammad siddique
2025/09/10 HybridSource Connector - NullPointerException on recovery of a checkpoint Matt Cuento
2025/09/10 Re: NullPointerException after enabling checkpoint file merging Zakelly Lan
2025/09/10 Re: Flink Kubernetes Operator problems Gyula Fóra
2025/09/09 Re: NullPointerException after enabling checkpoint file merging Kevin Kim
2025/09/09 Re: State processor's table API with custom map value Alexis Sarda-Espinosa
2025/09/09 Re: State processor's table API with custom map value Gabor Somogyi
2025/09/09 State processor's table API with custom map value Alexis Sarda-Espinosa
2025/09/09 Re: NullPointerException after enabling checkpoint file merging Gabor Somogyi
2025/09/08 Re: NullPointerException after enabling checkpoint file merging Zakelly Lan
2025/09/08 Unsubscribe Swagat Mishra
2025/09/07 Optimizations of SQL EXCEPT Alexis Sarda-Espinosa
2025/09/07 Flink Metrics - Histogram Ben Amiel
2025/09/07 Re: NullPointerException after enabling checkpoint file merging Zakelly Lan
2025/09/06 Re: NullPointerException after enabling checkpoint file merging Gabor Somogyi
2025/09/05 Re: NullPointerException after enabling checkpoint file merging Kevin Kim
2025/09/04 Re: NullPointerException after enabling checkpoint file merging Zakelly Lan
2025/09/04 RE: Re: Autoscaling Global Scaling Factor (???) Salva Alcántara
2025/09/04 Re: NullPointerException after enabling checkpoint file merging Kevin Kim
2025/09/03 Re: Require some assistance unpacking complex json as string into table George
2025/09/03 [ANNOUNCE] flink-mcp: MCP Server for Apache Flink SQL Gateway Maciej Bryński
2025/09/03 Require some assistance unpacking complex json as string into table George
2025/09/02 NullPointerException after enabling checkpoint file merging Kevin Kim
2025/09/02 Unsubscribe neha goyal
2025/09/01 Apache Flink Catalogs George
2025/09/01 Re: Flink Sink when using AsyncSinkBase Ahmed Hamdy
2025/08/31 Re: Flink Sink when using AsyncSinkBase Mark Zitnik
2025/08/28 Re: Flink Sink when using AsyncSinkBase Ahmed Hamdy
2025/08/27 Re: CDC consuming from Postgres -> Resulting in NULL column George
2025/08/27 Re: Flink Sink when using AsyncSinkBase Poorvank Bhatia
2025/08/27 CDC consuming from Postgres -> Resulting in NULL column George
2025/08/27 Flink Sink when using AsyncSinkBase Mark Zitnik
2025/08/26 Re: [Batch][1.19] Order of elements within the same key in KeyedProcessFunction without event time Gabor Somogyi
2025/08/26 [Batch][1.19] Order of elements within the same key in KeyedProcessFunction without event time lec ssmi
2025/08/25 RE: Sharing data among flink operator pipeline Kamal Mittal via user
2025/08/25 Re: Sharing data among flink operator pipeline Kyle Lahnakoski via user
2025/08/25 RE: Sharing data among flink operator pipeline Kamal Mittal via user
2025/08/25 Re: Sharing data among flink operator pipeline shenzhongwei
2025/08/25 Re: Sharing data among flink operator pipeline Nikola Milutinovic
2025/08/22 [ANNOUNCE] Apache flink-connector-kafka 4.0.1 release Fabian Paul
2025/08/21 Re: Sharing data among flink operator pipeline shenzhongwei
2025/08/21 Re: Sharing data among flink operator pipeline Pedro Mázala
2025/08/21 Sharing data among flink operator pipeline Kamal Mittal via user
2025/08/19 RE: Re: Re: Re: Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Yaroslav Chernysh
2025/08/19 Re: Re: Re: Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Gabor Somogyi
2025/08/19 RE: Re: Re: Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Yaroslav Chernysh
2025/08/19 Unsubscribe forideal
2025/08/18 Re: Re: Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Gabor Somogyi
2025/08/18 RE: Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Yaroslav Chernysh
2025/08/18 RE: Re: Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Yaroslav Chernysh
2025/08/18 Re: Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Gabor Somogyi
2025/08/18 Re: Autoscaling Global Scaling Factor (???) Salva Alcántara
2025/08/17 Re: Autoscaling Global Scaling Factor (???) Zhanghao Chen
2025/08/15 Re: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Gabor Somogyi
2025/08/15 Re: Autoscaling Global Scaling Factor (???) Salva Alcántara
2025/08/15 RE: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Yaroslav Chernysh
2025/08/15 RE: Re: Job Manager's REST endpoint address advertising: IP address vs hostname Yaroslav Chernysh
2025/08/15 Re: Autoscaling Global Scaling Factor (???) Salva Alcántara
2025/08/15 Re: Autoscaling Global Scaling Factor (???) Zhanghao Chen
2025/08/15 Unsubscribe [email protected]
2025/08/14 退订 Pangang Wu
2025/08/14 Re: Job Manager's REST endpoint address advertising: IP address vs hostname Gabor Somogyi
2025/08/14 Job Manager's REST endpoint address advertising: IP address vs hostname Yaroslav Chernysh
2025/08/13 Re: Autoscaling Global Scaling Factor (???) Salva Alcántara
2025/08/13 Re: Autoscaling Global Scaling Factor (???) Zhanghao Chen
2025/08/13 RE: Autoscaling Global Scaling Factor (???) Salva Alcántara
2025/08/13 Autoscaling Global Scaling Factor (???) Salva Alcántara
2025/08/11 Consistent RTE Job failures for Flink Job Amrit Sarkar
2025/08/11 Re: Maintaining time attribute after a Window Outer Join David Anderson
2025/08/11 Re: Unit testing KeyedProcessFunction that uses async state Lasse Nedergaard
2025/08/10 Re: Running Python jobs via Kubernetes operator Dian Fu
2025/08/09 Re: What is the best way to play with json in flink? Zhanghao Chen
2025/08/09 Re: What is the best way to play with json in flink? Xeno Amess
2025/08/09 Re: What is the best way to play with json in flink? Zhanghao Chen
2025/08/08 Consistent RTE Job failures for Flink Job Amrit Sarkar
2025/08/08 What is the best way to play with json in flink? Xeno Amess
2025/08/08 Re: What is the best way to play with json in flink? Xeno Amess
2025/08/07 Unsubscribe 3pang zhu
2025/08/07 ElasticsearchConnector for ES version 9.x.x patricia lee
2025/08/05 Running Python jobs via Kubernetes operator Nikola Milutinovic
2025/08/05 [ANNOUNCE] Debo CLI v0.1.0 – Unified Hadoop Ecosystem Management Tool Surafel Temesgen
2025/08/04 Re: [ANNOUNCE] Apache Flink 2.1.0 released Jiangang Liu
2025/08/04 Re: [ANNOUNCE] Apache Flink 2.1.0 released Jacky Lau
2025/08/04 Webinar - Apache Flink Production Monitoring & Optimizations Tips Itamar Syn-Hershko via user
2025/08/01 Seeking Guidance on Restarting FlinkSessionJob to Update PyFlink Script on Kubernetes Pachara Aryuyuen (Kas)
2025/07/31 Re: [ANNOUNCE] Apache Flink 2.1.0 released xiangyu feng
2025/07/31 Re: [ANNOUNCE] Apache Flink 2.1.0 released Zakelly Lan
2025/07/31 RE: Kafka partition assignment for consumers Kamal Mittal via user
2025/07/31 Unsubscribe 杨鹏
2025/07/30 [ANNOUNCE] Apache Flink 2.1.0 released Ron Liu
2025/07/30 Re: Is it acceptable to create a FromCollectionSource in flink-runtime/flink-runtime-java? Xeno Amess
2025/07/30 Intermittent Stuck Job Recovery after Suspended ZooKeeper Connection Ben Augarten
2025/07/30 Redeploy job cause StateMigrationException Мосин Николай
2025/07/30 Is it acceptable to create a FromCollectionSource in flink-runtime/flink-runtime-java? Xeno Amess
2025/07/30 Re: Kafka partition assignment for consumers Hongshun Wang
2025/07/29 Unsubscribe drewfranklin
2025/07/29 Unsubscribe 李佳宸
2025/07/29 Issue with savepoint creation using UnionListState Lucas Gameiro Borges via user
2025/07/29 RE:Maintaining time attribute after a Window Outer Join Nic Townsend
2025/07/28 Re:Maintaining time attribute after a Window Outer Join Xuyang
2025/07/28 Maintaining time attribute after a Window Outer Join Nic Townsend
2025/07/28 Unsubscribe Ramana
2025/07/27 Unsubscribe jasvendra kumar
2025/07/27 Re: Issue with Special Characters in userProgramArguments When Submitting Flink Application to YARN Shengkai Fang
2025/07/25 RE: RE: Autoscaler 409 error due to UID precondition failure on configmap Salva Alcántara
2025/07/24 Re: Kafka partition assignment for consumers Frens Jan Rumph
2025/07/24 Re: Kafka partition assignment for consumers Kamal Mittal via user
2025/07/24 Unsubscribe Bryan Cantos
2025/07/24 Re: Kafka partition assignment for consumers Frens Jan Rumph
2025/07/24 RE: Kafka partition assignment for consumers Kamal Mittal via user
2025/07/23 Re: Kafka partition assignment for consumers Frens Jan Rumph
2025/07/23 RE: Kafka partition assignment for consumers Kamal Mittal via user
2025/07/23 Re:Re: Where is flink 2.1? Xuyang
2025/07/23 Kafka partition assignment for consumers Kamal Mittal via user
2025/07/23 RE: Kafka cluster rebalancing Kamal Mittal via user
2025/07/23 Re: Where is flink 2.1? Xeno Amess
2025/07/23 Re: Where is flink 2.1? Xeno Amess
2025/07/23 Flink Java17-based incompatibility with Kubernetes Operator Nikola Milutinovic
2025/07/23 Re: Where is flink 2.1? Frens Jan Rumph
2025/07/23 RE: Kafka cluster rebalancing Kamal Mittal via user
2025/07/22 RE: Kafka cluster rebalancing Kamal Mittal via user
2025/07/22 RE: Autoscaler 409 error due to UID precondition failure on configmap Salva Alcántara
2025/07/22 Autoscaler 409 error due to UID precondition failure on configmap Salva Alcántara
2025/07/21 Issue on Flink CDC with Oracle CDB + PDB hlx98007