阿里云文档 2024-11-28

如何在Dataphin自定义Ververica Flink实时任务的资源

Ververica Flink实时任务资源自定义,即指实时计算Flink配置细粒度资源的专家模式 (BETA),Flink全托管引入的全新的资源配置模式,支持对作业所使用的资源进行细粒度的资源控制,以满足作业吞吐的要求。系统会自动根据您配置的资源需求,以Native K8s的模式运行作业,TM的规格和个数将会根据Slot的规格和作业并发度,由系统自动决定。本文将介绍如何在Dataphin自定义Ve...

文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之如何通过savepoint恢复Flink CDC任务

问题一:Flink CDC我使用cdc从oracle同步数据到doris,数据全部加载到内存后,报错怎么办? Flink CDC里我使用cdc从oracle同步数据到doris,这边将数据全部加载到内存后,报错如下:2024-01-09 15:11:00,825 WARN org.apache.flink.runtime.taskmanager.Task [] - Sink sink-d...

实时计算 Flink版操作报错合集之如何通过savepoint恢复Flink CDC任务
文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之如何从指定的savepoint恢复任务

问题一:Flink 这是为何? Flink 这是为何?我的数据库中压根没有wh_item_lending这个表 flink是1.13.6的 CDC是1.4.0 参考答案: 应该是mysql 的元数...

实时计算 Flink版产品使用问题之如何从指定的savepoint恢复任务
文章 2024-02-26 来自:开发者社区

Flink问题之从SavePoint启动任务修改的代码不生效

问题一:关于jdbc connector扩展问题 hi all我这里有个需求需要从sql里面写数据到clickhouse里面,但是看源码,发现并不好扩展,https://github.com/apache/flink/blob/d04872d2c6b7570ea3ba02f8fc4fca02daa96118/flink-connectors/flink-connector-jd...

文章 2024-02-26 来自:开发者社区

Flink部署问题之带上savepoint部署任务报错如何解决

问题一:Flink Cli 部署问题 大家好,我在部署的时候发现了一个问题,我通过restAPI接口停掉了一个任务并保存了它的savepoint(步骤:/jobs/overview ---> /jobs/{jobid}/savepoints ---> /jobs/{jobid}/savepoints/{triggerid}),但我通过flink命令带上savepoint部署任...

文章 2024-02-24 来自:开发者社区

Flink CDC数据同步问题之用savepoint重启任务报错如何解决

问题一:请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄 请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/503721?spm=a2c6h.13066369.questio...

Flink CDC数据同步问题之用savepoint重启任务报错如何解决
问答 2024-02-06 来自:开发者社区

bin/flink-cdc.sh 版本3.0,如何从指定的savepoint启动或恢复任务?

bin/flink-cdc.sh 版本3.0 这种方式如何从指定的savepoint或者savepoint启动恢复任务呢?

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

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启?

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启,这是正常日志?

问答 2023-09-06 来自:开发者社区

Flink CDC我是在程序里面把整库同步进行了集成,用savepoint重启任务就是报错?

问题1:Flink CDC我是在程序里面把整库同步进行了集成,程序里启停任务,现在问题是同步数据时候,以前是5张表,一个任务,现在改为7张表一个任务后,用savepoint重启任务就是报错?需要设置allowNonRestoredState参数问题2:命令方式,我也看到有,就是程序里配置,一直找不到

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

flink cdc使用savepoint停止任务新的表会按照那种模式进行消费呢?

flink cdc使用savepoint停止任务,再用savepoint启动时,新加了一张表,并更改了消费方式,比如从binlog头部消费改为了全量转增量,那接下来新的表会按照那种模式进行消费呢?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注