You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Wrong format when passing arguments with space - posted by 姜鑫 <ji...@gmail.com> on 2022/04/01 03:14:16 UTC, 2 replies.
- Re: [DataStream API] Watermarks not closing TumblingEventTimeWindow with Reduce function - posted by r pp <pr...@gmail.com> on 2022/04/01 07:58:15 UTC, 3 replies.
- Re: Could you please give me a hand about json object in flink sql - posted by Qingsheng Ren <re...@gmail.com> on 2022/04/01 09:25:59 UTC, 6 replies.
- Unbalanced distribution of keyed stream to downstream parallel operators - posted by Isidoros Ioannou <ak...@gmail.com> on 2022/04/01 09:37:09 UTC, 4 replies.
- Re: Question about community collaboration options - posted by Martijn Visser <ma...@apache.org> on 2022/04/01 10:07:19 UTC, 0 replies.
- Re: [External] Re: Potential Bug with Date Serialization for Table Stream - posted by Martijn Visser <ma...@apache.org> on 2022/04/01 11:27:49 UTC, 1 replies.
- Re: DBT-flink profile? - posted by Martijn Visser <ma...@ververica.com> on 2022/04/01 11:34:02 UTC, 0 replies.
- Re: Flink SQL and data shuffling (keyBy) - posted by Marios Trivyzas <ma...@gmail.com> on 2022/04/01 15:52:17 UTC, 3 replies.
- Helm install flink-kubernetes-operator failed - posted by spoon_lz <sp...@126.com> on 2022/04/02 07:11:23 UTC, 2 replies.
- 答复: Helm install flink-kubernetes-operator failed - posted by Geng Biao <bi...@gmail.com> on 2022/04/02 07:25:54 UTC, 0 replies.
- The flink-kubernetes-operator vs third party flink operators - posted by Hao t Chang <ht...@us.ibm.com> on 2022/04/02 09:00:22 UTC, 3 replies.
- Why discard checkpoints on the job finished - posted by Wu Poker <po...@gmail.com> on 2022/04/02 10:29:27 UTC, 1 replies.
- Elasticsearch SQL connector with SSL - posted by Yuheng Zhong <ri...@gmail.com> on 2022/04/03 02:50:11 UTC, 3 replies.
- Basic Question on Incremental Checkpoint/RocksDB - posted by Josson Paul <jo...@gmail.com> on 2022/04/03 05:31:05 UTC, 5 replies.
- Source with S3 bucket with millions ( billions ) of object ( small files ) - posted by Vishal Santoshi <vi...@gmail.com> on 2022/04/03 22:07:16 UTC, 3 replies.
- Submit jobs via Rest API and deploy Flink on a running Kubernetes cluster (Native way) - posted by Burcu Gul POLAT EGRI <be...@sdt.com.tr> on 2022/04/04 08:16:02 UTC, 6 replies.
- temporal join against versioned table - posted by Fruzsina Piroska Nagy <fr...@cloudera.com> on 2022/04/04 10:28:29 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 0.1.0 released - posted by Gyula Fóra <gy...@apache.org> on 2022/04/04 11:45:57 UTC, 0 replies.
- HOP_PROCTIME is returning null - posted by Surendra Lalwani <su...@swiggy.in> on 2022/04/04 13:40:42 UTC, 1 replies.
- Error Using datastream API - posted by Sandeep Sharat <sa...@gmail.com> on 2022/04/04 15:37:00 UTC, 3 replies.
- Question About Histograms - posted by Anil K <se...@gmail.com> on 2022/04/04 19:56:19 UTC, 2 replies.
- Local recovery with 1.15 snapshot - posted by Abdullah Alkawatrah <ak...@gmail.com> on 2022/04/04 21:53:02 UTC, 0 replies.
- WatermarkStrategy for IngestionTime - posted by Xinbin Huang <bi...@apache.org> on 2022/04/04 22:09:14 UTC, 2 replies.
- BigQuery connector debugging - posted by Matthew Brown <me...@matthewbrown.io> on 2022/04/05 07:42:05 UTC, 3 replies.
- FlinkKafkaProducer - Avro - Schema Registry - posted by Dan Serb <da...@boatyardx.com> on 2022/04/05 08:54:11 UTC, 2 replies.
- Flink metric - posted by long ha dac <vo...@yahoo.com> on 2022/04/05 10:51:38 UTC, 1 replies.
- BIGDECIMAL data handling - posted by Anitha Thankappan <an...@quantiphi.com> on 2022/04/05 13:40:27 UTC, 3 replies.
- Why first op after union cannot be chained? - posted by Zhanghao Chen <zh...@outlook.com> on 2022/04/05 16:11:17 UTC, 2 replies.
- Re: Not able to connect with Elasticsearch using PyFlink and connector-jar - posted by Dian Fu <di...@gmail.com> on 2022/04/06 06:53:18 UTC, 1 replies.
- submit jobs to session cluster with external jars - posted by Sitan Pang <na...@gmail.com> on 2022/04/06 08:38:28 UTC, 0 replies.
- HDFS streaming source concerns - posted by Carlos Downey <ca...@gmail.com> on 2022/04/06 14:17:10 UTC, 2 replies.
- python table api - posted by "ivan.rosero@agilent.com" <iv...@agilent.com> on 2022/04/06 14:45:07 UTC, 3 replies.
- Missing metrics in Flink v 1.15.0 rc-0 - posted by Peter Schrott <pe...@bluerootlabs.io> on 2022/04/06 15:19:29 UTC, 2 replies.
- Error during shutdown of StandaloneApplicationClusterEntryPoint via JVM shutdown hook - posted by Alexey Trenikhun <ye...@msn.com> on 2022/04/06 15:20:00 UTC, 3 replies.
- Produnction : Flink 1.14.4 : Kafka reader threads blocked - posted by Vignesh Ramesh <vi...@gmail.com> on 2022/04/07 04:33:56 UTC, 1 replies.
- Official Flink operator additional class paths - posted by Francis Conroy <fr...@switchdin.com> on 2022/04/07 07:13:49 UTC, 2 replies.
- Is there any way to get the ExecutionConfigurations in Dynamic factory class - posted by Anitha Thankappan <an...@quantiphi.com> on 2022/04/07 08:11:16 UTC, 3 replies.
- flink pipeline handles very small amount of messages in a second (only 500) - posted by Sigalit Eliazov <e....@gmail.com> on 2022/04/07 11:12:57 UTC, 2 replies.
- Re: Weird Flink Kafka source watermark behavior - posted by Jin Yi <ji...@promoted.ai> on 2022/04/08 07:54:10 UTC, 7 replies.
- Using state processor API to read state defined with a TypeHint - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2022/04/08 07:58:42 UTC, 2 replies.
- RE: RocksDB state not cleaned up - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2022/04/08 10:54:21 UTC, 1 replies.
- RocksDB's state size discrepancy with what's seen with state processor API - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2022/04/08 14:16:34 UTC, 16 replies.
- DataStream request / response - posted by Jason Thomas <ka...@gmail.com> on 2022/04/08 16:34:37 UTC, 5 replies.
- Unsubscribe - posted by Natalie Dunn <na...@ec.ai> on 2022/04/08 17:25:00 UTC, 8 replies.
- Flink Kafka Issue with EXACTLY_ONCE semantics - posted by Praneeth Ramesh <sr...@gmail.com> on 2022/04/09 01:21:38 UTC, 3 replies.
- StateFun - How to run the application in a Flink cluster and IDE - posted by M Singh <ma...@yahoo.com> on 2022/04/09 14:53:37 UTC, 0 replies.
- table api conditionally double quoting data in csv - posted by Shameet Doshi <sh...@firstperformance.com> on 2022/04/09 20:53:14 UTC, 1 replies.
- Apache StateFun - Broadcast to all functions and Timers - posted by M Singh <ma...@yahoo.com> on 2022/04/10 10:11:34 UTC, 0 replies.
- Unsubscribed - posted by Samir Vasani <sa...@gmail.com> on 2022/04/10 10:32:49 UTC, 1 replies.
- 来自我是当当当的邮件 - posted by 我是当当当 <li...@163.com> on 2022/04/10 15:07:58 UTC, 0 replies.
- Flink job savepoints but job didn't terminate successfully - posted by Dan Hill <qu...@gmail.com> on 2022/04/10 20:31:04 UTC, 1 replies.
- Broadcast state corrupted ? - posted by Alexey Trenikhun <ye...@msn.com> on 2022/04/10 20:39:05 UTC, 7 replies.
- How to process events with different JSON schemas in single Kinesis stream using PyFlink? - posted by John Tipper <jo...@hotmail.com> on 2022/04/10 22:10:45 UTC, 2 replies.
- Avro deserialization issue - posted by Anitha Thankappan <an...@quantiphi.com> on 2022/04/11 13:41:53 UTC, 3 replies.
- Enabling savepoints when deploying in Application Mode - posted by Lilli Pearson <ep...@wayfair.com> on 2022/04/11 18:08:40 UTC, 2 replies.
- Discuss making KafkaSubscriber Public - posted by Mason Chen <ma...@gmail.com> on 2022/04/12 03:46:05 UTC, 4 replies.
- Reactive mode and checkpointing - posted by aryan m <ma...@gmail.com> on 2022/04/12 04:42:46 UTC, 3 replies.
- How to reprocess historical data with event-time windowing? - posted by Ty Brooks <tb...@sovrn.com> on 2022/04/12 15:28:32 UTC, 1 replies.
- Apache StateFun - A few questions about of module.yaml - posted by M Singh <ma...@yahoo.com> on 2022/04/12 19:11:51 UTC, 0 replies.
- Issue with doing filesink to HDFS - posted by Anubhav Nanda <aa...@gmail.com> on 2022/04/13 04:50:08 UTC, 3 replies.
- Flink state migration from 1.9 to 1.13 - posted by XU Qinghui <qi...@gmail.com> on 2022/04/13 17:44:45 UTC, 4 replies.
- Supporting different content-types such as String or JSON seems to always fail for me in Stateful Functions. - posted by Marco Villalobos <mv...@kineteque.com> on 2022/04/14 00:51:23 UTC, 6 replies.
- Entropy injection for S3 - posted by "Deshpande, Omkar" <Om...@intuit.com> on 2022/04/14 01:25:05 UTC, 0 replies.
- Interrupt collect() function when reading from kafka topic (in pyflink) - posted by Marjan Jordanovski <mj...@gmail.com> on 2022/04/14 10:24:09 UTC, 1 replies.
- FW: Pyflink Kafka consumer error (version 1.14.4) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/04/14 11:50:38 UTC, 1 replies.
- Re: How to debug Metaspace exception? - posted by John Smith <ja...@gmail.com> on 2022/04/14 15:59:19 UTC, 16 replies.
- Handling non-transient exceptions - posted by Jose Brandao <Jo...@blip.pt> on 2022/04/14 16:33:22 UTC, 3 replies.
- [Flink] ArrayIndexOutOfBound when encoding string to byte[] - posted by vtygoss <vt...@126.com> on 2022/04/15 07:00:43 UTC, 1 replies.
- 订阅 - posted by ZJYDZ1101 <lu...@vip.qq.com> on 2022/04/15 09:25:42 UTC, 0 replies.
- Vertica jdbc sink error - posted by Jasmin Redzepovic <ja...@superbet.com> on 2022/04/15 12:26:45 UTC, 1 replies.
- How to define event time and Watermark for intermediary joined table in FlinkSQL? - posted by liuxiangcao <xi...@gmail.com> on 2022/04/15 19:06:40 UTC, 3 replies.
- Re: java.lang.Exception: Job leader for job id 0efd8681eda64b072b72baef58722bc0 lost leadership. - posted by Jai Patel <ja...@cloudkitchens.com> on 2022/04/15 21:51:05 UTC, 2 replies.
- UnsupportedOperationException: The end timestamp of a processing-time window cannot become earlier than the current processing time by merging. - posted by Jai Patel <ja...@cloudkitchens.com> on 2022/04/15 21:57:39 UTC, 2 replies.
- how to initialize few things at task managers - posted by Great Info <gu...@gmail.com> on 2022/04/16 15:44:12 UTC, 4 replies.
- Huge number of GAX-Threads in Flink - posted by SHREEKANT ANKALA <as...@hotmail.com> on 2022/04/17 07:37:50 UTC, 3 replies.
- XXX doesn't exist in the parameters of the SQL statement - posted by John Tipper <jo...@hotmail.com> on 2022/04/17 13:14:18 UTC, 1 replies.
- Apache Flink StateFun user email list - posted by M Singh <ma...@yahoo.com> on 2022/04/17 14:08:56 UTC, 0 replies.
- Unable to create savepoint for iterative job - posted by Chen-Che Huang <ac...@gmail.com> on 2022/04/18 10:16:24 UTC, 1 replies.
- Adpative scheduler is not recognizing by Flink 1.14.0 - posted by Madan D <ma...@yahoo.com.au> on 2022/04/18 21:28:47 UTC, 1 replies.
- DecimalType.MAX_PRECISION, why 38? - posted by Yaroslav Tkachenko <ya...@goldsky.io> on 2022/04/19 00:42:02 UTC, 1 replies.
- New JM pod tries to connect to failed JM pod - posted by Alexey Trenikhun <ye...@msn.com> on 2022/04/19 01:25:11 UTC, 1 replies.
- [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/04/19 07:28:02 UTC, 1 replies.
- Flink checkpointing configuration - posted by Nikola Hrusov <n....@gmail.com> on 2022/04/19 13:08:16 UTC, 0 replies.
- /status endpoint of flink jobmanager not working - posted by Peter Schrott <pe...@bluerootlabs.io> on 2022/04/19 13:18:33 UTC, 1 replies.
- TumblingEventTimeWindows is not recognised by Flink-(version 1.14.4) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/04/19 13:22:24 UTC, 1 replies.
- flink-stop command fails with ` Operation not found under key` - posted by Harsh Shah <ha...@shopify.com> on 2022/04/19 16:21:48 UTC, 2 replies.
- Re: [EXT] Vertica jdbc sink error - posted by Jasmin Redzepovic <ja...@superbet.com> on 2022/04/19 20:34:02 UTC, 1 replies.
- Re: Alertmanager Sink Connector - posted by Konstantin Knauf <kn...@apache.org> on 2022/04/20 11:17:17 UTC, 1 replies.
- Problems with PrometheusReporter - posted by Peter Schrott <pe...@bluerootlabs.io> on 2022/04/20 14:48:13 UTC, 4 replies.
- Watermarking not advancing when parallelism is higher than kafka partitions and table.exec.source.idle-timeout is enabled - posted by liuxiangcao <xi...@gmail.com> on 2022/04/20 15:20:34 UTC, 3 replies.
- RocksDB efficiency and keyby - posted by Trystan <en...@gmail.com> on 2022/04/20 15:49:51 UTC, 4 replies.
- Restore Job from CheckPoint in IntelliJ IDE - MiniCluster - posted by Κωνσταντίνος Αγαπίδης <cs...@csd.uoc.gr> on 2022/04/20 20:01:52 UTC, 2 replies.
- Integration Test for Kafka Streaming job - posted by Alexey Trenikhun <ye...@msn.com> on 2022/04/20 22:00:50 UTC, 3 replies.
- Kubernetes killing TaskManager - Flink ignoring taskmanager.memory.process.size - posted by Dan Hill <qu...@gmail.com> on 2022/04/20 23:35:27 UTC, 2 replies.
- AvroRowDeserializationSchema - posted by lan tran <in...@gmail.com> on 2022/04/21 06:43:32 UTC, 14 replies.
- Jobmanager trying to be registered for Zombie Job - posted by Peter Schrott <pe...@bluerootlabs.io> on 2022/04/21 16:08:10 UTC, 9 replies.
- Exception Handling in ElasticsearchSink - posted by Rion Williams <ri...@gmail.com> on 2022/04/21 20:49:17 UTC, 1 replies.
- How to dynamically modify the schema information of a table - posted by 草莓 <w7...@163.com> on 2022/04/22 02:44:47 UTC, 2 replies.
- [ANNOUNCE] Apache Kyuubi (Incubating) released 1.5.1-incubating - posted by Fu Chen <fc...@apache.org> on 2022/04/22 03:00:54 UTC, 2 replies.
- DebeziumAvroDeserializationSchema - posted by lan tran <in...@gmail.com> on 2022/04/22 03:14:43 UTC, 1 replies.
- UUID on TableAPI - posted by lan tran <in...@gmail.com> on 2022/04/22 03:22:49 UTC, 5 replies.
- JobManager doesn't bring up new TaskManager during failure recovery - posted by "Zheng, Chenyu" <ch...@disneystreaming.com> on 2022/04/22 04:33:05 UTC, 6 replies.
- Flink batch mode does not sort by event timestamp - posted by Han You <Ha...@akunacapital.com> on 2022/04/22 05:57:02 UTC, 1 replies.
- test - posted by Samir Vasani <sa...@gmail.com> on 2022/04/22 14:19:26 UTC, 0 replies.
- How to use RichAsyncFunction with MiniClusterWithClientResource - posted by Satish Saley <sa...@apache.org> on 2022/04/22 16:41:40 UTC, 0 replies.
- Savepoint and cancel questions - posted by Dan Hill <qu...@gmail.com> on 2022/04/22 23:37:53 UTC, 2 replies.
- KAFKA SINK ERROR IN Flink-(version 1.14.4) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/04/23 05:46:03 UTC, 0 replies.
- Unit testing PyFlink SQL project - posted by John Tipper <jo...@hotmail.com> on 2022/04/23 20:44:12 UTC, 9 replies.
- HTTP REST API as Ingress/Egress - posted by Himanshu Sareen <hi...@outlook.com> on 2022/04/24 01:29:53 UTC, 0 replies.
- Re: KAFKA SINK ERROR IN Flink-(version 1.14.4) - posted by Dian Fu <di...@gmail.com> on 2022/04/24 01:40:12 UTC, 0 replies.
- Fwd: Write to Aliyun OSS via FileSystem connector hang Job Master on Finishing - posted by Yi Tang <ss...@gmail.com> on 2022/04/24 03:38:58 UTC, 2 replies.
- Random incorrect checkpoint existence check - posted by Chen-Che Huang <ac...@gmail.com> on 2022/04/25 01:57:40 UTC, 1 replies.
- TaskMgr Metaspace become bigger and bigger after submitting new jobs - posted by Lei Wang <le...@gmail.com> on 2022/04/25 02:09:46 UTC, 0 replies.
- how to setup working dir in Flink operator - posted by "ChangZhuo Chen (陳昌倬)" <cz...@czchen.org> on 2022/04/25 02:19:04 UTC, 2 replies.
- OOM errors cause by the new KafkaSink API - posted by Hua Wei Chen <os...@gmail.com> on 2022/04/25 03:44:08 UTC, 3 replies.
- Potential memory leak in org.apache.flink.runtime.checkpoint.DefaultCompletedCheckpointStore - posted by Hua Wei Chen <os...@gmail.com> on 2022/04/25 07:27:08 UTC, 1 replies.
- NO jobmanager.log for yarn-per-job submitted with sql-client.sh - posted by ruiyun wan <wr...@gmail.com> on 2022/04/26 09:21:36 UTC, 1 replies.
- Task manager shutting down. - posted by John Smith <ja...@gmail.com> on 2022/04/26 14:00:38 UTC, 2 replies.
- Kafka Sink Error in sending Row Type data in Flink-(version 1.14.4) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/04/27 10:57:33 UTC, 0 replies.
- Re: Kafka Sink Error in sending Row Type data in Flink-(version 1.14.4) - posted by Dian Fu <di...@gmail.com> on 2022/04/27 12:33:18 UTC, 0 replies.
- Flink team staffing - posted by Wei Liu <sm...@gmail.com> on 2022/04/27 23:31:36 UTC, 1 replies.
- Temporal join fails with "unexpected correlate variable $cor0 in the plan" - posted by Matthew Brown <me...@matthewbrown.io> on 2022/04/28 06:01:17 UTC, 1 replies.
- Flink-Iceberg Table Sink failing with org.apache.hadoop.fs.s3a.S3AStorageStatistics Cast exception - posted by Terry Heathcote <te...@gmail.com> on 2022/04/28 09:04:50 UTC, 1 replies.
- Using the official flink operator and kubernetes secrets - posted by Francis Conroy <fr...@switchdin.com> on 2022/04/28 09:30:46 UTC, 2 replies.
- Broadcast State + Stateful Operator + Async IO - posted by Vishal Surana <vi...@moengage.com> on 2022/04/28 16:41:38 UTC, 4 replies.
- Checkpoint Timeout Troubleshooting - posted by Sam Ch <sa...@gmail.com> on 2022/04/28 18:10:35 UTC, 1 replies.
- flink operator sometimes cannot start jobmanager after upgrading - posted by "ChangZhuo Chen (陳昌倬)" <cz...@czchen.org> on 2022/04/29 10:15:41 UTC, 0 replies.
- Multiple INSERT INTO within single PyFlink job? - posted by John Tipper <jo...@hotmail.com> on 2022/04/29 13:07:40 UTC, 1 replies.
- Kubernetes Operator --allowNonRestoredState config - posted by Shqiprim Bunjaku <sh...@gmail.com> on 2022/04/29 15:25:29 UTC, 2 replies.
- Could not restore state after upgrade from 1.11 -> 1.13 - posted by Tom Thornton <th...@yelp.com> on 2022/04/29 17:27:36 UTC, 1 replies.