dongjunchuan/de
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(数据集): Doris 数据源定时同步数据集定时任务执行成功无数据

Browse Source
This commit is contained in:
taojinlong 2024-03-22 15:42:33 +08:00
parent 98a24d6379
commit c2e0a569ff
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/backend/src/main/java/io/dataease/provider/engine/doris/DorisDDLProvider.java
View File

@ -99,7 +99,7 @@ public class DorisDDLProvider extends DDLProviderImpl {
} }
switch (datasetTableField.getDeExtractType()) { switch (datasetTableField.getDeExtractType()) {
case 0: case 0:
if (size <= 65533 || (keys != null && keys.contains(datasetTableField.getDataeaseName()))) { if (keys != null && keys.contains(datasetTableField.getDataeaseName())) {
Column_Fields.append("VARCHAR(length)".replace("length", String.valueOf(size))).append(",`"); Column_Fields.append("VARCHAR(length)".replace("length", String.valueOf(size))).append(",`");
} else { } else {
Column_Fields.append("STRING".replace("length", String.valueOf(size))).append(",`"); Column_Fields.append("STRING".replace("length", String.valueOf(size))).append(",`");

4
core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java
View File

@ -567,8 +567,8 @@ public class ExtractDataService {
} catch (Exception e) { } catch (Exception e) {
throw e; throw e;
} finally { } finally {
// File deleteFile = new File(root_path + datasetTable.getId() + ".sh"); File deleteFile = new File(root_path + datasetTable.getId() + ".sh");
// FileUtils.forceDelete(deleteFile); FileUtils.forceDelete(deleteFile);
} }
} }