You are viewing a plain text version of this content. The canonical link for it is here.
- Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout - posted by Ori Popowski <or...@gmail.com> on 2022/10/02 08:34:23 UTC, 1 replies.
- Flink Kafka Consumer performance issue - posted by Xin Ma <ke...@gmail.com> on 2022/10/02 12:23:25 UTC, 0 replies.
- Does kubernetes operator support manually triggering savepoint with canceling the job? - posted by "Liting Liu (litiliu)" <li...@cisco.com> on 2022/10/04 04:53:45 UTC, 3 replies.
- Re: [DISCUSS] FLIP-265 Deprecate and remove Scala API support - posted by Martijn Visser <ma...@apache.org> on 2022/10/04 11:58:17 UTC, 20 replies.
- Question about Flink Broadcast State event ordering - posted by Qing Lim <q....@mwam.com> on 2022/10/04 13:54:23 UTC, 5 replies.
- Can temporal table functions only be registered using the table API? - posted by Salva Alcántara <sa...@gmail.com> on 2022/10/04 17:18:20 UTC, 8 replies.
- Flink KafkaSource still referencing deleted topic - posted by Robert Cullen <ci...@gmail.com> on 2022/10/04 17:39:24 UTC, 5 replies.
- Support avro-confluent format for FileSystem SQL connector - posted by liuxiangcao <xi...@gmail.com> on 2022/10/04 20:15:38 UTC, 0 replies.
- ClassNotFoundException when loading protobuf message class in Flink SQL - posted by James McGuire via user <us...@flink.apache.org> on 2022/10/04 23:20:59 UTC, 2 replies.
- 回复: Re:Question about Flink Broadcast State event ordering - posted by 仙路尽头谁为峰 <xl...@163.com> on 2022/10/05 08:12:56 UTC, 0 replies.
- Flink FaultTolerant at operator level - posted by Great Info <gu...@gmail.com> on 2022/10/05 08:24:15 UTC, 1 replies.
- Old s3 files referenced in sink's state after migration from 1.14 to 1.15 - posted by "Vararu, Vadim" <va...@adswizz.com> on 2022/10/05 09:32:43 UTC, 0 replies.
- How to rebalance a Flink streaming table? - posted by Pavel Penkov <eb...@gmail.com> on 2022/10/05 09:54:07 UTC, 1 replies.
- Support Checkpointing in MongoDB Changestream Source(s) - posted by Armin Schnabel <ar...@cyface.de> on 2022/10/05 11:25:32 UTC, 0 replies.
- KafkaSource, consumer assignment, and Kafka ‘stretch’ clusters for multi-DC streaming apps - posted by Andrew Otto <ot...@wikimedia.org> on 2022/10/05 14:54:36 UTC, 3 replies.
- Sometimes checkpoints to s3 fail - posted by Evgeniy Lyutikov <eb...@avito.ru> on 2022/10/06 09:25:00 UTC, 1 replies.
- Switching kafka brokers - posted by Lars Skjærven <la...@gmail.com> on 2022/10/06 16:39:31 UTC, 1 replies.
- Debezium format with MongoDB - posted by Bobby Richard <bo...@broadcom.com> on 2022/10/07 14:20:32 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.2.0 released - posted by Gyula Fóra <gy...@apache.org> on 2022/10/07 15:05:10 UTC, 0 replies.
- Window state size with global window and custom trigger - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2022/10/07 20:47:53 UTC, 2 replies.
- Unsubscribe - posted by Abdul Rahman <ab...@gmail.com> on 2022/10/07 20:50:41 UTC, 0 replies.
- Validation error trying to use standalone mode with operator 1.2.0 - posted by Javier Vegas <jv...@strava.com> on 2022/10/07 21:59:31 UTC, 2 replies.
- Passing SSLContext to the ElasticSearchSink - posted by Nick Levandoski <ni...@gmail.com> on 2022/10/09 01:15:12 UTC, 1 replies.
- [DISCUSS] Reverting sink metric name changes made in 1.15 - posted by Qingsheng Ren <re...@apache.org> on 2022/10/09 02:35:12 UTC, 20 replies.
- New flink release date - posted by marco andreas <ma...@gmail.com> on 2022/10/09 08:40:32 UTC, 1 replies.
- videos Flink Forward San Francisco 2022 - posted by "guenterh.lists" <gu...@bluewin.ch> on 2022/10/09 14:09:22 UTC, 7 replies.
- Deserialize avro message without reader schema. - posted by Sucheth S <su...@gmail.com> on 2022/10/10 16:59:58 UTC, 2 replies.
- Preserve rowtime through join - posted by Matthias Broecheler <ma...@dataeng.ai> on 2022/10/10 21:12:53 UTC, 0 replies.
- Data type mapping - posted by Pouria Pirzadeh <po...@gmail.com> on 2022/10/10 22:51:47 UTC, 0 replies.
- Question about SQL gateway - posted by Ww J <ju...@gmail.com> on 2022/10/11 05:35:50 UTC, 2 replies.
- Flink falls back on to kryo serializer for GenericTypes - posted by Sucheth S <su...@gmail.com> on 2022/10/11 07:29:03 UTC, 2 replies.
- Partial broadcast/keyed connected streams - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2022/10/11 20:10:28 UTC, 1 replies.
- Job Manager getting restarted while restarting task manager - posted by Puneet Duggal <pu...@gmail.com> on 2022/10/11 22:24:56 UTC, 6 replies.
- 回复: Partial broadcast/keyed connected streams - posted by 仙路尽头谁为峰 <xl...@163.com> on 2022/10/12 01:42:40 UTC, 0 replies.
- NativeIoException PartitionRequestQueue - Encountered error while consuming partitions - posted by Clayton Wohl <cl...@gmail.com> on 2022/10/12 02:51:18 UTC, 0 replies.
- fail to mount hadoop-config-volume when using flink-k8s-operator - posted by "Liting Liu (litiliu)" <li...@cisco.com> on 2022/10/12 08:10:32 UTC, 1 replies.
- 回复: [DISCUSS] Reverting sink metric name changes made in 1.15 - posted by Ruan Hang <ru...@hotmail.com> on 2022/10/12 12:16:02 UTC, 0 replies.
- Job uptime metric in Flink Operator managed cluster - posted by Meghajit Mazumdar <me...@gojek.com> on 2022/10/12 13:54:25 UTC, 4 replies.
- Utilizing Kafka headers in Flink Kafka connector - posted by Great Info <gu...@gmail.com> on 2022/10/12 18:03:47 UTC, 2 replies.
- [ANNOUNCE] Apache Flink Table Store 0.2.1 released - posted by Jingsong Lee <lz...@apache.org> on 2022/10/13 02:45:50 UTC, 1 replies.
- allowNonRestoredState doesn't seem to be working - posted by Yaroslav Tkachenko <ya...@goldsky.com> on 2022/10/13 05:34:07 UTC, 4 replies.
- Kubernetes operator assign Job ID - posted by Evgeniy Lyutikov <eb...@avito.ru> on 2022/10/13 06:53:54 UTC, 1 replies.
- Is Flink 1.15.3 planned in foreseeable future? - posted by Maciek Próchniak <mp...@touk.pl> on 2022/10/13 07:50:13 UTC, 1 replies.
- Limiting backpressure during checkpoints - posted by Robin Cassan via user <us...@flink.apache.org> on 2022/10/13 15:39:09 UTC, 3 replies.
- Build failing when Flink version upgrade from 1.11.6 to 1.15.0 - posted by "Pappula, Prasanna via user" <us...@flink.apache.org> on 2022/10/13 16:05:04 UTC, 1 replies.
- Activate Flink HA without checkpoints on k8S - posted by marco andreas <ma...@gmail.com> on 2022/10/13 17:06:38 UTC, 2 replies.
- HA not working in standalone mode for operator 1.2 - posted by Javier Vegas <jv...@strava.com> on 2022/10/13 19:41:13 UTC, 2 replies.
- Broadcast state restoration for BroadcastProcessFunction - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2022/10/14 10:22:01 UTC, 0 replies.
- Re: jobmaster's fatal error will kill the session cluster - posted by Matthias Pohl via user <us...@flink.apache.org> on 2022/10/14 11:53:13 UTC, 2 replies.
- SQL Changes between 1.14 and 1.15? - posted by "PACE, JAMES" <jp...@att.com> on 2022/10/14 13:19:37 UTC, 1 replies.
- question about Async IO - posted by Galen Warren <ga...@cvillewarrens.com> on 2022/10/14 17:09:50 UTC, 1 replies.
- Flink 1.15 Interval Join error after Deduplicate - posted by li...@whu.edu.cn on 2022/10/15 01:50:44 UTC, 3 replies.
- Presto S3 filesystem access issue - checkpointing - EKS - posted by Vignesh Kumar Kathiresan via user <us...@flink.apache.org> on 2022/10/17 19:47:39 UTC, 1 replies.
- Flink CEP Incremental Checkpoint Issue - posted by Puneet Duggal <pu...@gmail.com> on 2022/10/17 20:05:36 UTC, 3 replies.
- Watermark generating mechanism in Flink SQL - posted by wang <24...@163.com> on 2022/10/18 03:31:56 UTC, 0 replies.
- Re: Watermark generating mechanism in Flink SQL - posted by Matthias Pohl via user <us...@flink.apache.org> on 2022/10/18 05:49:50 UTC, 0 replies.
- SQL Lookup join on nested field - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2022/10/18 07:28:26 UTC, 2 replies.
- Re: [E] Re: Presto S3 filesystem access issue - checkpointing - EKS - posted by Vignesh Kumar Kathiresan via user <us...@flink.apache.org> on 2022/10/18 23:28:29 UTC, 0 replies.
- 回复: Does kubernetes operator support manually triggering savepoint with canceling the job? - posted by "Liting Liu (litiliu)" <li...@cisco.com> on 2022/10/19 07:33:40 UTC, 0 replies.
- Cannot run pyflink example using Flink CLI - posted by Levan Huyen <lv...@gmail.com> on 2022/10/19 09:07:11 UTC, 6 replies.
- Table to DataStream conversion - Error while generating structured type converter. - posted by André Midea Jasiskis <mi...@gmail.com> on 2022/10/19 09:08:35 UTC, 1 replies.
- multiple s3 sinks - posted by "Katz, David L via user" <us...@flink.apache.org> on 2022/10/19 15:46:17 UTC, 0 replies.
- RE: [EXTERNAL]multiple s3 sinks - posted by "Katz, David L via user" <us...@flink.apache.org> on 2022/10/19 17:10:01 UTC, 0 replies.
- Flink Native K8S RBAC - posted by Calvin D Souza via user <us...@flink.apache.org> on 2022/10/19 19:44:51 UTC, 2 replies.
- [DISCUSS] Planning Flink 1.17 - posted by Qingsheng Ren <re...@apache.org> on 2022/10/20 07:44:36 UTC, 3 replies.
- Broadcast state and OutOfMemoryError: Direct buffer memory - posted by Dan Hill <qu...@gmail.com> on 2022/10/21 07:39:19 UTC, 1 replies.
- Modify savepoints in Flink - posted by Sriram Ganesh <sr...@gmail.com> on 2022/10/21 08:03:44 UTC, 6 replies.
- Difference between DataStream.broadcast() vs DataStream.broadcast(MapStateDescriptor) - posted by Qing Lim <q....@mwam.com> on 2022/10/21 16:19:39 UTC, 0 replies.
- Re: How to use connectors in PyFlink 1.15.0 when not defined in Python API? - posted by Levan Huyen <lv...@gmail.com> on 2022/10/24 02:26:03 UTC, 0 replies.
- [DISCUSS] Issue tracking workflow - posted by Xintong Song <to...@gmail.com> on 2022/10/24 05:28:32 UTC, 2 replies.
- RE: Skip malformed messages with the KafkaSink - posted by Salva Alcántara <sa...@gmail.com> on 2022/10/24 09:21:53 UTC, 0 replies.
- Flink SQL on Docker - posted by Tristan Culp via user <us...@flink.apache.org> on 2022/10/24 21:29:58 UTC, 1 replies.
- status no clear when deploying batch job with flink-k8s-operator - posted by "Liting Liu (litiliu)" <li...@cisco.com> on 2022/10/25 07:23:05 UTC, 1 replies.
- flink-table-api-scala-bridge sources - posted by Clemens Valiente <cl...@grab.com> on 2022/10/25 07:40:43 UTC, 1 replies.
- State Processor API - VoidNamespaceSerializer must be compatible with the old namespace serializer LongSerializer - posted by Filip Karnicki <fi...@gmail.com> on 2022/10/25 08:07:35 UTC, 5 replies.
- "Exec Failure java.io.EOFException null" message before taskmanagers crash - posted by Javier Vegas <jv...@strava.com> on 2022/10/26 01:27:26 UTC, 0 replies.
- configMap value error when using flink-operator? - posted by "Liting Liu (litiliu)" <li...@cisco.com> on 2022/10/26 05:17:44 UTC, 4 replies.
- Concatenating a bounded and unbounded stream - posted by Noel OConnor <no...@gmail.com> on 2022/10/26 15:05:27 UTC, 3 replies.
- Re: [DISCUSS ] add --jars to support users dependencies jars. - posted by Martijn Visser <ma...@apache.org> on 2022/10/27 06:48:52 UTC, 1 replies.
- Broadcast state and job restarts - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2022/10/27 20:41:03 UTC, 1 replies.
- Flink Kubernetes rocksdb backend volume type - posted by Vignesh Kumar Kathiresan via user <us...@flink.apache.org> on 2022/10/27 21:20:31 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.16.0 released - posted by Xingbo Huang <hx...@apache.org> on 2022/10/28 06:45:28 UTC, 3 replies.
- Performing left join between two streams - posted by Surendra Lalwani via user <us...@flink.apache.org> on 2022/10/28 07:11:20 UTC, 1 replies.
- When should we use flink-json instead of Jackson directly? - posted by Vishal Surana <vi...@moengage.com> on 2022/10/28 14:45:51 UTC, 1 replies.
- OutOfMemoryError (java heap space) on small, local test - posted by Matt Fysh <ma...@gmail.com> on 2022/10/31 03:47:56 UTC, 1 replies.
- [ANNOUNCE] Starting with Flink 1.17 release sync - posted by Martijn Visser <ma...@apache.org> on 2022/10/31 13:42:45 UTC, 0 replies.
- [Security] - Critical OpenSSL Vulnerability - posted by Tamir Sagi <Ta...@niceactimize.com> on 2022/10/31 18:21:58 UTC, 1 replies.
- Passive lineage collection? - posted by Maxwell Pospischil <ma...@cloudkitchens.com> on 2022/10/31 23:34:04 UTC, 0 replies.