文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之如何实现ZooKeeper抖动导致任务失败时,能从最近的检查点重新启动任务

问题一:Flink scala 和 java混编,Java21的字符串模板不识别 有什么办法解决吗? Flink scala 和 java混编,Java21的字符串模板不识别 有什么办法解决吗? 参考答案: 在Flink中,Scala和Java代码混编时,可能会遇到Java 21的字符串模板不识别的问题。为了解决这个问题,您可以尝试以下几种方法: ...

实时计算 Flink版产品使用问题之如何实现ZooKeeper抖动导致任务失败时,能从最近的检查点重新启动任务
文章 2024-08-26 来自:开发者社区

Apache Flink 实践问题之ZooKeeper 网络瞬断时如何解决

问题一:ZooKeeper 网络瞬断时,Flink JobManager 会遇到什么问题,以及这是如何影响 Flink 作业的? ZooKeeper 网络瞬断时,Flink JobManager 会遇到什么问题,以及这是如何影响 Flink 作业的? ...

Apache Flink 实践问题之ZooKeeper 网络瞬断时如何解决
问答 2024-08-05 来自:开发者社区

Flink 在哪个版本修复了 curator2.0 组件在 ZooKeeper状态下的行为问题?

Flink 在哪个版本修复了 curator2.0 组件在 ZooKeeper Suspended 状态下的行为问题?

问答 2024-02-01 来自:开发者社区

Flink中yarn per job配置zookeeper高可用无效是什么原因啊?

Flink中yarn per job配置zookeeper高可用无效是什么原因啊?

文章 2023-06-12 来自:开发者社区

FLINK ON K8S 基于Zookeeper和基于K8S原生HA的区别

背景本文基于Flink 1.13.xFlink on K8S分析基于原生K8S(基于ConfigMap) HA的数据交互图如下:基于Zookeeper HA的数据交互图如下:可以看到这两者的最大的区别在于:基于原生K8S的Active JobManager 会在选举成功后,持续向configMap中修改control-plane.alpha.kubernetes.io/leader的值,cont....

FLINK ON K8S 基于Zookeeper和基于K8S原生HA的区别
问答 2023-06-11 来自:开发者社区

flink 中我现在有两个zookeeper 一个连接kafka用的zookeeper 需要配置?

flink 中我现在有两个zookeeper 一个连接kafka用的zookeeper 需要配置zookeeper.sasl.client=false,还有一个hbase 用的zookeeper 需要配置zookeeper.sasl.client=true 这样怎么配置才能一起用啊?

问答 2023-05-16 来自:开发者社区

flink支持偏移量存在zookeeper的kafka消费吗?

flink支持偏移量存在zookeeper的kafka消费吗?

文章 2023-02-22 来自:开发者社区

flink hadoop 从0~1分布式计算与大数据项目实战(4)zookeeper内部原理流程简介以及java curator client操作集群注册,读取

zookeeper内部原理流程用processon画的有点大,看不清的可以放大查看流程图详解1.zookeeper 集群(至少个节点)启动后,会自动选举出一个leader,其他节点为follower 跟随节点 2.client 连接给定的单地址或者集群,连接集群时,会挑选一个可用的节点进行连接,整个节点可能时leader,也可能时follower 3.如果是读请求,则直接从当前连接的节点获取指定....

flink hadoop 从0~1分布式计算与大数据项目实战(4)zookeeper内部原理流程简介以及java curator client操作集群注册,读取
问答 2023-01-04 来自:开发者社区

大家遇到过flink ,zookeeper认证相关问题么?

大家遇到过flink ,zookeeper认证相关问题么?

问答 2022-11-23 来自:开发者社区

请问一下flink on yarn ha高可用的时候,flink的zookeeper3.5.9支持z

org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink-yarn

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等