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

Flink CDC里任务运行时间过长 cache缓存占用了大量资源 ,有没有具体数值可以参考?

Flink CDC里任务运行时间过长 cache缓存占用了大量资源 我想让cache资源自动释放或者减少使用内存 是它回答的这样嘛 设置状态后端最大值 如果设置了这个会不会导致任务有可能找不到状态报错 有没有具体的参数值可以参考下?

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

Flink CDC里用Linux脚本编写的CDC任务,同步整库,但是只有一个表在同步数据,怎么回事?

Flink CDC里用Linux脚本编写的CDC任务,同步整库,但是只有一个表在同步数据,这是咋回事?./flink run -Dexecution.checkpointing.interval=60s -Dparallelism.default=1 -c org.apache.doris.flink.tools.cdc.CdcTools /usr/resource/flink/flink-1.....

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

Flink CDC里我是想自动做断点续传,比如我某个任务的容器crash了,我需要重启任务怎么办?

Flink CDC里我是想自动做断点续传,比如我某个任务的容器crash了,我需要重启任务,这个时候没法预知去手动savepoint,该如何处理呢?

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

Flink CDC里每次重新启动任务它都会新建的话如何保证断点续传呢?

Flink CDC里我的flink任务每次启动都会在我给的checkpoint目录下面用随机字符串建立子目录,这样我每次重新启动任务它都会新建的话如何保证断点续传呢?我是通过FlinkDeployment部署到云上,启动的时候我尝试这样加过参数,但是貌似起不了作用,可能因为我这个目录是checkpoint自动生成的,不是我手动savepoint的?

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

Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,不生效怎么办?

Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据,checkpoint目前是持久化到oss上,我希望每次重启任务的时候不要从头开始抓取所有的消息。我的想法是在任务里面直接获取oss上最新进度的checkpoint目录,然后通过SavepointRestoreSettings去恢复任务进度,但是不生效。请问是什么情况,或者有没有别的更好解决方案?

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

Flink CDC里flink任务当前数据处理了多少条怎么获取啊?

Flink CDC里flink任务当前数据处理了多少条怎么获取啊?

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

我使用Flink CDC 3.0对mysql整库同步到starrock中,任务挂掉是为啥?

我使用Flink CDC 3.0对mysql整库同步到starrock中,现在任务已经创建好了,mysql的表和数据都同步到starrock中了,现在发现的问题是,我在源表加了新字段,接着flink的任务就挂掉了是为什么?

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

Flink vvr有计划配合代码仓库打包文件部署任务吗?

Flink vvr有计划配合代码仓库打包文件部署任务吗?

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

Flink 这个场景下是不是只支持一个任务中只同步这一张表呀?

我现在在这个场景下新加入其它的ctas语句,任务就直接起不来,Flink 这个场景下是不是只支持一个任务中只同步这一张表呀?

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

Hologres做实时数仓的一些敏感字段的加密解密有什么建议方案吗?都在flink任务里面做吗?

Hologres做实时数仓的一些敏感字段的加密解密有什么建议方案吗?都在flink任务里面做吗?

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

产品推荐

阿里云实时计算Flink

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

+关注