阿里云文档 2025-06-05

如何使用Flink,通过CTAS语句同步MySQL数据至StarRocks

本文为您介绍如何使用EMR DataFlow集群中的Flink服务,通过CTAS语句将MySQL数据同步至EMR Serverless StarRocks中。

阿里云文档 2025-05-14

Flink网络连通常见问题

实时计算Flink版默认不具备访问公网的能力,本文为您介绍如何进行公网访问、跨VPC访问、域名解析以及网络连通性测试等相关的常见问题。

阿里云文档 2025-04-23

注册Hive Kerberos集群

在实时计算控制台上注册Hive Kerberos集群信息后,可以访问支持Kerberos的Hive。本文为您介绍如何注册Hive Kerberos集群。

问答 2024-08-07 来自:开发者社区

在Flink CDC中,使用Flink HA模式可以做到flink集群重启后自动恢复运行的job吗?

在Flink CDC中,使用Flink HA模式可以做到flink集群重启后自动恢复正在运行的job吗?

问答 2024-08-06 来自:开发者社区

使用Flink HA模式可以做到flink集群重启后自动恢复正在运行的job吗?

使用Flink HA模式可以做到flink集群重启后自动恢复正在运行的job吗?

问答 2024-07-11 来自:开发者社区

Flink在HA模式,重启ZK集群,客户端任务提交异常(疑似脑裂)

基本信息 Flink 1.11.6版本,Standalone HA模式, 滚动重启了ZK集群在Flink集群的一个节点上使用flink run 命令提交多个任务 异常现象 部分任务提交失败,异常信息如下 [Flink-DispatcherRestEndpoint-thread-2] - [WARN ] - [org.apache.flink.runtime.rpc.akka.AkkaInvoc.....

问答 2024-04-22 来自:开发者社区

Flink背景:有这4tm2jm,zk做ha的standalone 集群,导致任务提交超时,怎么办?

Flink背景:有这4tm 2jm,zk做ha 的standalone 集群,执行seatunnel提交上来的batch作业。 问题:其中有两个tm在接到分发任务时报错,开了tm debug,看到leadship change,然后new leadship,但是address是null,导致任务提交超时?

阿里云文档 2024-01-25

问题描述如何购买Flink半托管集群问题原因查看Flink全托管控制台,存在Flink半托管/ACK的选项,但是没有找到创建Flink半托管的入口。解决方案目前Flink控制台已不再支持创建Flink半托管集群。若需创建自运维半托管的Flink集群,可以进入EMR控制台创建Dataflow集群。EM...

阿里云文档 2023-09-03

集群监控中的Flink指标有哪些_EMR on ECS_开源大数据平台 E-MapReduce(EMR)

本文为您介绍Flink指标的详细信息。

问答 2018-12-10 来自:开发者社区

Flink HA JobManager集群无法选择leader

我正在尝试在kubernetes上部署Apache Flink 1.6。按照作业管理器高可用性 页面上的教程进行操作。我已经从它的日志中找到了一个有效的Zookeeper 3.10集群我可以看到它没有配置为Kerberos或SASL。所有ACL规则都允许每个客户端写入和读取znode。当我启动集群时,一切都按预期工作,每个JobManager和TaskManager窗口都成功进入运行状态,我可以....

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

产品推荐

阿里云实时计算Flink

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

+关注