文章 2024-01-21 来自:开发者社区

在使用FlinkSQL进行数据同步时,创建了一个新的任务,但发现无法删除旧任务同步的历史数据

在使用FlinkSQL进行数据同步时,如果你重新创建了一个新的任务,但发现无法删除旧任务同步的历史数据,这可能是由于多种原因造成的。以下是一些建议和可能的解决方案: 1、 任务定义与状态: * Flink 任务的状态是在 Flink 的元数据存储中管理的。当你重新创建任务时,新任务会有一个新的状态,...

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

FlinkSQL任务数据同步-------重新创建新的任务后, 无法删除旧任务同步的历史数据问题

FlinkSQL创建的任务场景:mysql同步到kafka(采集数据), 再由kafka同步kafka(搬运数据), 再由kafka同步到mysql(数据落库), 当停止采集或者落库任务后, 再次创建新的采集或者新的落库任务; 现在出现以下几个问题 现在现象: ① 源表新增数据同步同步到目标表, 可以对新增的数据进行编辑同步到目标表, 可以对新增的数据进行删除, 目标也会同步删除...

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

dataworks这有个数据同步任务,数据源是oracle,该如何排查原因?

dataworks这有个数据同步任务,数据源是oracle,同步到maxcomputer,平时是2分钟左右就完成了,今天半个小时都没跑完,该如何排查原因?

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

Dataworks数据同步任务执行失败?

Dataworks数据同步任务执行失败? {"returnCode":"10","returnErrorSolution":"","returnMessage":"元数据接口调用失败","returnValue":{"table":"ods_dbo_jdt1"},"success":false}Request ID:0b736ec317046853551324049e4139

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

在数据传输DTS数据同步任务,在做增量同步时遇到一个错误,应该怎样排查?

在数据传输DTS数据同步任务,在做增量同步时遇到一个错误,错误代码DTS-RETRY-ERR-0079,想了解应该怎样排查?

问答 2023-12-23 来自:开发者社区

DataWorks数据同步发布一个任务了 但是在同步任务页面看不到, 这个是什么原因?

DataWorks数据同步发布一个任务了 但是在同步任务页面看不到, 这个是什么原因?

问答 2023-12-10 来自:开发者社区

DataWorks配置数据同步任务往MySQL写入数据,为何最后写入数据库的id不是从1开始的呢?

DataWorks配置数据同步任务往MySQL写入数据,MySQL设置了自增属性,从1开始,为何最后写入数据库的id不是从1开始的呢?任务执行前已执行了truncate命令?

问答 2023-12-10 来自:开发者社区

DataWorks数据同步任务报错,spec是什么意思?

DataWorks数据同步任务报错,partition key pt expected but missed in table's partition spec是什么意思?我查看了导入的数据表结构,是以pt为分区

问答 2023-12-04 来自:开发者社区

Flink CDC任务里有三个 全量+增量 的数据同步。并没有下降(如下图红框),这是为什么呀?

Flink CDC任务里有三个 全量+增量 的数据同步。现在有两个已经完成了全量同步(如上图蓝框),但是我查看任务所占的内存,并没有下降(如下图红框),这是为什么呀?是否正常,可否优化?

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

dataworks中 独享集成资源组 不是负责数据同步的吗? 为什么同步任务还会一直wait?

dataworks中 独享集成资源组 不是负责数据同步的吗? 为什么同步任务还会一直wait? 这里的tunnel资源组又是什么

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

产品推荐