diff --git a/dinky-common/src/main/java/org/dinky/data/enums/Status.java b/dinky-common/src/main/java/org/dinky/data/enums/Status.java index 27e886adbd..ef58f83f59 100644 --- a/dinky-common/src/main/java/org/dinky/data/enums/Status.java +++ b/dinky-common/src/main/java/org/dinky/data/enums/Status.java @@ -193,7 +193,6 @@ public enum Status { MODE_IS_NOT_ALLOW_SELECT(12014, "mode.is.not.allow.select"), OPERATE_NOT_SUPPORT_QUERY(12015, "operate.not.support.query"), TASK_NOT_OPERATE_PERMISSION(12016, "task.not.operate.permission"), - TASK_SQL_NO_EXECUTABLE(12017, "task.sql.no.executable"), /** * alert instance diff --git a/dinky-common/src/main/resources/i18n/messages_en_US.properties b/dinky-common/src/main/resources/i18n/messages_en_US.properties index 3a6f925e4e..d1ce15d0e6 100644 --- a/dinky-common/src/main/resources/i18n/messages_en_US.properties +++ b/dinky-common/src/main/resources/i18n/messages_en_US.properties @@ -290,7 +290,6 @@ task.update.failed=Task Update failed mode.is.not.allow.select=Application / Pre-Job mode does not allow executing select statements. To perform this operation, please switch to Local, Standalone, or Yarn session modes. operate.not.support.query=The [Run] button does not support select statements, please switch to the [Query] button. task.not.operate.permission=No operation permission for the task -task.sql.no.executable=Does not contain executable statement types: {0} # process process.submit.submitTask= Submit the job diff --git a/dinky-common/src/main/resources/i18n/messages_zh_CN.properties b/dinky-common/src/main/resources/i18n/messages_zh_CN.properties index 87266f0493..1bd66abddf 100644 --- a/dinky-common/src/main/resources/i18n/messages_zh_CN.properties +++ b/dinky-common/src/main/resources/i18n/messages_zh_CN.properties @@ -290,7 +290,6 @@ task.update.failed=Task更新失败 mode.is.not.allow.select=Application / Pre-Job 模式不允许执行 select 语句, 如需执行此操作, 请切换至 Local、Standalone、Yarn session等模式 operate.not.support.query=[运行] 按钮不支持 select 语句,请切换至 [查询] 按钮 task.not.operate.permission=任务无操作权限 -task.sql.no.executable=不包含可执行的语句类型: {0} # process process.submit.submitTask=提交作业 diff --git a/dinky-core/src/main/java/org/dinky/job/builder/JobTransBuilder.java b/dinky-core/src/main/java/org/dinky/job/builder/JobTransBuilder.java index e3fb5a0ce8..74cb561296 100644 --- a/dinky-core/src/main/java/org/dinky/job/builder/JobTransBuilder.java +++ b/dinky-core/src/main/java/org/dinky/job/builder/JobTransBuilder.java @@ -22,8 +22,6 @@ import org.dinky.assertion.Asserts; import org.dinky.constant.FlinkSQLConstant; import org.dinky.data.enums.GatewayType; -import org.dinky.data.enums.Status; -import org.dinky.data.exception.BusException; import org.dinky.data.result.IResult; import org.dinky.data.result.InsertResult; import org.dinky.data.result.ResultBuilder; @@ -44,12 +42,10 @@ import org.apache.flink.runtime.jobgraph.SavepointRestoreSettings; import org.apache.flink.table.api.TableResult; -import java.text.MessageFormat; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.UUID; -import java.util.stream.Collectors; /** * JobTransBuilder @@ -68,9 +64,7 @@ public static JobTransBuilder build(JobManager jobManager) { @Override public void run() throws Exception { if (jobParam.getTrans().isEmpty()) { - String transSqlTypes = - SqlType.getTransSqlTypes().stream().map(SqlType::getType).collect(Collectors.joining(",")); - throw new BusException(MessageFormat.format(Status.TASK_SQL_NO_EXECUTABLE.getMessage(), transSqlTypes)); + return; } if (useStatementSet) {