diff --git a/dinky-admin/src/main/java/org/dinky/data/dto/APIExecuteSqlDTO.java b/dinky-admin/src/main/java/org/dinky/data/dto/APIExecuteSqlDTO.java index f5f439956a..d3c5c3e95f 100644 --- a/dinky-admin/src/main/java/org/dinky/data/dto/APIExecuteSqlDTO.java +++ b/dinky-admin/src/main/java/org/dinky/data/dto/APIExecuteSqlDTO.java @@ -125,7 +125,6 @@ public JobConfig getJobConfig() { .useResult(useResult) .useChangeLog(useChangeLog) .useAutoCancel(useAutoCancel) - .useSession(false) .useRemote(true) .address(address) .jobName(jobName) diff --git a/dinky-admin/src/main/java/org/dinky/data/dto/APIExplainSqlDTO.java b/dinky-admin/src/main/java/org/dinky/data/dto/APIExplainSqlDTO.java index 66a4bd5770..df361e6383 100644 --- a/dinky-admin/src/main/java/org/dinky/data/dto/APIExplainSqlDTO.java +++ b/dinky-admin/src/main/java/org/dinky/data/dto/APIExplainSqlDTO.java @@ -58,7 +58,6 @@ public class APIExplainSqlDTO extends AbstractStatementDTO { public JobConfig getJobConfig() { return JobConfig.builder() .type(GatewayType.LOCAL.getLongValue()) - .useSession(false) .useRemote(false) .fragment(isFragment()) .statementSet(useStatementSet) diff --git a/dinky-admin/src/main/java/org/dinky/data/dto/TaskDTO.java b/dinky-admin/src/main/java/org/dinky/data/dto/TaskDTO.java index d2f0c4e54e..914736f650 100644 --- a/dinky-admin/src/main/java/org/dinky/data/dto/TaskDTO.java +++ b/dinky-admin/src/main/java/org/dinky/data/dto/TaskDTO.java @@ -226,13 +226,6 @@ public class TaskDTO extends AbstractStatementDTO { notes = "Flag indicating whether to use auto-canceling") private boolean useAutoCancel; - @ApiModelProperty( - value = "Use Session", - dataType = "boolean", - example = "false", - notes = "Flag indicating whether to use a session") - private boolean useSession; - @ApiModelProperty(value = "Session", dataType = "String", example = "session_id", notes = "The session identifier") private String session; diff --git a/dinky-admin/src/main/java/org/dinky/service/impl/StudioServiceImpl.java b/dinky-admin/src/main/java/org/dinky/service/impl/StudioServiceImpl.java index 0be00ea4bd..332edf04d1 100644 --- a/dinky-admin/src/main/java/org/dinky/service/impl/StudioServiceImpl.java +++ b/dinky-admin/src/main/java/org/dinky/service/impl/StudioServiceImpl.java @@ -91,10 +91,6 @@ public JdbcSelectResult getCommonSqlData(Integer taskId) { @Override public IResult executeDDL(StudioDDLDTO studioDDLDTO) { JobConfig config = studioDDLDTO.getJobConfig(); - if (!config.isUseSession()) { - config.setAddress( - clusterInstanceService.buildEnvironmentAddress(config.isUseRemote(), studioDDLDTO.getClusterId())); - } JobManager jobManager = JobManager.build(config); return jobManager.executeDDL(studioDDLDTO.getStatement()); } diff --git a/dinky-core/src/main/java/org/dinky/explainer/Explainer.java b/dinky-core/src/main/java/org/dinky/explainer/Explainer.java index 9d2de6592d..1448ab428e 100644 --- a/dinky-core/src/main/java/org/dinky/explainer/Explainer.java +++ b/dinky-core/src/main/java/org/dinky/explainer/Explainer.java @@ -365,7 +365,6 @@ public JobPlanInfo getJobPlanInfo(String statement) { public List getLineage(String statement) { JobConfig jobConfig = JobConfig.builder() .type(GatewayType.LOCAL.getLongValue()) - .useSession(false) .useRemote(false) .fragment(true) .statementSet(useStatementSet) diff --git a/dinky-core/src/main/java/org/dinky/job/JobConfig.java b/dinky-core/src/main/java/org/dinky/job/JobConfig.java index 0e65b98296..0bbea9771a 100644 --- a/dinky-core/src/main/java/org/dinky/job/JobConfig.java +++ b/dinky-core/src/main/java/org/dinky/job/JobConfig.java @@ -110,13 +110,6 @@ public class JobConfig { notes = "Flag indicating whether to use auto-cancel") private boolean useAutoCancel; - @ApiModelProperty( - value = "Flag indicating whether to use session", - dataType = "boolean", - example = "true", - notes = "Flag indicating whether to use session") - private boolean useSession; - @ApiModelProperty( value = "Session information", dataType = "String", diff --git a/dinky-core/src/test/java/org/dinky/core/JobManagerTest.java b/dinky-core/src/test/java/org/dinky/core/JobManagerTest.java index b1a1571632..e16a0465cc 100644 --- a/dinky-core/src/test/java/org/dinky/core/JobManagerTest.java +++ b/dinky-core/src/test/java/org/dinky/core/JobManagerTest.java @@ -49,7 +49,6 @@ public void cancelJobSelect() { .useResult(true) .useChangeLog(true) .useAutoCancel(true) - .useSession(true) .session("s1") .clusterId(2) .jobName("Test")