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

This commit is contained in:
taojinlong 2021-08-04 10:33:12 +08:00
parent b4a057d46b
commit e438d4e1f0
2 changed files with 5 additions and 1 deletions

View File

@ -283,7 +283,7 @@ public class ExtractDataService {
createDorisTable(DorisTableUtils.dorisTmpName(DorisTableUtils.dorisName(datasetTableId)), dorisTablColumnSql);
generateTransFile("all_scope", datasetTable, datasource, datasetTableFields, null);
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 {
generateJobFile("all_scope", datasetTable, String.join(",", datasetTableFields.stream().map(DatasetTableField::getDataeaseName).collect(Collectors.toList())));
}

View File

@ -432,10 +432,14 @@ export default {
created() {
this.timer = setInterval(() => {
this.listTaskLog(false)
}, 5000);
this.taskTimer = setInterval(() => {
this.listTask(false)
}, 5000)
},
beforeDestroy() {
clearInterval(this.timer)
clearInterval(this.taskTimer)
},
methods: {
calHeight() {