阿里云文档 2024-11-28

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

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

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

flink cdc 读mysql 写进kafka,在执行一段时间后,任务就一直出于初始化状态?

flink cdc 读mysql 写进kafka,在执行一段时间后,任务就一直出于初始化状态,一直刷这种日志,请问该怎么解决?

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

实时计算 Flink版操作报错合集之CDC任务在异常后整个record sent从0初始化开始,是什么导致的

问题一:Flink CDC中,分片表添加字段报错,可以看下吗 ? Flink CDC中,分片表添加字段报错,可以看下吗 ? 参考回答: 根据提供的错误信息,可以看出是在使用Flink CDC(Change Data Capture)时出现了异常。具体错误为java.lang.IllegalArgumentException: add column of AddC...

实时计算 Flink版操作报错合集之CDC任务在异常后整个record sent从0初始化开始,是什么导致的
文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之任务在同步过程中新增同步表后选择全量初始化历史数据,是否会阻塞原先其余表的增量同步

问题一:Flink cdc在同步过程中新增同步表后选择全量初始化历史数据,会阻塞原先其余表的增量同步吗? Flink cdc任务在同步过程中新增同步表后选择全量初始化历史数据,会阻塞原先其余表的增量同步么? 参考答案: 新增表不影响其他,有个feature是新增表不断流。增量数据从任务开始就在同步了。历史数据同步及binlog同步在全量阶段是并行执行的...

实时计算 Flink版产品使用问题之任务在同步过程中新增同步表后选择全量初始化历史数据,是否会阻塞原先其余表的增量同步
文章 2024-05-18 来自:开发者社区

实时计算 Flink版产品使用合集之在Flink Stream API中,可以在任务启动时初始化一些静态的参数并将其存储在内存中吗

问题一:Flink CDC中SQL server CDC采集是必须要求表有primary key吗? Flink CDC中SQL server CDC采集是必须要求表有primary key吗? 参考回答:...

实时计算 Flink版产品使用合集之在Flink Stream API中,可以在任务启动时初始化一些静态的参数并将其存储在内存中吗
问答 2024-04-26 来自:开发者社区

Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,什么时候开始增量?

Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,如果十几个小时才能初始化完成,无锁算法开始增量的时候是从十几个小时前的binlog位点增量还是从当前时间位点增量?(如果是从十几个小时前的binlog位点衔接增量,如果binlog已经归档了,就会报错文件找不到)

问答 2024-03-27 来自:开发者社区

flink任务重启 从最新状态恢复 有2个task 一直在初始化状态很久才能启动 是什么原因?

flink任务重启 从最新状态恢复 有2个task 一直在初始化状态很久才能启动 是什么原因?

问答 2024-03-25 来自:开发者社区

.Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,初始化什么时候开始?

Flink cdc任务在同步过程中新增同步表后选择全量初始化历史数据,会阻塞原先其余表的增量同步么?

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

Flink中kafkaSink 使用精准一次性语意 为啥恢复任务的时候初始化的时间很长?

Flink中kafkaSink 使用精准一次性语意 为啥恢复任务的时候初始化的时间很长 会导致 ck 失败?

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

现在flink cdc 接入mysql 表时 表新增字段 还会导致同步任务重新初始化吗 ?

现在flink cdc 接入mysql 表时 表新增字段 还会导致同步任务重新初始化吗 ?

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问