You are viewing a plain text version of this content. The canonical link for it is here.
- Re: OutOfMemoryError (java heap space) on small, local test - posted by Matt Fysh <ma...@gmail.com> on 2022/11/01 01:21:51 UTC, 0 replies.
- Re: [Security] - Critical OpenSSL Vulnerability - posted by Mason Chen <ma...@gmail.com> on 2022/11/01 05:09:10 UTC, 6 replies.
- 【SQL Gateway - HiveServer2】UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS. - posted by QiZhu Chan <qi...@163.com> on 2022/11/01 06:52:20 UTC, 1 replies.
- [SUMMARY] Flink 1.17 Release Sync 11/1/2022 - posted by Qingsheng Ren <re...@apache.org> on 2022/11/01 09:29:30 UTC, 0 replies.
- Re: Could not find any factory for identifier 'filesystem' - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2022/11/01 10:04:53 UTC, 1 replies.
- why select limit so slow on yarn cluster - posted by Si-li Liu <un...@gmail.com> on 2022/11/01 16:17:52 UTC, 1 replies.
- Re: Flink SQL on Docker - posted by Tristan Culp via user <us...@flink.apache.org> on 2022/11/01 23:45:21 UTC, 0 replies.
- RE: Build failing when Flink version upgrade from 1.11.6 to 1.15.0 - posted by "Colletta, Edward via user" <us...@flink.apache.org> on 2022/11/02 01:37:32 UTC, 0 replies.
- Regarding Flink Upgrades - posted by Prasanna kumar <pr...@gmail.com> on 2022/11/02 06:45:14 UTC, 2 replies.
- Re: Flink CEP Incremental Checkpoint Issue - posted by Puneet Duggal <pu...@gmail.com> on 2022/11/02 08:01:04 UTC, 0 replies.
- Re: question about Async IO - posted by Filip Karnicki <fi...@gmail.com> on 2022/11/02 09:13:56 UTC, 2 replies.
- Does reduce function on keyed window gives any guarantee on the order of elements? - posted by Qing Lim <q....@mwam.com> on 2022/11/02 17:32:35 UTC, 4 replies.
- Question about UDF randomly processed input row twice - posted by Xinyi Yan <ya...@apache.org> on 2022/11/02 22:59:20 UTC, 3 replies.
- 30$/hr Data Architect - posted by sri hari kali charan Tummala <ka...@gmail.com> on 2022/11/02 23:41:12 UTC, 0 replies.
- How to get checkpoint stats after job has terminated - posted by Guojun Li <gj...@gmail.com> on 2022/11/03 03:30:40 UTC, 2 replies.
- Re: 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/11/03 08:40:34 UTC, 0 replies.
- Vulnerabilities in Flink docker images - posted by Prasanna kumar <pr...@gmail.com> on 2022/11/04 04:07:55 UTC, 1 replies.
- Getting error stacktrace during job submission on Flink Operator - posted by Meghajit Mazumdar <me...@gojek.com> on 2022/11/04 09:10:24 UTC, 0 replies.
- UDFs classloading changes in 1.16 - posted by Alexander Fedulov <al...@deltastream.io> on 2022/11/04 10:15:04 UTC, 2 replies.
- Consumption stops on some Kafka partitions in job running on Flink 1.15.2 - posted by Samuel Chase <sa...@gmail.com> on 2022/11/07 06:27:04 UTC, 4 replies.
- Strange issue with exactly once checkpoints and the kafka sink - posted by Salva Alcántara <sa...@gmail.com> on 2022/11/07 07:06:48 UTC, 1 replies.
- Load Distribution in specific Slot of Taskmanager in flink(version 1.15.2) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/11/07 12:39:51 UTC, 1 replies.
- [blog article] Howto migrate a real-life batch pipeline from the DataSet API to the DataStream API - posted by Etienne Chauchot <ec...@apache.org> on 2022/11/07 14:29:54 UTC, 8 replies.
- Kinesis Connector does not work - posted by Matt Fysh <ma...@gmail.com> on 2022/11/08 01:14:03 UTC, 3 replies.
- support escaping `#` in flink job spec in Flink-operator - posted by liuxiangcao <xi...@gmail.com> on 2022/11/08 03:55:24 UTC, 7 replies.
- FeatHub - A feature store that uses Apache Flink for real-time feature ETL - posted by Dong Lin <li...@gmail.com> on 2022/11/08 05:43:00 UTC, 0 replies.
- Converting ResolvedSchema to JSON and Protobuf Schemas - posted by Theodor Wübker <th...@inside-m2m.de> on 2022/11/08 13:21:05 UTC, 11 replies.
- How to write custom serializer for dynamodb connector - posted by Matt Fysh <ma...@gmail.com> on 2022/11/08 14:01:56 UTC, 3 replies.
- Unexpected behaviour when configuring both `withWatermarkAlignment` & `withIdleness` - posted by Reem Razak via user <us...@flink.apache.org> on 2022/11/09 16:42:29 UTC, 0 replies.
- Flink fails to authenticate with adlsgen2 azure storage account using managed identities in an Azure Kubernetes Cluster - posted by "DEROCCO, CHRISTOPHER" <cd...@att.com> on 2022/11/09 20:39:26 UTC, 0 replies.
- RocksDB checkpoints clean up with TaskManager restart. - posted by Vidya Sagar Mula <mu...@gmail.com> on 2022/11/09 23:31:04 UTC, 0 replies.
- Any caveats about processing abstract classes ? - posted by Davide Bolcioni via user <us...@flink.apache.org> on 2022/11/10 01:01:48 UTC, 3 replies.
- kubernetes.taskmanager.cpu.limit-factor not working in Flink Operator - posted by Meghajit Mazumdar <me...@gojek.com> on 2022/11/10 11:20:57 UTC, 4 replies.
- [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/10 11:50:51 UTC, 3 replies.
- Task Manager restart and RocksDB incremental checkpoints issue. - posted by Vidya Sagar Mula <mu...@gmail.com> on 2022/11/10 17:38:43 UTC, 6 replies.
- Spark Scala Contract Opportunity @USA - posted by sri hari kali charan Tummala <ka...@gmail.com> on 2022/11/10 21:39:00 UTC, 0 replies.
- How to use lookup join sql hint - posted by Si-li Liu <un...@gmail.com> on 2022/11/12 08:27:54 UTC, 3 replies.
- Class loading in PbFormatUtils.getDescriptor - posted by Theodor Wübker <th...@inside-m2m.de> on 2022/11/14 08:38:03 UTC, 1 replies.
- Kafka transactioins & flink checkpoints - posted by Vishal Surana <vi...@moengage.com> on 2022/11/15 08:07:22 UTC, 3 replies.
- Missing image tag in apache/flink repository ? - posted by Alon Halimi via user <us...@flink.apache.org> on 2022/11/15 08:45:03 UTC, 1 replies.
- [SUMMARY] Flink 1.17 Release Sync 11/15/2022 - posted by Leonard Xu <xb...@gmail.com> on 2022/11/15 09:50:24 UTC, 0 replies.
- Any way to improve list state get performance - posted by tao xiao <xi...@gmail.com> on 2022/11/15 12:50:13 UTC, 2 replies.
- Kafka transactions drastically limit usability of Flink savepoints - posted by Yordan Pavlov <y....@gmail.com> on 2022/11/15 14:36:06 UTC, 3 replies.
- Reading Parquet file with array of structs cause error - posted by "Benenson, Michael via user" <us...@flink.apache.org> on 2022/11/15 19:51:43 UTC, 4 replies.
- Owner reference with the Kubernetes operator - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2022/11/16 14:32:05 UTC, 2 replies.
- Savepoint restore mode for the Kubernetes operator - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2022/11/16 14:39:28 UTC, 4 replies.
- Kubernetes operator and jobs with last-state upgrades - posted by Alexis Sarda-Espinosa <sa...@gmail.com> on 2022/11/16 17:24:41 UTC, 1 replies.
- Dependency resolution issue with apache-flink 1.16.0 python package. - posted by Yogi Devendra <yo...@apache.org> on 2022/11/16 22:20:58 UTC, 1 replies.
- Flink Operator in Golang? - posted by Mark Lee <li...@126.com> on 2022/11/17 08:16:37 UTC, 2 replies.
- Increasing the Parallelism for an operation breaks the state due to MaxParallelism - posted by Kostas Netsiporenko <ko...@adjoe.io> on 2022/11/17 18:28:38 UTC, 0 replies.
- Stand alone K8s HA mode with Static Tokens Used by Service Accounts - posted by Berkay Polat via user <us...@flink.apache.org> on 2022/11/17 20:36:35 UTC, 2 replies.
- 答复: Flink Operator in Golang? - posted by Mark Lee <li...@126.com> on 2022/11/18 04:09:54 UTC, 0 replies.
- Deploy Flink Operator in an k8s enviroment without helm? - posted by Mark Lee <li...@126.com> on 2022/11/18 04:57:26 UTC, 3 replies.
- 答复: Deploy Flink Operator in an k8s enviroment without helm? - posted by Mark Lee <li...@126.com> on 2022/11/18 05:55:48 UTC, 1 replies.
- Flink SQL JSON - posted by Timothy Bess <td...@gmail.com> on 2022/11/18 20:10:41 UTC, 1 replies.
- Unaligned Checkpoints disabled even though I enabled them - posted by Ori Popowski <or...@gmail.com> on 2022/11/20 14:00:29 UTC, 5 replies.
- More backpressure and Kafka lag after upgrading to 1.15 and using Buffer Debloat - posted by Ori Popowski <or...@gmail.com> on 2022/11/21 08:58:53 UTC, 5 replies.
- Facing Issue in running Python Flink Program in flink cluster (Version=1.15.2) - posted by "harshit.varshney@iktara.ai" <Ha...@iktara.ai> on 2022/11/21 12:50:56 UTC, 1 replies.
- WIndowing in batch mode - posted by "Suparn Lele (sulele)" <su...@cisco.com> on 2022/11/22 06:26:51 UTC, 1 replies.
- [Flink K8s operator] HA metadata not available to restore from last state - posted by Dongwon Kim <ea...@gmail.com> on 2022/11/22 08:42:35 UTC, 2 replies.
- [Knowledge Transfer] - Flink Native kubernetes + Istio - posted by Tamir Sagi <Ta...@niceactimize.com> on 2022/11/22 11:44:27 UTC, 2 replies.
- Flink Operator in an off-line k8s enviroment - posted by Mark Lee <li...@126.com> on 2022/11/22 13:00:56 UTC, 2 replies.
- Get job submission status for Flink Operator - posted by Meghajit Mazumdar <me...@gojek.com> on 2022/11/22 14:45:31 UTC, 3 replies.
- "Authentication failed" in "ConnectionState" when enabling internal SSL on Yarn with self signed certificate - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2022/11/22 16:18:22 UTC, 2 replies.
- Weird Flink SQL error - posted by Dan Hill <qu...@gmail.com> on 2022/11/23 05:55:20 UTC, 11 replies.
- Unable to write checkpoint metadata to s3 using pyflink (1.16.0) - posted by Mujahid Niaz <mu...@gmail.com> on 2022/11/23 12:52:42 UTC, 1 replies.
- Query about flink job manager dashboard - posted by naga sudhakar <na...@gmail.com> on 2022/11/23 16:59:48 UTC, 8 replies.
- Physical memory and Auto Memory settings in TM - posted by ramkrishna vasudevan <ra...@gmail.com> on 2022/11/23 17:50:39 UTC, 0 replies.
- Flink 1.16.0: java.lang.NoSuchMethodException: org.apache.flink.metrics.prometheus.PrometheusReporter.() - posted by Clayton Wohl <cl...@gmail.com> on 2022/11/23 22:39:09 UTC, 1 replies.
- Apache vs Spotify Flink Operator? - posted by Clayton Wohl <cl...@gmail.com> on 2022/11/23 22:44:49 UTC, 1 replies.
- Support for higher-than-millisecond resolution event-time timestamps - posted by Salva Alcántara <sa...@gmail.com> on 2022/11/25 04:32:07 UTC, 3 replies.
- Safe way to clear old checkpoint data - posted by Evgeniy Lyutikov <eb...@avito.ru> on 2022/11/25 08:32:34 UTC, 3 replies.
- How can I deploy a flink cluster with 4 TaskManagers? - posted by Mark Lee <li...@126.com> on 2022/11/25 11:30:31 UTC, 1 replies.
- Several job in kubernetes restarts because Scheduler is being stopped. - posted by Evgeniy Lyutikov <eb...@avito.ru> on 2022/11/25 12:19:06 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.15.3 released - posted by Fabian Paul <fp...@apache.org> on 2022/11/25 13:22:08 UTC, 0 replies.
- create Flink session cluster and multi-session job - posted by Mark Lee <li...@126.com> on 2022/11/26 07:29:22 UTC, 1 replies.
- Example Flink SQL fromDataStream watermark code not showing *rowtime* - posted by Dan Hill <qu...@gmail.com> on 2022/11/26 07:51:10 UTC, 1 replies.
- What is the recommended cpu.memory configuration of the Flink kubernetes operator in the production environment ? - posted by hjw <18...@163.com> on 2022/11/28 07:00:54 UTC, 1 replies.
- 来自hjw的邮件 - posted by hjw <hj...@163.com> on 2022/11/28 07:03:56 UTC, 1 replies.
- How to make flink operator as a cluster operator? - posted by Mark Lee <li...@126.com> on 2022/11/28 10:02:44 UTC, 0 replies.
- Supports parameters such as spark.yarn.dist.jars - posted by melin li <li...@gmail.com> on 2022/11/29 01:48:15 UTC, 0 replies.
- Support Stored procedures - posted by melin li <li...@gmail.com> on 2022/11/29 02:10:04 UTC, 0 replies.
- Optimize ApplicationDeployer API design - posted by melin li <li...@gmail.com> on 2022/11/29 02:14:09 UTC, 0 replies.
- How's JobManager bring up TaskManager in Application Mode or Session Mode? - posted by 李 <li...@126.com> on 2022/11/29 04:22:30 UTC, 1 replies.
- Table API: Custom Kafka formats for Confluent Protobuf and JSON - posted by Theodor Wübker <th...@inside-m2m.de> on 2022/11/29 10:26:25 UTC, 2 replies.
- [SUMMARY] Flink 1.17 Release Sync 11/29/2022 - posted by Qingsheng Ren <re...@apache.org> on 2022/11/29 12:12:08 UTC, 0 replies.
- Flink 1.15.3 Docker image - posted by "Roberts, Ben (Senior Developer) via user" <us...@flink.apache.org> on 2022/11/29 15:26:55 UTC, 2 replies.
- "An illegal reflective access operation has occurred" during KeyedStream process - posted by Curtis Jensen <cu...@gmail.com> on 2022/11/29 23:25:17 UTC, 1 replies.
- Flink Table Kinesis sink not failing when sink fails - posted by Dan Hill <qu...@gmail.com> on 2022/11/30 00:06:52 UTC, 4 replies.
- Re: [EXTERNAL] Re: Flink 1.15.3 Docker image - posted by "Roberts, Ben (Senior Developer) via user" <us...@flink.apache.org> on 2022/11/30 09:50:58 UTC, 0 replies.
- Flink Operator create Session Job unsuccessfully - posted by Mark Lee <li...@126.com> on 2022/11/30 15:01:50 UTC, 0 replies.
- flink-kubernetes-operator: image entrypoint misbehaves due to inability to write - posted by Lucas Caparelli <lu...@gympass.com> on 2022/11/30 21:35:20 UTC, 1 replies.
- java.lang.ClassCastException on flink application mode - posted by Leon Xu <lx...@attentivemobile.com> on 2022/11/30 22:27:07 UTC, 0 replies.