You are viewing a plain text version of this content. The canonical link for it is here.
- Flink 1.14.4 HybridSource consumes lots of CPU resources - posted by Arthur Li <li...@126.com> on 2022/05/01 01:14:04 UTC, 5 replies.
- Re: Task manager shutting down. - posted by John Smith <ja...@gmail.com> on 2022/05/01 02:04:14 UTC, 5 replies.
- getting EOFException in Table API Flink - posted by Lokeish Desaichetty <lo...@npci.org.in> on 2022/05/01 10:11:13 UTC, 0 replies.
- Re: How to debug Metaspace exception? - posted by John Smith <ja...@gmail.com> on 2022/05/02 03:29:30 UTC, 7 replies.
- About job execution - posted by Ww J <ju...@gmail.com> on 2022/05/02 06:15:42 UTC, 4 replies.
- Flink with JaCoCo - Heartbeat of TaskManager timed out - posted by Sigalit Eliazov <e....@gmail.com> on 2022/05/02 06:42:22 UTC, 2 replies.
- Re: flink operator sometimes cannot start jobmanager after upgrading - posted by Márton Balassi <ba...@gmail.com> on 2022/05/02 08:00:11 UTC, 3 replies.
- How should I call external HTTP services with PyFlink? - posted by Dhavan Vaidya <dh...@kofluence.com> on 2022/05/02 12:53:38 UTC, 6 replies.
- Pyflink -> Redshift/S3/Firehose - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/02 13:36:50 UTC, 1 replies.
- Flink-SQL returning duplicate rows for some records - posted by Joost Molenaar <j....@gmail.com> on 2022/05/02 13:59:48 UTC, 3 replies.
- trigger once (batch job with streaming semantics) - posted by Georg Heiler <ge...@gmail.com> on 2022/05/02 14:45:50 UTC, 5 replies.
- Re: Re: How to define event time and Watermark for intermediary joined table in FlinkSQL? - posted by liuxiangcao <xi...@gmail.com> on 2022/05/02 21:05:57 UTC, 0 replies.
- RE: RocksDB's state size discrepancy with what's seen with state processor API - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2022/05/03 00:47:35 UTC, 1 replies.
- Migrating Flink apps across cloud with state - posted by Hemanga Borah <bo...@gmail.com> on 2022/05/03 01:11:39 UTC, 7 replies.
- Prometheus metrics does not work in 1.15.0 taskmanager - posted by "ChangZhuo Chen (陳昌倬)" <cz...@czchen.org> on 2022/05/03 02:25:35 UTC, 21 replies.
- REMINDER - Travel Assistance available for ApacheCon NA New Orleans 2022 - posted by Gavin McDonald <gm...@apache.org> on 2022/05/03 11:05:04 UTC, 0 replies.
- Re: Using the official flink operator and kubernetes secrets - posted by Yang Wang <da...@gmail.com> on 2022/05/03 14:22:10 UTC, 3 replies.
- flink task manager memory leak - posted by Qihua Yang <ya...@gmail.com> on 2022/05/03 16:24:22 UTC, 3 replies.
- Issue with HybridSource recovering from Savepoint - posted by Kevin Lam <ke...@shopify.com> on 2022/05/03 18:48:05 UTC, 5 replies.
- Flink checkpointing with slow pipelines - posted by Deepak Nagaraj <de...@primer.ai> on 2022/05/03 21:00:41 UTC, 0 replies.
- Setting boundedness for legacy Hadoop sequence file sources - posted by Ken Krugler <kk...@transpac.com> on 2022/05/03 21:10:33 UTC, 0 replies.
- Flink serialization errors at a batch job - posted by Yunus Olgun <yu...@gmail.com> on 2022/05/03 21:30:25 UTC, 1 replies.
- Unsubscribe - posted by Nishant Gupta <ni...@gmail.com> on 2022/05/04 11:26:55 UTC, 4 replies.
- [ANNOUNCE] Apache Flink 1.15.0 released - posted by Yun Gao <ga...@apache.org> on 2022/05/05 06:37:53 UTC, 1 replies.
- Stateful Functions pauses routing during checkpoint. - posted by Ammon Diether <ad...@gmail.com> on 2022/05/05 22:25:55 UTC, 1 replies.
- Re: Checkpoint Timeout Troubleshooting - posted by Sam Ch <sa...@gmail.com> on 2022/05/05 23:26:29 UTC, 0 replies.
- Failed to restore from ck, because of KryoException - posted by "Liting Liu (litiliu)" <li...@cisco.com> on 2022/05/06 02:20:20 UTC, 1 replies.
- Re: How to return JSON Object from UDF - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2022/05/06 08:36:24 UTC, 5 replies.
- Fwd: [Discuss] Creating an Apache Flink slack workspace - posted by Xintong Song <to...@gmail.com> on 2022/05/06 09:07:24 UTC, 22 replies.
- [REMINDER] Final Call for Presentations for Flink Forward San Francisco 2022 - posted by Timo Walther <tw...@apache.org> on 2022/05/06 09:57:37 UTC, 0 replies.
- Practical guidance with Scala and Flink >= 1.15 - posted by Salva Alcántara <sa...@gmail.com> on 2022/05/06 16:36:38 UTC, 8 replies.
- Flink Kubernetes operator not having a scale subresource - posted by Jay Ghiya <gh...@gmail.com> on 2022/05/06 18:03:27 UTC, 5 replies.
- flink Job is throwing depdnecy issue when submitted to clusrer - posted by Great Info <gu...@gmail.com> on 2022/05/07 05:21:18 UTC, 1 replies.
- WaterMark that defined in DDL does not work - posted by JianWen Huang <ji...@gmail.com> on 2022/05/07 08:41:36 UTC, 1 replies.
- Unable to start sql-client when putting flink-table-planner_2.12-1.15.0.jar to lib folder - posted by Jeff Zhang <zj...@gmail.com> on 2022/05/07 14:05:55 UTC, 3 replies.
- PyFlink - java code packaging - posted by aryan m <ma...@gmail.com> on 2022/05/08 02:55:52 UTC, 1 replies.
- Flink EOF Error on Running Code - posted by sambhav gupta <co...@gmail.com> on 2022/05/08 22:20:44 UTC, 1 replies.
- Job with iterative stream easily got stuck during checkpoint/savepoint creation - posted by Chen-Che Huang <ac...@gmail.com> on 2022/05/09 03:06:24 UTC, 0 replies.
- Notify on 0 events in a Tumbling Event Time Window - posted by Shilpa Shankar <ss...@bandwidth.com> on 2022/05/09 12:54:52 UTC, 4 replies.
- FW: Rabbitmq Connection error with Flink version(1.15.0) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/05/09 14:03:18 UTC, 1 replies.
- What causes a task to change parallelism? - posted by Jason Politis <jp...@carrera.io> on 2022/05/09 20:44:38 UTC, 1 replies.
- Re: OOM errors cause by the new KafkaSink API - posted by Hua Wei Chen <os...@gmail.com> on 2022/05/10 02:28:46 UTC, 3 replies.
- How to get flink to use POJO serializer when enum is present in POJO class - posted by Tejas B <te...@gmail.com> on 2022/05/10 05:22:41 UTC, 5 replies.
- Re: RichAsyncFunction + Cache or Map State? - posted by Dan Hill <qu...@gmail.com> on 2022/05/10 05:45:05 UTC, 0 replies.
- table.local-time-zone not working - posted by Surendra Lalwani <su...@swiggy.in> on 2022/05/10 07:01:01 UTC, 4 replies.
- sharing data between 2 pipelines - posted by Sigalit Eliazov <e....@gmail.com> on 2022/05/10 10:09:11 UTC, 2 replies.
- Converting from table to stream, following Avro schema - posted by Dhavan Vaidya <dh...@kofluence.com> on 2022/05/10 13:09:14 UTC, 4 replies.
- Re: [State Processor API] unable to load the state of a trigger attached to a session window - posted by Dongwon Kim <ea...@gmail.com> on 2022/05/11 01:07:20 UTC, 2 replies.
- [ANNOUNCE] Apache Flink Table Store 0.1.0 released - posted by Jingsong Lee <lz...@apache.org> on 2022/05/11 05:55:17 UTC, 1 replies.
- Getting JSON kafka source parsing error with DDL - posted by Shubham Bansal <sh...@gmail.com> on 2022/05/11 06:19:55 UTC, 1 replies.
- How can I set job parameter in flink sql - posted by wang <24...@163.com> on 2022/05/11 06:36:37 UTC, 4 replies.
- Query on using Apache Flink with Confluent Kafka - posted by elakiya udhayanan <la...@gmail.com> on 2022/05/11 07:27:41 UTC, 0 replies.
- Flink on Native K8s jobs turn in to `SUSPENDED` status unexpectedly. - posted by Xiaolong Wang <xi...@smartnews.com> on 2022/05/11 11:17:43 UTC, 2 replies.
- Resizing kube container sizes dynamically for custom jobs - posted by "Geldenhuys, Morgan Karl" <mo...@tu-berlin.de> on 2022/05/11 13:42:52 UTC, 1 replies.
- [QUESTION] In Flink k8s Application mode with HA can not using History Server for history backend - posted by 谭家良 <ta...@126.com> on 2022/05/11 14:27:10 UTC, 0 replies.
- unsubscribe - posted by Henry Cai <hc...@pinterest.com> on 2022/05/11 17:14:43 UTC, 2 replies.
- How to define TypeInformation for Flink recursive resolved POJO - posted by Fuyao Li <fu...@oracle.com> on 2022/05/11 19:03:45 UTC, 1 replies.
- Incompatible data types while using firehose sink - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/11 19:39:41 UTC, 6 replies.
- Checkpointing - Job Manager S3 Head Requests are 404s - posted by Aeden Jameson <ae...@gmail.com> on 2022/05/11 23:53:41 UTC, 5 replies.
- Source without persistent state - posted by Alexey Trenikhun <ye...@msn.com> on 2022/05/12 02:28:41 UTC, 0 replies.
- AWS EMR Yarn api shutdown flink task container does`t work - posted by WuKong <wu...@foxmail.com> on 2022/05/12 03:30:20 UTC, 0 replies.
- http stream as input data source - posted by Harald Busch <ba...@bnv-bamberg.de> on 2022/05/12 03:37:29 UTC, 3 replies.
- Configuring heap size for Flink client - posted by Zhanghao Chen <zh...@outlook.com> on 2022/05/12 04:05:16 UTC, 0 replies.
- How to test Flink SQL UDF with open method? - posted by zhouhaifengmath <zh...@gmail.com> on 2022/05/12 06:33:46 UTC, 2 replies.
- Data loss while writing to File System - posted by Surendra Lalwani <su...@swiggy.in> on 2022/05/12 08:55:12 UTC, 0 replies.
- At-least once sinks and their behaviour in a non-failure scenario - posted by Piotr Domagalski <pi...@domagalski.com> on 2022/05/12 09:28:08 UTC, 1 replies.
- Batching in kinesis sink - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/12 10:30:47 UTC, 2 replies.
- Incorrect checkpoint id used when job is recovering - posted by tao xiao <xi...@gmail.com> on 2022/05/12 13:18:22 UTC, 4 replies.
- Community fork of Flink Scala API for Scala 2.12/2.13/3.x - posted by Roman Grebennikov <gr...@dfdx.me> on 2022/05/12 14:42:35 UTC, 4 replies.
- Pulsar/Flink Error: PulsarAdminException$NotFoundException: Topic not exist - posted by Jason Kania <ja...@ymail.com> on 2022/05/12 16:28:42 UTC, 0 replies.
- Re: [External] : Re: How to define TypeInformation for Flink recursive resolved POJO - posted by Fuyao Li <fu...@oracle.com> on 2022/05/12 16:45:58 UTC, 1 replies.
- Re: [External] : Re: How to get flink to use POJO serializer when enum is present in POJO class - posted by Fuyao Li <fu...@oracle.com> on 2022/05/13 04:08:01 UTC, 0 replies.
- Split string flatmap -> Arraylist/List - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/13 07:29:01 UTC, 1 replies.
- Join two data stream using DataStream API using PyFlink - posted by lan tran <in...@gmail.com> on 2022/05/13 08:35:07 UTC, 1 replies.
- Flink MiniCluster: Multiple Task Managers - posted by Κωνσταντίνος Αγαπίδης <cs...@csd.uoc.gr> on 2022/05/14 18:45:01 UTC, 2 replies.
- taskexecutor .out files - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/15 11:04:37 UTC, 3 replies.
- Kinesis Sink - Data being received with intermittent breaks - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/15 22:12:35 UTC, 8 replies.
- What is the alternative schema of DirectOutput - posted by Boot <33...@qq.com> on 2022/05/16 09:19:01 UTC, 0 replies.
- Does kafka key is supported in kafka sink table - posted by wang <24...@163.com> on 2022/05/16 14:03:12 UTC, 2 replies.
- Running in application mode on YARN without fat jar - posted by Pavel Penkov <eb...@gmail.com> on 2022/05/16 14:59:35 UTC, 1 replies.
- How to distribute DataStream rows parallelly to executors without duplication - posted by Anitha Thankappan <an...@quantiphi.com> on 2022/05/16 16:38:26 UTC, 0 replies.
- Help - for single input, getting multiple same output over each slide's - posted by Shankar Mane <ss...@gmail.com> on 2022/05/16 16:40:22 UTC, 5 replies.
- Checkpoint directories not cleared as TaskManagers run - posted by James Sandys-Lumsdaine <ja...@hotmail.com> on 2022/05/16 17:52:17 UTC, 6 replies.
- Checkpoint declined (Null Pointer exception) - posted by Sudharsan R <su...@gmail.com> on 2022/05/16 23:33:36 UTC, 0 replies.
- Question of Flink Operator Application Cluster Deployment - posted by Xiao Ma <xi...@geotab.com> on 2022/05/17 03:37:09 UTC, 5 replies.
- How to avoid multiple reading from same topic - posted by Surendra Lalwani <su...@swiggy.in> on 2022/05/17 07:44:23 UTC, 3 replies.
- Channel became inactive while submitting job - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/17 10:33:44 UTC, 1 replies.
- Metrics in Flink UI - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/17 19:28:50 UTC, 2 replies.
- Memory configuration for Queue - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/17 20:50:13 UTC, 0 replies.
- Deployment on k8s via API - posted by Devin Bost <de...@gmail.com> on 2022/05/18 00:28:16 UTC, 1 replies.
- Could not copy native libraries - Permission denied - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/18 08:07:04 UTC, 1 replies.
- How to KafkaConsume from Particular Partition in Flink(version 1.14.4) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/05/18 09:02:29 UTC, 2 replies.
- [ANNOUNCE] Call for Presentations for ApacheCon Asia 2022 streaming track - posted by Yu Li <ca...@gmail.com> on 2022/05/18 11:47:47 UTC, 0 replies.
- Flink Job Execution issue at Yarn - posted by Anitha Thankappan <an...@quantiphi.com> on 2022/05/18 12:25:43 UTC, 0 replies.
- Schema Evolution of POJOs fails on Field Removal - posted by David Jost <da...@uniberg.com> on 2022/05/18 13:07:11 UTC, 3 replies.
- 答复: Flink Job Execution issue at Yarn - posted by Geng Biao <bi...@gmail.com> on 2022/05/18 13:08:18 UTC, 0 replies.
- Kafka Sink Key and Value Avro Schema Usage Issues - posted by "Ghiya, Jay (GE Healthcare)" <Ja...@ge.com> on 2022/05/18 16:21:06 UTC, 2 replies.
- Confusing S3 Entropy Injection Behavior - posted by Aeden Jameson <ae...@gmail.com> on 2022/05/18 17:47:48 UTC, 3 replies.
- Window aggregation fails after upgrading to Flink 1.15 - posted by Pouria Pirzadeh <po...@gmail.com> on 2022/05/19 00:53:03 UTC, 3 replies.
- Flink application on yarn cluster - main method not found - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/19 08:49:23 UTC, 2 replies.
- Flink Stateful Function - Regex Match in State Key - posted by Himanshu Sareen <hi...@outlook.com> on 2022/05/19 09:30:04 UTC, 0 replies.
- Re: HTTP REST API as Ingress/Egress - posted by Himanshu Sareen <hi...@outlook.com> on 2022/05/19 09:35:02 UTC, 1 replies.
- Final reminder: ApacheCon North America call for presentations closing soon - posted by Rich Bowen <rb...@apache.org> on 2022/05/19 09:44:23 UTC, 0 replies.
- Applying backpressure to limit state memory consumption - posted by Robin Cassan <ro...@contentsquare.com> on 2022/05/19 13:19:04 UTC, 2 replies.
- Introducing Statefun Tsukuyomi - posted by Tymur Yarosh <ti...@gmail.com> on 2022/05/19 13:19:42 UTC, 0 replies.
- Job Logs - Yarn Application Mode - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/19 14:56:39 UTC, 6 replies.
- Flink - SQL Tumble End on event time not returning any result - posted by Raghunadh Nittala <ra...@gmail.com> on 2022/05/20 02:44:39 UTC, 0 replies.
- accuracy validation of streaming pipeline - posted by vtygoss <vt...@126.com> on 2022/05/20 08:02:39 UTC, 4 replies.
- [DISCUSS] Update Scala 2.12.7 to 2.12.15 - posted by Martijn Visser <ma...@apache.org> on 2022/05/20 08:36:47 UTC, 2 replies.
- Flatmap node at 100% - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/20 08:51:14 UTC, 2 replies.
- Python Job Type Support in Flink Kubernetes Operator - posted by Jeesmon Jacob <je...@gmail.com> on 2022/05/20 19:46:51 UTC, 2 replies.
- Flink SQL Dates Between and Parallelism - posted by Jason Politis <jp...@carrera.io> on 2022/05/20 20:52:41 UTC, 3 replies.
- Task Manager Heap Memory Overflowing - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/20 21:03:11 UTC, 2 replies.
- Example of Beam Go job that uses Flink Kubernetes operator - posted by Red Daly <re...@gmail.com> on 2022/05/21 00:17:49 UTC, 2 replies.
- Application mode deployment through API call - posted by Leon Xu <lx...@attentivemobile.com> on 2022/05/21 06:24:13 UTC, 7 replies.
- Json Deserialize in DataStream API with array length not fixed - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/21 06:58:33 UTC, 2 replies.
- Flink Job Manager unable to recognize Task Manager Available slots - posted by "s_penakalapati@yahoo.com" <s_...@yahoo.com> on 2022/05/21 19:00:23 UTC, 2 replies.
- Request for Review: FLINK-27507 and FLINK-27509 - posted by Shubham Bansal <sh...@gmail.com> on 2022/05/22 02:12:23 UTC, 1 replies.
- 答复: Application mode deployment through API call - posted by Geng Biao <bi...@gmail.com> on 2022/05/22 03:10:57 UTC, 0 replies.
- Application mode -yarn dependancy error - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/22 15:58:56 UTC, 1 replies.
- Flink UI in Application Mode - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/22 17:43:17 UTC, 3 replies.
- OutputTag alternative with pyflink 1.15.0 - posted by Lakshya Garg <la...@gmail.com> on 2022/05/23 04:02:26 UTC, 2 replies.
- TolerableCheckpointFailureNumber not always applying - posted by Gaël Renoux <ga...@datadome.co> on 2022/05/23 09:18:09 UTC, 4 replies.
- How to enable statefun metrics for the Slf4j reporter - posted by Christopher Gustafson <ch...@kth.se> on 2022/05/23 12:03:05 UTC, 4 replies.
- flink sql api, exception when setting "table.exec.state.ttl" - posted by 李诗君 <li...@126.com> on 2022/05/23 12:32:33 UTC, 2 replies.
- Flink Kubernetes Operator: Specifying env variables from ConfigMaps - posted by Mads Ellersgaard Kalør <me...@kaunt.com> on 2022/05/23 13:19:41 UTC, 2 replies.
- GlobalCommitter in Flink's two-phase commit - posted by di wu <67...@qq.com> on 2022/05/24 07:11:24 UTC, 1 replies.
- Flink HUDI Sink - MinIO S3 access Issue - posted by sambhav gupta <co...@gmail.com> on 2022/05/24 10:02:35 UTC, 1 replies.
- Source vs SourceFunction and testing - posted by Piotr Domagalski <pi...@domagalski.com> on 2022/05/24 15:34:25 UTC, 7 replies.
- Flink DataStream and remote Stateful Functions interoperability - posted by Himanshu Sareen <hi...@outlook.com> on 2022/05/24 18:15:40 UTC, 1 replies.
- LinkedMap ClassCastException issue - posted by wang <24...@163.com> on 2022/05/25 07:01:11 UTC, 1 replies.
- length value for some classes extending LogicalType. - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2022/05/25 09:29:10 UTC, 3 replies.
- Flink 1.14.4 -> 1.15.0 Upgrade Problem - posted by Clayton Wohl <cl...@gmail.com> on 2022/05/25 16:24:37 UTC, 1 replies.
- how does a slow FaaS affect the Flink StateFun cluster? - posted by Marco Villalobos <mv...@kineteque.com> on 2022/05/25 21:41:53 UTC, 0 replies.
- Flink metrics flattened after Job restart - posted by Sahil Aulakh <sa...@gmail.com> on 2022/05/26 01:39:03 UTC, 2 replies.
- Any lessons-learned with boundless (infinite) joins, especially at scale? - posted by Devin Bost <de...@gmail.com> on 2022/05/26 03:02:09 UTC, 1 replies.
- Custom restart strategy - posted by unknown unknown <un...@gmail.com> on 2022/05/26 15:05:43 UTC, 3 replies.
- Exception when running Java UDF with Blink table planner - posted by Tom Thornton <th...@yelp.com> on 2022/05/26 22:47:04 UTC, 2 replies.
- How to achieve processing model as Storm - posted by calvin beloy <cc...@yahoo.com> on 2022/05/27 14:10:04 UTC, 1 replies.
- Questions about Flink Stateful Functions Current Capabilities - posted by Ryan van Huuksloot <ry...@shopify.com> on 2022/05/28 20:29:58 UTC, 0 replies.
- Large backpressure and slow checkpoints in StateFun - posted by Christopher Gustafson <ch...@kth.se> on 2022/05/30 06:29:19 UTC, 1 replies.
- Can we use CheckpointedFunction with the new Source api? - posted by Qing Lim <q....@mwam.com> on 2022/05/30 12:09:15 UTC, 3 replies.
- Status of File Sink Common (flink-file-sink-common) - posted by Jun Qin <qi...@gmail.com> on 2022/05/30 21:24:10 UTC, 3 replies.
- FileSource SourceReader failure scenario - posted by Meghajit Mazumdar <me...@gojek.com> on 2022/05/31 08:29:54 UTC, 2 replies.
- Flink task stuck - MapPartition WAITING on java.util.concurrent.CompletableFuture$Signaller - posted by Gorjan Todorovski <go...@gmail.com> on 2022/05/31 11:54:18 UTC, 0 replies.
- Re: [External] Re: Exception when running Java UDF with Blink table planner - posted by Tom Thornton <th...@yelp.com> on 2022/05/31 18:05:31 UTC, 1 replies.