You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Issue upgrading to Flink v1.14.3; non-restored state - posted by Dan Hill <qu...@gmail.com> on 2022/03/01 00:32:08 UTC, 4 replies.
- - posted by 谭 海棠 <mu...@outlook.com> on 2022/03/01 00:56:04 UTC, 1 replies.
- Flink failure rate restart not work as expect - posted by 刘 家锹 <LJ...@outlook.com> on 2022/03/01 02:23:03 UTC, 6 replies.
- 退订 - posted by 谭 海棠 <mu...@outlook.com> on 2022/03/01 03:48:08 UTC, 0 replies.
- Re: pyflink object to java object - posted by Xingbo Huang <hx...@gmail.com> on 2022/03/01 04:05:48 UTC, 1 replies.
- Re: Pods are OOMKilled with RocksDB backend after a few checkpoints - posted by Yun Tang <my...@live.com> on 2022/03/01 07:30:19 UTC, 4 replies.
- RE: processwindowfunction output Iterator - posted by Schwalbe Matthias <Ma...@viseca.ch> on 2022/03/01 08:26:49 UTC, 1 replies.
- Adaptive Batch Configuration Does Not Work - posted by Edwin <xu...@163.com> on 2022/03/01 11:30:33 UTC, 1 replies.
- Netty Client Thread - Classloader leak - posted by Sudharsan R <su...@gmail.com> on 2022/03/01 15:52:34 UTC, 1 replies.
- Flink 1.13.6 showing 1.13.5 - posted by Razin Bouzar <rb...@salesforce.com> on 2022/03/01 18:00:51 UTC, 2 replies.
- Looking for advice on moving Datastream job to Table SQL - posted by Jonathan Weaver <my...@gmail.com> on 2022/03/01 19:13:27 UTC, 0 replies.
- Re: Flink job recovery after task manager failure - posted by "Afek, Ifat (Nokia - IL/Kfar Sava)" <if...@nokia.com> on 2022/03/01 21:55:15 UTC, 3 replies.
- org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send data to Kafka: Pending record count must be zero at this point: 5592 - posted by 刘方亮 <li...@gmail.com> on 2022/03/02 02:26:00 UTC, 0 replies.
- 回复: Flink failure rate restart not work as expect - posted by 刘 家锹 <LJ...@outlook.com> on 2022/03/02 05:54:40 UTC, 0 replies.
- Left join query not clearing state after migrating from 1.9.0 to 1.14.3 - posted by Prakhar Mathur <pr...@gojek.com> on 2022/03/02 08:41:16 UTC, 4 replies.
- Kafka Source in a Geo Replicated Kafka Cluster - posted by Chirag Dewan <ch...@yahoo.in> on 2022/03/02 09:26:27 UTC, 0 replies.
- Help with pom dependencies for Flink with Table API - posted by Adesh Dsilva <ad...@gmail.com> on 2022/03/02 17:37:21 UTC, 2 replies.
- KafkaPartitionSplitReader handleSplitsChanges - posted by Mason Chen <ma...@gmail.com> on 2022/03/02 22:16:58 UTC, 1 replies.
- Questions regarding connecting local FlinkSQL client to remote JobManager in K8s - posted by Elkhan Dadashov <el...@gmail.com> on 2022/03/02 22:20:20 UTC, 2 replies.
- Customizing backpressure mechanism for RichParallelSourceFunction - posted by Le Xu <sh...@gmail.com> on 2022/03/03 05:31:45 UTC, 1 replies.
- How to sort Iterable in ProcessWindowFunction? - posted by HG <ha...@gmail.com> on 2022/03/03 14:12:24 UTC, 4 replies.
- Re: AWS Kinesis Flink vs K8s - posted by Puneet Duggal <pu...@gmail.com> on 2022/03/03 14:25:40 UTC, 0 replies.
- error: cannot find symbol .setDeliverGuarantee in KafkaRecordSerializationSchemaBuilder - posted by HG <ha...@gmail.com> on 2022/03/03 14:41:40 UTC, 0 replies.
- Re: Example with JSONKeyValueDeserializationSchema? - posted by Kamil ty <ka...@gmail.com> on 2022/03/03 16:07:11 UTC, 2 replies.
- StreamingFileSink bulk formats - small files - posted by Kamil ty <ka...@gmail.com> on 2022/03/03 16:16:37 UTC, 0 replies.
- Task Manager shutdown causing jobs to fail - posted by Puneet Duggal <pu...@gmail.com> on 2022/03/03 18:50:00 UTC, 3 replies.
- Max parallelism and reactive mode - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2022/03/03 22:24:07 UTC, 1 replies.
- Version Upgrade of FlinkSQL (1.10 to 1.12) - posted by zihao chen <is...@gmail.com> on 2022/03/04 03:23:14 UTC, 2 replies.
- Re:Re: source code build failure - posted by Edwin <xu...@163.com> on 2022/03/04 05:38:26 UTC, 0 replies.
- Pyflink1.13 or JavaFlink1.13 + Jpython + Python2.7, which way has better performance? - posted by vtygoss <vt...@126.com> on 2022/03/04 06:36:28 UTC, 1 replies.
- [statefun] hadoop dependencies and StatefulFunctionsConfigValidator - posted by Filip Karnicki <fi...@gmail.com> on 2022/03/04 08:53:58 UTC, 3 replies.
- Incremental checkpointing & RocksDB Serialization - posted by Vidya Sagar Mula <mu...@gmail.com> on 2022/03/04 09:00:30 UTC, 5 replies.
- Late events during job catch up & Unbalanced sources - posted by Shqiprim Bunjaku <sh...@gmail.com> on 2022/03/04 12:25:46 UTC, 5 replies.
- Shaded zookeeper - curator mismatch? - posted by Filip Karnicki <fi...@gmail.com> on 2022/03/04 15:12:05 UTC, 3 replies.
- Source API question around idle (expensive) SplitFetchers being shutdown. - posted by Jonathan Weaver <my...@gmail.com> on 2022/03/04 17:21:15 UTC, 1 replies.
- Question about Flink counters - posted by Shane Bishop <sh...@outlook.com> on 2022/03/04 21:24:21 UTC, 7 replies.
- Controlling group partitioning with DataStream - posted by Ken Krugler <kk...@transpac.com> on 2022/03/04 22:54:52 UTC, 4 replies.
- PyFlink : submission via rest - posted by aryan m <ma...@gmail.com> on 2022/03/05 18:07:45 UTC, 4 replies.
- Submit job to a session cluster on Kubernetes via REST API - posted by Almog Rozencwajg <Al...@niceactimize.com> on 2022/03/06 07:28:44 UTC, 1 replies.
- Require help regarding possible issue/bug I'm facing while using Flink - posted by "Chia De Xun ." <de...@bytedance.com> on 2022/03/07 01:16:35 UTC, 1 replies.
- [DISCUSS] Flink's supported APIs and Hive query syntax - posted by Martijn Visser <ma...@apache.org> on 2022/03/07 11:23:00 UTC, 10 replies.
- Could not stop job with a savepoint - posted by Vinicius Peracini <vi...@zenvia.com> on 2022/03/07 13:56:22 UTC, 7 replies.
- Flatmap operator in an Asynchronous call - posted by Diwakar Jha <di...@gmail.com> on 2022/03/07 21:16:57 UTC, 4 replies.
- Re: [External] Require help regarding possible issue/bug I'm facing while using Flink - posted by Qingsheng Ren <re...@gmail.com> on 2022/03/08 02:24:13 UTC, 0 replies.
- MapState.entries() - posted by Alexey Trenikhun <ye...@msn.com> on 2022/03/08 05:10:44 UTC, 2 replies.
- Flink Checkpoint Timeout - posted by Mahantesh Patil <ma...@gmail.com> on 2022/03/08 06:46:59 UTC, 2 replies.
- Flink Statefun Kafka Ingress Record Key Deserializer - posted by Xin Li <xi...@shopback.com> on 2022/03/08 07:33:03 UTC, 1 replies.
- Using another FileSystem configuration while creating a job - posted by Gil De Grove <gi...@digazu.com> on 2022/03/08 07:47:50 UTC, 4 replies.
- Savepoint API challenged with large savepoints - posted by Schwalbe Matthias <Ma...@viseca.ch> on 2022/03/08 12:43:46 UTC, 2 replies.
- Move savepoint to another s3 bucket - posted by Lukáš Drbal <lu...@gmail.com> on 2022/03/08 15:37:21 UTC, 5 replies.
- replay kinesis events - posted by Guoqin Zheng <la...@gmail.com> on 2022/03/09 00:15:09 UTC, 2 replies.
- Problem about adding custom kryo serializer - posted by gu...@foxmail.com on 2022/03/09 07:10:00 UTC, 1 replies.
- Evolving Schemas with ParquetColumnarRowInputFormat - posted by Kevin Lam <ke...@shopify.com> on 2022/03/09 16:04:18 UTC, 0 replies.
- Flink sql calculate principle question - posted by JianWen Huang <ji...@gmail.com> on 2022/03/09 17:31:37 UTC, 1 replies.
- 回复：Fwd: [DISCUSS] Flink's supported APIs and Hive query syntax - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com> on 2022/03/10 06:18:52 UTC, 0 replies.
- Interval join operator is not forwarding watermarks correctly - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2022/03/10 18:26:37 UTC, 5 replies.
- Flink argo native k8s application mode - posted by Eric Berryman <er...@gmail.com> on 2022/03/10 19:45:52 UTC, 0 replies.
- Re: Flink Statefun and Feature computation - posted by Federico D'Ambrosio <fe...@gmail.com> on 2022/03/10 23:07:21 UTC, 1 replies.
- Checkpointing in StateFun - posted by Christopher Gustafson <ch...@kth.se> on 2022/03/11 08:24:30 UTC, 3 replies.
- Re: Add libatomic1 to flink image - posted by Konstantin Knauf <kn...@apache.org> on 2022/03/11 12:43:23 UTC, 0 replies.
- Slowness using GenericWriteAheadSink - posted by "Sandys-Lumsdaine, James" <Ja...@systematica.com> on 2022/03/11 13:59:40 UTC, 3 replies.
- Re: Queryable State Deprecation - posted by Ron Crocker <rc...@newrelic.com> on 2022/03/12 06:19:02 UTC, 0 replies.
- Debugging SQL queries - posted by dz902 <dz...@gmail.com> on 2022/03/14 02:42:00 UTC, 6 replies.
- INSERT INTO not immediate - posted by dz902 <dz...@gmail.com> on 2022/03/14 11:27:57 UTC, 2 replies.
- FileSink to GCS - posted by Bobby Richard <bo...@broadcom.com> on 2022/03/14 14:21:11 UTC, 4 replies.
- Reading FileSource Files in a particular order - posted by Kevin Lam <ke...@shopify.com> on 2022/03/14 14:40:21 UTC, 1 replies.
- Use existing Kafka zookeeper for Flink - posted by HG <ha...@gmail.com> on 2022/03/14 15:12:59 UTC, 1 replies.
- [Flink Batch SQL] Why DISTINCT aggregates not support in Group Window Aggregation? - posted by zhouhaifengmath <zh...@gmail.com> on 2022/03/15 04:14:21 UTC, 0 replies.
- Adjusted frame length exceeds 2147483647 - posted by Ori Popowski <or...@gmail.com> on 2022/03/15 05:52:25 UTC, 4 replies.
- Flink sql client support k8s application mode？ - posted by JianWen Huang <ji...@gmail.com> on 2022/03/15 08:41:12 UTC, 0 replies.
- Setting S3 as State Backend in SQL Client - posted by dz902 <dz...@gmail.com> on 2022/03/15 11:14:34 UTC, 11 replies.
- RocksDB metrics for effective memory consumption - posted by Donatien Schmitz <do...@uclouvain.be> on 2022/03/15 11:45:45 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.1.4.4 released - posted by Konstantin Knauf <kn...@apache.org> on 2022/03/15 13:21:18 UTC, 5 replies.
- 回复：Re: Fwd: [DISCUSS] Flink's supported APIs and Hive query syntax - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com> on 2022/03/15 15:07:04 UTC, 0 replies.
- Rescaling REST API not working - posted by Aarsh Shah <aa...@sharechat.co> on 2022/03/16 06:15:49 UTC, 1 replies.
- how to convert Table to DataStream / DataSet by TableEnvironment on Batch mode? - posted by vtygoss <vt...@126.com> on 2022/03/16 06:26:47 UTC, 0 replies.
- [SEEK HELP Python Flink] How to run pyflink unit test in pycharm - posted by "javacaoyu@163.com" <ja...@163.com> on 2022/03/16 08:22:59 UTC, 2 replies.
- Watermarks event time vs processing time - posted by HG <ha...@gmail.com> on 2022/03/16 09:05:37 UTC, 6 replies.
- Adding a custom Kafka deserializer to Statefun Job - posted by Christopher Gustafson <ch...@kth.se> on 2022/03/16 13:59:19 UTC, 0 replies.
- Stateful function with GCP Pub/Sub ingress/egress - posted by David Dixon <da...@creditkarma.com> on 2022/03/16 20:18:13 UTC, 0 replies.
- Flink Kinesis checkpoint failures long running service - posted by Vijayendra Yadav <co...@gmail.com> on 2022/03/16 21:01:52 UTC, 4 replies.
- Potential Bug with Date Serialization for Table Stream - posted by Tom Thornton <th...@yelp.com> on 2022/03/16 22:59:19 UTC, 1 replies.
- Flink SQL 1.12 How to implement query Hbase table on secondary index - posted by WuKong <wu...@foxmail.com> on 2022/03/17 02:23:51 UTC, 0 replies.
- ClassCastException occurs when Flink DataStream sends a message to a remote stateful function - posted by Tymur Yarosh <ti...@gmail.com> on 2022/03/17 14:48:40 UTC, 0 replies.
- how to set kafka sink ssl properties - posted by HG <ha...@gmail.com> on 2022/03/17 14:55:07 UTC, 4 replies.
- Re: [External] Re: Potential Bug with Date Serialization for Table Stream - posted by Tom Thornton <th...@yelp.com> on 2022/03/17 16:59:08 UTC, 1 replies.
- Correct way to cleanly shut down StateFun Harness in test code - posted by Ken Krugler <kk...@transpac.com> on 2022/03/17 18:36:28 UTC, 0 replies.
- Flink UI - Operator Chaining - broken with "Records Sent" - posted by Dan Hill <qu...@gmail.com> on 2022/03/17 22:16:41 UTC, 2 replies.
- onTimer() of a KeyedProcessFunction stops getting triggered after a while - posted by Binil Benjamin <bb...@splunk.com> on 2022/03/17 23:54:39 UTC, 9 replies.
- [File partition Flink] - posted by lan tran <in...@gmail.com> on 2022/03/18 05:03:58 UTC, 1 replies.
- Weird Flink Kafka source watermark behavior - posted by Dan Hill <qu...@gmail.com> on 2022/03/18 05:13:10 UTC, 14 replies.
- Kafka source with multiple partitions loses data during savepoint recovery - posted by Sharon Xie <sh...@gmail.com> on 2022/03/18 05:28:50 UTC, 2 replies.
- Clarifying ProcessFunction.onTimer and watermark behavior - posted by Dan Hill <qu...@gmail.com> on 2022/03/18 05:38:11 UTC, 1 replies.
- scala shell not part of 1.14.4 download - posted by Georg Heiler <ge...@gmail.com> on 2022/03/18 11:42:27 UTC, 7 replies.
- Re: Issue with Flink UI for Flink 1.14.0 - posted by Peter Westermann <no...@genesys.com> on 2022/03/18 12:37:41 UTC, 1 replies.
- Re: Flink SQL 1.12 How to implement query Hbase table on secondary index - posted by Jing Ge <ji...@ververica.com> on 2022/03/18 17:37:19 UTC, 1 replies.
- exception when parallelizing application - posted by Prashant Deva <pr...@astradot.com> on 2022/03/20 04:24:44 UTC, 4 replies.
- Is it possible to make SideOutput back to input stream? - posted by Chen-Che Huang <ac...@gmail.com> on 2022/03/21 06:26:31 UTC, 2 replies.
- Query regarding ClassCastException - posted by Mahima Agarwal <ma...@gmail.com> on 2022/03/21 09:26:40 UTC, 2 replies.
- Protobuf ClassNotFound for Embedded Module - posted by Christopher Gustafson <ch...@kth.se> on 2022/03/21 11:43:11 UTC, 0 replies.
- Kubernetes HA on an application cluster - posted by marco andreas <ma...@gmail.com> on 2022/03/21 19:41:18 UTC, 1 replies.
- Temporarily pause splits fetching when unavailable - posted by Xinbin Huang <bi...@apache.org> on 2022/03/21 22:35:14 UTC, 0 replies.
- Question about Flink(Standalone) - posted by 李杰进13922030138 <13...@139.com> on 2022/03/22 01:52:13 UTC, 0 replies.
- Asking about the partition files - posted by lan tran <in...@gmail.com> on 2022/03/22 10:27:51 UTC, 0 replies.
- Last task takes too long to complete DataStream API - posted by "Vasileva, Valeriia" <c-...@disneystreaming.com> on 2022/03/22 15:24:38 UTC, 2 replies.
- [ANNOUNCE] Call for Presentations is open for Flink Forward San Francisco 2022 in-person! - posted by Timo Walther <tw...@apache.org> on 2022/03/22 15:52:12 UTC, 0 replies.
- Python UDF Gauge Metrics not working & error log on Vectorized UDF - posted by Jesry Pandawa <je...@gmail.com> on 2022/03/22 17:13:26 UTC, 2 replies.
- Connection warnings when running Flink statefun - posted by John Kattukudiyil <jo...@adeptmind.ai> on 2022/03/22 17:17:33 UTC, 0 replies.
- Flink OOM issue - posted by Phoebe Kwok <ph...@primer.ai> on 2022/03/22 19:37:31 UTC, 1 replies.
- Using Amazon EC2 Spot instances with Flink - posted by "Vasileva, Valeriia" <c-...@disneystreaming.com> on 2022/03/22 22:33:25 UTC, 4 replies.
- Clust rconfiguration for network-intensive Flink job - posted by "Vasileva, Valeriia" <c-...@disneystreaming.com> on 2022/03/22 22:48:53 UTC, 0 replies.
- Flink plugin can't get access to some of the classes in /opt/flink/lib folder - posted by Fan Xie <fx...@linkedin.com> on 2022/03/22 23:42:52 UTC, 1 replies.
- FileSystem format - posted by lan tran <in...@gmail.com> on 2022/03/23 02:39:26 UTC, 1 replies.
- Flink kafka consumer disconnection, application processing stays behind - posted by Isidoros Ioannou <ak...@gmail.com> on 2022/03/23 11:19:51 UTC, 3 replies.
- Apache Flink 1.15 Meetup - posted by Johannes Moser <jo...@ververica.com> on 2022/03/23 15:04:10 UTC, 0 replies.
- flink SQL client with kafka confluent avro binaries setup - posted by Georg Heiler <ge...@gmail.com> on 2022/03/23 15:58:41 UTC, 3 replies.
- SQL Client Kafka (UPSERT?) Sink for confluent-avro - posted by Georg Heiler <ge...@gmail.com> on 2022/03/24 10:57:39 UTC, 2 replies.
- Flink SQL AVG with mandatory type casting - posted by Georg Heiler <ge...@gmail.com> on 2022/03/24 15:08:23 UTC, 1 replies.
- DBT-flink profile? - posted by Georg Heiler <ge...@gmail.com> on 2022/03/24 17:27:26 UTC, 2 replies.
- Flink STOP with savepoint - posted by Diwakar Jha <di...@gmail.com> on 2022/03/25 04:04:30 UTC, 1 replies.
- Apache Flink + Apache arrow flight - posted by Deepak Sharma <de...@gmail.com> on 2022/03/25 04:45:11 UTC, 0 replies.
- Traffic mismatch between operators - posted by Kai Fu <zz...@gmail.com> on 2022/03/25 08:40:24 UTC, 3 replies.
- Flink Web ui not stable in kubernetes? - posted by Sebastian Struss <st...@justtrack.io> on 2022/03/25 08:42:27 UTC, 3 replies.
- Where can I find flink-kubernetes-operator project? - posted by Makas Tzavellas <ma...@gmail.com> on 2022/03/25 08:44:29 UTC, 2 replies.
- flink cluster startup time - posted by Frank Dekervel <fr...@kapernikov.com> on 2022/03/25 08:45:54 UTC, 4 replies.
- "Native Kubernetes" sample in Flink documentation fails. JobManager Web Interface is wrongly generated. [Flink 1.14.4] - posted by Burcu Gul POLAT EGRI <be...@sdt.com.tr> on 2022/03/25 13:37:38 UTC, 4 replies.
- flink-kubernetes-operator: Flink deployment stuck in scheduled state when increasing resource CPU above 1 - posted by Makas Tzavellas <ma...@gmail.com> on 2022/03/25 18:48:53 UTC, 3 replies.
- Exactly-once sink sync checkpoint stacking time effect - posted by Filip Karnicki <fi...@gmail.com> on 2022/03/26 13:10:47 UTC, 2 replies.
- Deploy a Flink session cluster natively on K8s with multi AZ - posted by Almog Rozencwajg <Al...@niceactimize.com> on 2022/03/27 06:49:42 UTC, 2 replies.
- JobManager failed to renew it's leadership (K8S HA) - posted by marco andreas <ma...@gmail.com> on 2022/03/27 10:34:48 UTC, 1 replies.
- Where is the "Partitioned All Cache" doc? - posted by dz902 <dz...@gmail.com> on 2022/03/28 04:26:58 UTC, 2 replies.
- Date time convert - posted by lan tran <in...@gmail.com> on 2022/03/28 04:37:36 UTC, 0 replies.
- Datetime format - posted by lan tran <in...@gmail.com> on 2022/03/28 05:10:45 UTC, 1 replies.
- flink docker image (1.14.4) unable to access other pods from flink program (job and task manager access is fine) - posted by Jin Yi <ji...@promoted.ai> on 2022/03/29 03:23:08 UTC, 7 replies.
- Need Help - posted by Himanshu Sareen <hi...@outlook.com> on 2022/03/29 05:37:11 UTC, 0 replies.
- Re: Wrong format when passing arguments with space - posted by David Morávek <dm...@apache.org> on 2022/03/29 07:15:16 UTC, 1 replies.
- Parallel processing in a 2 node cluster apparently not working - posted by HG <ha...@gmail.com> on 2022/03/29 11:30:36 UTC, 1 replies.
- Pyflink elastic search connectors - posted by Sandeep Sharat <sa...@gmail.com> on 2022/03/29 12:50:43 UTC, 5 replies.
- How to debug Metaspace exception? - posted by John Smith <ja...@gmail.com> on 2022/03/29 22:09:58 UTC, 6 replies.
- Naming sql_statment job - posted by lan tran <in...@gmail.com> on 2022/03/30 10:52:23 UTC, 1 replies.
- Call for Presentations now open, ApacheCon North America 2022 - posted by Rich Bowen <rb...@apache.org> on 2022/03/30 12:16:06 UTC, 0 replies.
- how to achieve sideOutputLateData() in FlinkSQL? - posted by liuxiangcao <xi...@gmail.com> on 2022/03/30 21:38:43 UTC, 3 replies.
- Flink SQL and data shuffling (keyBy) - posted by Yaroslav Tkachenko <ya...@goldsky.io> on 2022/03/31 04:17:59 UTC, 0 replies.
- "Native Kubernetes" Application Mode sample in Flink documentation fails. [Flink 1.14.4] - posted by Burcu Gul POLAT EGRI <be...@sdt.com.tr> on 2022/03/31 06:30:07 UTC, 1 replies.
- Could you please give me a hand about json object in flink sql - posted by wang <24...@163.com> on 2022/03/31 13:42:50 UTC, 0 replies.
- [DataStream API] Watermarks not closing TumblingEventTimeWindow with Reduce function - posted by Ryan van Huuksloot <ry...@shopify.com> on 2022/03/31 14:57:28 UTC, 0 replies.
- Question about community collaboration options - posted by Hao t Chang <ht...@us.ibm.com> on 2022/03/31 21:44:26 UTC, 0 replies.