提交 9579d08b authored 作者: taojinlong's avatar taojinlong

fix: 原始表添加列时,同步失败

上级 2e888d35
...@@ -283,7 +283,7 @@ public class ExtractDataService { ...@@ -283,7 +283,7 @@ public class ExtractDataService {
createDorisTable(DorisTableUtils.dorisTmpName(DorisTableUtils.dorisName(datasetTableId)), dorisTablColumnSql); createDorisTable(DorisTableUtils.dorisTmpName(DorisTableUtils.dorisName(datasetTableId)), dorisTablColumnSql);
generateTransFile("all_scope", datasetTable, datasource, datasetTableFields, null); generateTransFile("all_scope", datasetTable, datasource, datasetTableFields, null);
if (datasetTable.getType().equalsIgnoreCase("sql")) { if (datasetTable.getType().equalsIgnoreCase("sql")) {
generateJobFile("all_scope", datasetTable, fetchSqlField(new Gson().fromJson(datasetTable.getInfo(), DataTableInfoDTO.class).getSql(), datasource)); generateJobFile("all_scope", datasetTable, String.join(",", datasetTableFields.stream().map(DatasetTableField::getDataeaseName).collect(Collectors.toList())));
} else { } else {
generateJobFile("all_scope", datasetTable, String.join(",", datasetTableFields.stream().map(DatasetTableField::getDataeaseName).collect(Collectors.toList()))); generateJobFile("all_scope", datasetTable, String.join(",", datasetTableFields.stream().map(DatasetTableField::getDataeaseName).collect(Collectors.toList())));
} }
......
...@@ -433,10 +433,14 @@ export default { ...@@ -433,10 +433,14 @@ export default {
created() { created() {
this.timer = setInterval(() => { this.timer = setInterval(() => {
this.listTaskLog(false) this.listTaskLog(false)
}, 5000);
this.taskTimer = setInterval(() => {
this.listTask(false)
}, 5000) }, 5000)
}, },
beforeDestroy() { beforeDestroy() {
clearInterval(this.timer) clearInterval(this.timer)
clearInterval(this.taskTimer)
}, },
methods: { methods: {
calHeight() { calHeight() {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论