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

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错为什么?

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错,请问是什么原因?请参考图片:

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

在Flink CDC中 抽取数据 凌晨失败了 白天重启任务 它还从之前零点失败时候的点位开始消费?

在Flink CDC中 抽取数据 凌晨失败了 白天重启任务 它还从之前零点失败时候的点位开始消费?

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

使用flink on yarn模式提交任务,这个是少了什么配置吗?

使用flink on yarn模式提交任务,想让其flink web固定到一台服务器启动,通过如上配置,端口生效,但是地址仍是随机到集群节点,这个是少了什么配置吗?flink1.16.2版本,我测试了1.12.7版本,这样配置是没问题的

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

Flink任务的jar包打的是最小包,如何指定这个本地磁盘lib目录,能有效加载这些依赖包呢?

Flink任务的jar包打的是最小包,maven依赖的其他包在本地磁盘lib目录,flink启动脚本,在yarn上运行,如何指定这个本地磁盘lib目录,能有效加载这些依赖包呢?

问答 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-07-11 来自:开发者社区

Flink如果停止了再启动 任务会从停止时候的位点继续消费么 ?

如果通过cdc把数据同步到datahub上面 datahub再转发到flink(主要是为了数据重放) 接受datahub数据的flink任务 Flink如果停止了再启动 任务会从停止时候的位点继续消费么 ?

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

任务可以通过深度检查部署成功,但是启动会ddl超时默认的600s,Flink这个参数在哪里设置?

任务可以通过深度检查部署成功,但是启动会ddl超时默认的600s,Flink这个参数在哪里设置?

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

Flink CDC任务发送到远程flink集群运行,这样方式为啥不生效啊?

Flink CDC任务发送到远程flink集群运行,这样方式为啥不生效啊?在flinkUI界面一直监控不到这个任务,一直都是在本地启动的,有没有大佬搞过这个,请教一下

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

Flink CDC如何做到不重启flink任务,监听到table_3表呢?

Flink CDC同步任务 监听mysql 表 table_*mysql中已存在table_1 table_2表,这俩张表数据同步没问题mysql中新增表table_3,如何做到不重启flink任务,监听到table_3表呢?不重启flink cdc任务,监听新创建的表 binlog呢

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

Flink CDC中batch模式下这两个source都是加载同一张表没有办法优化成一个读取任务么?

Flink CDC中batch模式下 这两个source都是加载同一张表 没有办法优化成一个读取任务么 ?

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

产品推荐

阿里云实时计算Flink

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

+关注