diff --git a/headless/core/src/main/java/com/tencent/supersonic/headless/core/config/ExecutorConfig.java b/headless/core/src/main/java/com/tencent/supersonic/headless/core/config/ExecutorConfig.java index 909a1d78c..5a0adb785 100644 --- a/headless/core/src/main/java/com/tencent/supersonic/headless/core/config/ExecutorConfig.java +++ b/headless/core/src/main/java/com/tencent/supersonic/headless/core/config/ExecutorConfig.java @@ -8,7 +8,7 @@ import org.springframework.context.annotation.Configuration; @Configuration public class ExecutorConfig { - @Value("${s2.metricParser.agg.mysql.lowVersion:5.7}") + @Value("${s2.metricParser.agg.mysql.lowVersion:8.0}") private String mysqlLowVersion; @Value("${s2.metricParser.agg.ck.lowVersion:20.4}") diff --git a/headless/core/src/main/java/com/tencent/supersonic/headless/core/utils/SqlGenerateUtils.java b/headless/core/src/main/java/com/tencent/supersonic/headless/core/utils/SqlGenerateUtils.java index ba7bd31e4..0c5f87781 100644 --- a/headless/core/src/main/java/com/tencent/supersonic/headless/core/utils/SqlGenerateUtils.java +++ b/headless/core/src/main/java/com/tencent/supersonic/headless/core/utils/SqlGenerateUtils.java @@ -260,7 +260,7 @@ public class SqlGenerateUtils { public boolean isSupportWith(EngineType engineTypeEnum, String version) { if (engineTypeEnum.equals(EngineType.MYSQL) && Objects.nonNull(version) - && version.startsWith(executorConfig.getMysqlLowVersion())) { + && StringUtil.compareVersion(version, executorConfig.getMysqlLowVersion()) < 0) { return false; } if (engineTypeEnum.equals(EngineType.CLICKHOUSE) && Objects.nonNull(version)