fix: sql 数据集 抽取

This commit is contained in:
taojinlong 2021-06-11 16:59:10 +08:00
parent dbf671c4f7
commit 0011bae39c

View File

@ -226,6 +226,7 @@ public class ExtractDataService {
}else {
DatasetTableIncrementalConfig datasetTableIncrementalConfig = dataSetTableService.incrementalConfig(datasetTableId);
if (datasetTableIncrementalConfig == null || StringUtils.isEmpty(datasetTableIncrementalConfig.getTableId())) {
updateTableStatus(datasetTableId, datasetTable, JobStatus.Completed);
return;
}
DatasetTableTaskLog request = new DatasetTableTaskLog();
@ -233,6 +234,7 @@ public class ExtractDataService {
request.setStatus(JobStatus.Completed.name());
List<DatasetTableTaskLog> datasetTableTaskLogs = dataSetTableTaskLogService.select(request);
if (CollectionUtils.isEmpty(datasetTableTaskLogs)) {
updateTableStatus(datasetTableId, datasetTable, JobStatus.Completed);
return;
}