From c2e0a569ff9687749a429873757570745b53bc5e Mon Sep 17 00:00:00 2001 From: taojinlong Date: Fri, 22 Mar 2024 15:42:33 +0800 Subject: [PATCH] =?UTF-8?q?fix(=E6=95=B0=E6=8D=AE=E9=9B=86):=20Doris=20?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=BA=90=E5=AE=9A=E6=97=B6=E5=90=8C=E6=AD=A5?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E9=9B=86=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E6=89=A7=E8=A1=8C=E6=88=90=E5=8A=9F=E6=97=A0=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../io/dataease/provider/engine/doris/DorisDDLProvider.java | 2 +- .../java/io/dataease/service/dataset/ExtractDataService.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/core/backend/src/main/java/io/dataease/provider/engine/doris/DorisDDLProvider.java b/core/backend/src/main/java/io/dataease/provider/engine/doris/DorisDDLProvider.java index 79378adcc3..768fceb54b 100644 --- a/core/backend/src/main/java/io/dataease/provider/engine/doris/DorisDDLProvider.java +++ b/core/backend/src/main/java/io/dataease/provider/engine/doris/DorisDDLProvider.java @@ -99,7 +99,7 @@ public class DorisDDLProvider extends DDLProviderImpl { } switch (datasetTableField.getDeExtractType()) { 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(",`"); } else { Column_Fields.append("STRING".replace("length", String.valueOf(size))).append(",`"); diff --git a/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java b/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java index ef5ef50634..bf8180936c 100644 --- a/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java +++ b/core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java @@ -567,8 +567,8 @@ public class ExtractDataService { } catch (Exception e) { throw e; } finally { -// File deleteFile = new File(root_path + datasetTable.getId() + ".sh"); -// FileUtils.forceDelete(deleteFile); + File deleteFile = new File(root_path + datasetTable.getId() + ".sh"); + FileUtils.forceDelete(deleteFile); } }