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

flink1.11 执行任务控制台日志怎么没有 application ID 呀?

flink1.11 执行任务控制台日志怎么没有 application ID 呀?

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

mysql增加默认值,这个ddl操作,会导致flink cdc任务同步失败吗?

mysql增加默认值,这个ddl操作,会导致flink cdc任务同步失败吗?

文章 2023-11-08 来自:开发者社区

在Flink CDC中,本地模式(Local Mode)是指Flink任务在单个节点上运行

在Flink CDC中,本地模式(Local Mode)是指Flink任务在单个节点上运行,不启用任务并行度,所有算子都在一个线程中执行。在这种模式下,Flink CDC可以实现断点续传。 具体来说,你可以通过以下步骤来实现断点续传: 在全量同步开始前,记录同步位置。这可...

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

Flink CDC维表的数据只是在flink任务起来就一直不更新吗 哪怕是这个维表数据有变动?

Flink CDC维表的数据只是在flink任务起来就一直不更新吗 哪怕是这个维表数据有变动?

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

Flink CDC mongodb数据 有一个分区报了oplog过期,为什么任务不会失败啊?

Flink CDC mongodb数据 有一个分区报了oplog过期,其他分区都正常,为什么任务不会失败啊?

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

Flink CDC任务全量跑完后 jvm heap 内存占用一直在增加 不知道为啥?

Flink CDC任务全量跑完后 jvm heap 内存占用一直在增加 不知道为啥?已经从占用1.6G增加到2.2G了 ,就是我有两个任务 都是单表同步 全量+增量 全量同步完毕后jvm heap 占用1.6G 然后过了三分钟 内存占用飙到了 2.2G 这期间并没有增量任务

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

Flink CDC如果数据源换了(只是数据量变了) ck的路径没变 那新任务里 ck还有用吗?

Flink CDC如果数据源换了(只是数据量变了) ck的路径没变 那新任务里 ck还有用吗?

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

Flink CDC你们cdc配置db.*,如果库里频繁加表,你们是咋操作的,一加表就重启任务?

Flink CDC你们cdc配置db.*,如果库里频繁加表,你们是咋操作的,一加表就重启任务?不生效啊,任务一直运行着,库里新建一个表,如果不重启任务,增量数据都进不去,只能savepoint,然后savepoint恢复任务,不及时恢复任务,那么后面这个表的历史数据会丢失,除非在任务初始化的时候指定表名,全量启动,后面新建的表,再加到配置里,然后恢复启动不会有问题

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

Flink CDC我在配置文件分配了三个G 没提交任务是只占用了100m 现在已经增长到1.7G?

Flink CDC我在配置文件分配了三个G 没提交任务是只占用了100m 全量阶段跑完后占用1.6G 然后就一直不动了。现在已经增长到1.7G?

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

Flink CDC这种任务 全量跑完内存不会释放吗?

Flink CDC这种任务 全量跑完内存不会释放吗?

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

产品推荐

实时计算 Flink

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

+关注