You are viewing a plain text version of this content. The canonical link for it is here.
- Re: K8s operator - Stop Job with savepoint on session cluster via Java API - posted by Shammon FY <zj...@gmail.com> on 2023/09/01 01:58:25 UTC, 2 replies.
- Re: [Question] How to scale application based on 'reactive' mode - posted by Dennis Jung <in...@gmail.com> on 2023/09/01 02:50:26 UTC, 9 replies.
- Send data asynchronously to a 3rd party via SinkFunction - posted by patricia lee <pl...@gmail.com> on 2023/09/01 08:26:39 UTC, 2 replies.
- Re: Flink local mini cluster is causing memory leak when triggered multiple times - posted by Bashir Sadjad via user <us...@flink.apache.org> on 2023/09/01 19:14:08 UTC, 0 replies.
- Re: Blue green deployment with Flink Apache Operator - posted by David Anderson <da...@apache.org> on 2023/09/01 21:23:32 UTC, 0 replies.
- Re: Job graph - posted by David Anderson <da...@apache.org> on 2023/09/01 22:24:21 UTC, 1 replies.
- backpressured metrics doesnt work - posted by Kenan Kılıçtepe <kk...@gmail.com> on 2023/09/04 13:49:21 UTC, 2 replies.
- k8s operator - clearing operator state - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2023/09/04 21:21:59 UTC, 0 replies.
- 回复: [Question] How to scale application based on 'reactive' mode - posted by Chen Zhanghao <zh...@outlook.com> on 2023/09/05 06:59:22 UTC, 0 replies.
- Re: Flink K8S operator does not support IPv6 - posted by Xiaolong Wang <xi...@smartnews.com> on 2023/09/05 09:40:30 UTC, 0 replies.
- Keytab Setup on Kubernetes - posted by Chirag Dewan via user <us...@flink.apache.org> on 2023/09/05 11:30:46 UTC, 3 replies.
- Re: In Flink, is there a way to merge two streams in stateful manner - posted by Muazim Wani <mu...@gmail.com> on 2023/09/05 15:05:46 UTC, 0 replies.
- Disabling Job Submissions through Flink UI - posted by Muazim Wani <mu...@gmail.com> on 2023/09/05 16:31:17 UTC, 1 replies.
- Question regarding asyncIO timeout - posted by Leon Xu <lx...@attentivemobile.com> on 2023/09/05 19:16:27 UTC, 3 replies.
- How to read flinkSQL job state - posted by Yifan He via user <us...@flink.apache.org> on 2023/09/06 05:10:05 UTC, 12 replies.
- Strange exception in UnitTest when migrate Flink v1.16.2 to v1.17.1 - posted by "Teunissen, F.G.J. (Fred) via user" <us...@flink.apache.org> on 2023/09/06 10:44:30 UTC, 2 replies.
- Re: Help needed on stack overflow query - posted by Feng Jin <ji...@gmail.com> on 2023/09/06 12:09:47 UTC, 1 replies.
- Memory Leak - posted by Kenan Kılıçtepe <kk...@gmail.com> on 2023/09/06 12:32:03 UTC, 3 replies.
- Flink KafkaSource failure on empty partitions - posted by David Clutter <da...@bridg.com> on 2023/09/06 14:43:12 UTC, 0 replies.
- Re: Uneven TM Distribution of Flink on YARN - posted by Lu Niu <qq...@gmail.com> on 2023/09/06 16:16:52 UTC, 3 replies.
- Async IO metrics for tps - posted by patricia lee <pl...@gmail.com> on 2023/09/07 04:01:37 UTC, 3 replies.
- Flink job reading from s3 path - posted by "Hou, Lijuan via user" <us...@flink.apache.org> on 2023/09/07 05:59:44 UTC, 0 replies.
- Re: Kubernetes operator listing jobs TimeoutException - posted by Evgeniy Lyutikov <eb...@avito.ru> on 2023/09/07 06:26:40 UTC, 0 replies.
- Serialize and Parse ResolvedExpression - posted by Xianxun Ye <ye...@gmail.com> on 2023/09/07 06:41:49 UTC, 2 replies.
- updating keyed state in open method. - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2023/09/07 07:37:50 UTC, 3 replies.
- using CheckpointedFunction on a keyed state - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2023/09/07 07:59:03 UTC, 3 replies.
- kafka duplicate messages - posted by nick toker <ni...@gmail.com> on 2023/09/07 11:35:41 UTC, 1 replies.
- Order of Execution in KeyedBroadcastProcessFunction - posted by Anil K <se...@gmail.com> on 2023/09/07 12:15:45 UTC, 2 replies.
- Why flink-s3-fs-presto is recommended for checkpointing - posted by Prabhu Joseph <pr...@gmail.com> on 2023/09/07 12:21:04 UTC, 0 replies.
- Re: [DISCUSS][FLINK-31788][FLINK-33015] Add back Support emitUpdateWithRetract for TableAggregateFunction - posted by Jark Wu <im...@gmail.com> on 2023/09/07 13:29:53 UTC, 2 replies.
- Failure to restore from last completed checkpoint - posted by Jacqlyn Bender via user <us...@flink.apache.org> on 2023/09/07 21:11:30 UTC, 3 replies.
- org.apache.flink.kubernetes.shaded.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException - posted by han <cj...@163.com> on 2023/09/08 06:52:50 UTC, 0 replies.
- Problem when testing table API in local - posted by Oscar Perez via user <us...@flink.apache.org> on 2023/09/08 13:16:19 UTC, 4 replies.
- observedGeneration field in FlinkDeployment - posted by Tony Chen <to...@robinhood.com> on 2023/09/08 21:48:49 UTC, 3 replies.
- Watermarks - posted by Sid <fl...@gmail.com> on 2023/09/09 07:46:51 UTC, 3 replies.
- Incompatible KafkaProducer version - posted by Krzysztof Jankiewicz <ja...@gmail.com> on 2023/09/10 12:34:31 UTC, 3 replies.
- Flink kubernets operator delete HA metadata after resuming from suspend - posted by Evgeniy Lyutikov <eb...@avito.ru> on 2023/09/11 09:20:48 UTC, 7 replies.
- e2e tests with flink - posted by Oscar Perez via user <us...@flink.apache.org> on 2023/09/11 09:38:32 UTC, 1 replies.
- Feedback on Testing Guidelines for Data Stream Processing Applications - posted by Alexandre Strapacao Guedes Vianna <as...@cin.ufpe.br> on 2023/09/11 14:51:40 UTC, 0 replies.
- Reading parquet files using Flink - posted by "Hou, Lijuan via user" <us...@flink.apache.org> on 2023/09/11 21:48:43 UTC, 1 replies.
- Re: Heartbeat of TaskManager with id container - posted by xiangyu feng <xi...@gmail.com> on 2023/09/12 02:44:59 UTC, 1 replies.
- Modifying default config when deploying operator with OLM - posted by Zach Lorimer <zl...@gmail.com> on 2023/09/12 15:29:14 UTC, 0 replies.
- Checkpoint jitter? - posted by Őrhidi Mátyás <ma...@gmail.com> on 2023/09/12 20:57:15 UTC, 5 replies.
- pyflink aggfunction in tvf question - posted by faronzz <fa...@163.com> on 2023/09/13 06:56:05 UTC, 0 replies.
- Ways to expose Flink Operator metrics port on k8s? - posted by Zach Lorimer <zl...@gmail.com> on 2023/09/14 01:50:21 UTC, 0 replies.
- Install Flink Document as a PDF Book - posted by Yunhui Han <la...@gmail.com> on 2023/09/14 10:18:39 UTC, 1 replies.
- About Flink parquet format - posted by Kamal Mittal via user <us...@flink.apache.org> on 2023/09/14 11:26:48 UTC, 8 replies.
- Flink upgrade 1.14.6 to 1.15.4 -> StackOverflowError - posted by Alexey Trenikhun <ye...@msn.com> on 2023/09/14 17:56:39 UTC, 2 replies.
- 回复: Install Flink Document as a PDF Book - posted by Chen Zhanghao <zh...@outlook.com> on 2023/09/15 04:21:08 UTC, 0 replies.
- Securing Keytab File in Flink - posted by Chirag Dewan via user <us...@flink.apache.org> on 2023/09/15 05:02:17 UTC, 2 replies.
- Maven plugin to detect issues in Flink projects - posted by "Kartoglu, Emre" <ka...@amazon.co.uk> on 2023/09/15 10:31:43 UTC, 4 replies.
- Urgent: Mitigating Slow Consumer Impact and Seeking Open-Source Solutions in Apache Kafka Consumers - posted by Karthick <ib...@gmail.com> on 2023/09/15 10:40:54 UTC, 5 replies.
- Recommended Download Directory for File Source - posted by Kirti Dhar Upadhyay K via user <us...@flink.apache.org> on 2023/09/15 10:55:35 UTC, 1 replies.
- Flink 1.15 KubernetesHaServicesFactory - posted by Alexey Trenikhun <ye...@msn.com> on 2023/09/16 02:36:41 UTC, 2 replies.
- Re: Urgent: Mitigating Slow Consumer Impact and Seeking Open-SourceSolutions in Apache Kafka Consumers - posted by Wei Chen <sa...@qq.com> on 2023/09/16 22:34:40 UTC, 4 replies.
- HA in k8s operator - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2023/09/16 23:58:55 UTC, 3 replies.
- 回复: HA in k8s operator - posted by Chen Zhanghao <zh...@outlook.com> on 2023/09/17 05:27:26 UTC, 0 replies.
- FlinkML 'DenseVector' object has no attribute 'get_fields_by_names' - posted by Evgeniy Lyutikov <eb...@avito.ru> on 2023/09/18 07:29:41 UTC, 2 replies.
- Custom Metrics not showing in prometheus - posted by patricia lee <pl...@gmail.com> on 2023/09/18 08:58:17 UTC, 1 replies.
- Possible bug when converting table to upsert changelog stream - posted by Charles Tan <ct...@gmail.com> on 2023/09/18 14:19:39 UTC, 1 replies.
- Upgrading Flink to 1.17, facing org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator - posted by "Hou, Lijuan via user" <us...@flink.apache.org> on 2023/09/18 21:07:47 UTC, 0 replies.
- flink design pazzule - posted by 李柱良 <24...@qq.com> on 2023/09/19 01:58:10 UTC, 1 replies.
- Query Regarding CSV Decoder - posted by Kirti Dhar Upadhyay K via user <us...@flink.apache.org> on 2023/09/19 07:49:19 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions Release 3.3.0 released - posted by Martijn Visser <ma...@apache.org> on 2023/09/19 10:37:09 UTC, 1 replies.
- [CVE-2023-41834] Apache Flink Stateful Functions allowed HTTP header injection due to Improper Neutralization of CRLF Sequences - posted by Martijn Visser <ma...@apache.org> on 2023/09/19 10:43:45 UTC, 0 replies.
- Using Flink k8s operator on OKD - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2023/09/19 22:00:50 UTC, 2 replies.
- 回复： flink design pazzule - posted by 李柱良 <24...@qq.com> on 2023/09/20 02:16:49 UTC, 0 replies.
- Extract response stream out of a AsyncSinkBase operator - posted by Bhupendra Yadav <en...@gmail.com> on 2023/09/20 10:56:14 UTC, 0 replies.
- Test message - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2023/09/20 19:24:32 UTC, 0 replies.
- Zookeeper HA with Kubernetes: Possible to use the same Zookeeper cluster w/multiple Flink Operators? - posted by Brian King <bk...@wikimedia.org> on 2023/09/20 21:57:34 UTC, 2 replies.
- Flink Gzip Sink with Error - posted by Yunhui Han <la...@gmail.com> on 2023/09/21 04:11:58 UTC, 0 replies.
- Window aggregation on two joined table - posted by Eugenio Marotti <in...@gmail.com> on 2023/09/21 06:55:37 UTC, 4 replies.
- Postgres Jdbc Exactly Once Sink Deadlock with UPSERT query - posted by Pascal Rosenkranz <pr...@mail.de> on 2023/09/21 10:01:39 UTC, 0 replies.
- Completable Future in RichSinkFunction with Retry - posted by patricia lee <pl...@gmail.com> on 2023/09/21 15:52:00 UTC, 0 replies.
- Is there any example that use hbase connector in stream API - posted by 碳酸君 <zw...@gmail.com> on 2023/09/22 02:00:28 UTC, 3 replies.
- Flink File Source: File read strategy - posted by Kirti Dhar Upadhyay K via user <us...@flink.apache.org> on 2023/09/22 07:10:39 UTC, 3 replies.
- Side outputs documentation - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2023/09/22 08:54:50 UTC, 4 replies.
- Parallel Count Metrics relation - posted by Kenan Kılıçtepe <kk...@gmail.com> on 2023/09/22 14:46:11 UTC, 0 replies.
- Issue with flink-kubernetes-operator not updating execution.savepoint.path after savepoint deletion - posted by Nathan Moderwell <na...@robinhood.com> on 2023/09/22 17:20:05 UTC, 2 replies.
- Number of kafka producer thread created - posted by Neha Rawat <N....@netwitness.com> on 2023/09/23 23:59:44 UTC, 0 replies.
- After using the jemalloc memory allocator for a period of time, checkpoint timeout occurs and tasks are stuck - posted by rui chen <ru...@gmail.com> on 2023/09/25 02:15:15 UTC, 6 replies.
- Pending Metrics - posted by rania duni <ra...@gmail.com> on 2023/09/25 07:14:50 UTC, 1 replies.
- Default Flink S3 FileSource Questions - posted by Varun Narayanan Chakravarthy via user <us...@flink.apache.org> on 2023/09/25 16:41:59 UTC, 0 replies.
- Dashboard Bytes/Records Received/Sent showing Zero values - posted by Jason Kania via user <us...@flink.apache.org> on 2023/09/25 22:03:56 UTC, 0 replies.
- Execution model when using AsyncIO - posted by Vignesh Kumar Kathiresan via user <us...@flink.apache.org> on 2023/09/25 23:05:59 UTC, 0 replies.
- ProcessWindowFunction Parallelism - posted by patricia lee <pl...@gmail.com> on 2023/09/26 13:30:56 UTC, 0 replies.
- 回复: ProcessWindowFunction Parallelism - posted by Chen Zhanghao <zh...@outlook.com> on 2023/09/26 13:36:36 UTC, 0 replies.
- backpressure for just one subtask - posted by Kenan Kılıçtepe <kk...@gmail.com> on 2023/09/26 15:06:47 UTC, 0 replies.
- 回复: backpressure for just one subtask - posted by Chen Zhanghao <zh...@outlook.com> on 2023/09/27 01:29:40 UTC, 0 replies.
- Custom Prometheus metrics disappeared in 1.16.2 => 1.17.1 upgrade - posted by Javier Vegas <jv...@strava.com> on 2023/09/27 02:42:33 UTC, 3 replies.
- Continuous errors with Azure ABFSS - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2023/09/27 19:17:04 UTC, 4 replies.
- Flink with HDFS - posted by Jose Henrry Matituy Manchabajoy <he...@gmail.com> on 2023/09/27 20:02:51 UTC, 1 replies.
- Flink Kafka offset commit issues - posted by elakiya udhayanan <la...@gmail.com> on 2023/09/28 07:25:43 UTC, 3 replies.
- Cannot find metata file metadats in directory - posted by rui chen <ru...@gmail.com> on 2023/09/28 10:08:16 UTC, 1 replies.
- Alternate Unaligned Incremental Checkpoints taking longer durations - posted by Saurabh Singh via user <us...@flink.apache.org> on 2023/09/28 17:37:20 UTC, 3 replies.
- Pyflink unittest cases - posted by joshua perez <jo...@gmail.com> on 2023/09/30 08:17:01 UTC, 0 replies.