This is an automated email from the ASF dual-hosted git repository.
zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 5a3563bf0c [Improvement-18056] Remove unused code in common module
(#18104)
5a3563bf0c is described below
commit 5a3563bf0c51d36977652736ffeb8ab969f3d2a9
Author: xiangzihao <[email protected]>
AuthorDate: Tue Mar 31 23:00:16 2026 +0800
[Improvement-18056] Remove unused code in common module (#18104)
---
.../common/constants/CommandKeyConstants.java | 10 ----
.../common/constants/Constants.java | 45 --------------
.../common/constants/DateConstants.java | 30 ----------
.../common/enums/ApiTriggerType.java | 47 ---------------
.../dolphinscheduler/common/enums/CacheType.java | 40 -------------
.../dolphinscheduler/common/enums/ProgramType.java | 31 ----------
.../common/enums/SlotCheckState.java | 23 -------
.../common/enums/SqoopJobType.java | 43 -------------
.../common/enums/SqoopQueryType.java | 41 -------------
.../common/enums/StateEventType.java | 45 --------------
.../common/enums/TaskEventType.java | 28 ---------
.../common/enums/TaskRecordStatus.java | 34 -----------
.../log/remote/RemoteLogHandleThreadPool.java | 44 --------------
.../common/model/PreviousTaskNode.java | 70 ----------------------
.../common/model/WorkerServerModel.java | 62 -------------------
15 files changed, 593 deletions(-)
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/CommandKeyConstants.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/CommandKeyConstants.java
index be435b3160..a9a9152e9a 100644
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/CommandKeyConstants.java
+++
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/CommandKeyConstants.java
@@ -27,16 +27,6 @@ public class CommandKeyConstants {
*/
public static final String CMD_PARAM_RECOVER_WORKFLOW_ID_STRING =
"ProcessInstanceId";
- public static final String CMD_PARAM_RECOVERY_START_NODE_STRING =
"StartNodeIdList";
-
- public static final String CMD_PARAM_RECOVERY_WAITING_THREAD =
"WaitingThreadInstanceId";
-
- public static final String CMD_PARAM_SUB_WORKFLOW = "processInstanceId";
-
- public static final String CMD_PARAM_EMPTY_SUB_PROCESS = "0";
-
- public static final String CMD_PARAM_SUB_WORKFLOW_PARENT_INSTANCE_ID =
"parentProcessInstanceId";
-
public static final String CMD_PARAM_SUB_WORKFLOW_DEFINITION_CODE =
"workflowDefinitionCode";
public static final String CMD_PARAM_START_NODES = "StartNodeList";
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/Constants.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/Constants.java
index 03742f875f..79a0e37ed5 100644
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/Constants.java
+++
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/Constants.java
@@ -45,12 +45,6 @@ public final class Constants {
*/
public static final String FS_DEFAULT_FS = "resource.hdfs.fs.defaultFS";
- /**
- * hdfs/s3 configuration
- * resource.storage.upload.base.path
- */
- public static final String RESOURCE_UPLOAD_PATH =
"resource.storage.upload.base.path";
-
/**
* data basedir path
*/
@@ -128,9 +122,6 @@ public final class Constants {
public static final String ADDRESS = "address";
public static final String DATABASE = "database";
- public static final String OTHER = "other";
- public static final String USER = "user";
- public static final String JDBC_URL = "jdbcUrl";
public static final String IMPORT_SUFFIX = "_import_";
@@ -219,7 +210,6 @@ public final class Constants {
public static final String THREAD_NAME_ALERT_SERVER = "Alert-Server";
// suffix of crc file
- public static final String CRC_SUFFIX = ".crc";
/**
* complement date default cron string
@@ -233,21 +223,6 @@ public final class Constants {
public static final Duration SERVER_CLOSE_WAIT_TIME =
Duration.ofSeconds(3);
- /**
- * jar
- */
- public static final String JAR = "jar";
-
- /**
- * hadoop
- */
- public static final String HADOOP = "hadoop";
-
- /**
- * -D <property>=<value>
- */
- public static final String D = "-D";
-
/**
* exit code success
*/
@@ -263,27 +238,16 @@ public final class Constants {
*/
public static final int DEFINITION_FAILURE = -1;
- public static final int OPPOSITE_VALUE = -1;
-
/**
* workflow or task definition first version
*/
public static final int VERSION_FIRST = 1;
- /**
- * FAILED
- */
- public static final String FAILED = "FAILED";
- /**
- * RUNNING
- */
- public static final String RUNNING = "RUNNING";
/**
* underline "_"
*/
public static final String UNDERLINE = "_";
- public static final String STAR = "*";
public static final String GLOBAL_PARAMS = "globalParams";
public static final String LOCAL_PARAMS = "localParams";
public static final String SUBWORKFLOW_INSTANCE_ID =
"subWorkflowInstanceId";
@@ -345,8 +309,6 @@ public final class Constants {
*/
public static final String SSO_LOGIN_USER_STATE = "sso.login.user.state";
- public static final String TASK_INSTANCE_ID_MDC_KEY = "taskInstanceId";
-
/**
* status
*/
@@ -401,8 +363,6 @@ public final class Constants {
*/
public static final int SESSION_TIME_OUT = 7200;
- public static final String CLASS = "class";
-
/**
* authorize writable perm
*/
@@ -500,11 +460,6 @@ public final class Constants {
/** string no */
public static final String STRING_NO = "NO";
- public static final Integer QUERY_ALL_ON_SYSTEM = 0;
- public static final Integer QUERY_ALL_ON_PROJECT = 1;
- public static final Integer QUERY_ALL_ON_WORKFLOW = 2;
- public static final Integer QUERY_ALL_ON_TASK = 3;
-
public static final String REMOTE_LOGGING_ENABLE = "remote.logging.enable";
public static final String REMOTE_LOGGING_TARGET = "remote.logging.target";
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/DateConstants.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/DateConstants.java
index 1ec56ede63..73f80efb9d 100644
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/DateConstants.java
+++
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/constants/DateConstants.java
@@ -29,11 +29,6 @@ public class DateConstants {
*/
public static final String YYYYMMDD = "yyyyMMdd";
- /**
- * date format of yyyyMMddHHmmss
- */
- public static final String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
-
/**
* date format of yyyyMMddHHmmssSSS
*/
@@ -63,29 +58,4 @@ public class DateConstants {
* system date(yyyymmdd) yesterday
*/
public static final String PARAMETER_BUSINESS_DATE = "system.biz.date";
-
- /**
- * month_begin
- */
- public static final String MONTH_BEGIN = "month_begin";
- /**
- * add_months
- */
- public static final String ADD_MONTHS = "add_months";
- /**
- * month_end
- */
- public static final String MONTH_END = "month_end";
- /**
- * week_begin
- */
- public static final String WEEK_BEGIN = "week_begin";
- /**
- * week_end
- */
- public static final String WEEK_END = "week_end";
- /**
- * timestamp
- */
- public static final String TIMESTAMP = "timestamp";
}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ApiTriggerType.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ApiTriggerType.java
deleted file mode 100644
index 92814e6191..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ApiTriggerType.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-import com.baomidou.mybatisplus.annotation.EnumValue;
-
-/**
- * trigger support type
- */
-public enum ApiTriggerType {
-
- PROCESS(0, "process instance"),
- TASK(1, "task node"),
- COMMAND(2, "command");
-
- ApiTriggerType(int code, String desc) {
- this.code = code;
- this.desc = desc;
- }
-
- @EnumValue
- private final int code;
- private final String desc;
-
- public int getCode() {
- return code;
- }
-
- public String getDesc() {
- return desc;
- }
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/CacheType.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/CacheType.java
deleted file mode 100644
index b288a9831a..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/CacheType.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-public enum CacheType {
-
- TENANT("tenant"),
- USER("user"),
- QUEUE("queue"),
- PROCESS_DEFINITION("processDefinition"),
- PROCESS_TASK_RELATION("processTaskRelation"),
- TASK_DEFINITION("taskDefinition"),
- WORKER_GROUP("workerGroup"),
- SCHEDULE("schedule");
-
- CacheType(String cacheName) {
- this.cacheName = cacheName;
- }
-
- private final String cacheName;
-
- public String getCacheName() {
- return cacheName;
- }
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ProgramType.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ProgramType.java
deleted file mode 100644
index f0b245215a..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ProgramType.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-/**
- * support program types
- */
-public enum ProgramType {
- /**
- * 0 JAVA,1 SCALA,2 PYTHON,3 SQL
- */
- JAVA,
- SCALA,
- PYTHON,
- SQL
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SlotCheckState.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SlotCheckState.java
deleted file mode 100644
index b37a3338d1..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SlotCheckState.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-public enum SlotCheckState {
-
- PASS, INJECT, CHANGE
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopJobType.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopJobType.java
deleted file mode 100644
index 17b244c745..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopJobType.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-import com.baomidou.mybatisplus.annotation.EnumValue;
-
-public enum SqoopJobType {
-
- CUSTOM(0, "CUSTOM"),
- TEMPLATE(1, "TEMPLATE");
-
- SqoopJobType(int code, String descp) {
- this.code = code;
- this.descp = descp;
- }
-
- @EnumValue
- private final int code;
- private final String descp;
-
- public int getCode() {
- return code;
- }
-
- public String getDescp() {
- return descp;
- }
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopQueryType.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopQueryType.java
deleted file mode 100644
index 4d279f5d8e..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopQueryType.java
+++ /dev/null
@@ -1,41 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-public enum SqoopQueryType {
-
- FORM(0, "SQOOP_QUERY_FORM"),
- SQL(1, "SQOOP_QUERY_SQL");
-
- private final Integer code;
-
- private final String desc;
-
- SqoopQueryType(Integer code, String desc) {
- this.code = code;
- this.desc = desc;
- }
-
- public Integer getCode() {
- return code;
- }
-
- public String getDesc() {
- return desc;
- }
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/StateEventType.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/StateEventType.java
deleted file mode 100644
index 79a3926da2..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/StateEventType.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-import com.baomidou.mybatisplus.annotation.EnumValue;
-
-public enum StateEventType {
-
- TASK_STATE_CHANGE(1, "task state change"),
- TASK_TIMEOUT(3, "task timeout"),
- TASK_RETRY(5, "task retry"),
- ;
-
- StateEventType(int code, String descp) {
- this.code = code;
- this.descp = descp;
- }
-
- @EnumValue
- private final int code;
- private final String descp;
-
- public int getCode() {
- return code;
- }
-
- public String getDescp() {
- return descp;
- }
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskEventType.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskEventType.java
deleted file mode 100644
index 371694a051..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskEventType.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-public enum TaskEventType {
- DISPATCH,
- DELAY,
- RUNNING,
- RESULT,
- UPDATE_PID,
- WORKER_REJECT,
- CACHE,
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskRecordStatus.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskRecordStatus.java
deleted file mode 100644
index a57ad3fe47..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskRecordStatus.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.enums;
-
-/**
- * task record status
- *
- */
-public enum TaskRecordStatus {
-
- /**
- * status：
- * 0 success
- * 1 failure
- * 2 exception
- */
- SUCCESS, FAILURE, EXCEPTION
-
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/log/remote/RemoteLogHandleThreadPool.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/log/remote/RemoteLogHandleThreadPool.java
deleted file mode 100644
index 96e743bb3f..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/log/remote/RemoteLogHandleThreadPool.java
+++ /dev/null
@@ -1,44 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.log.remote;
-
-import org.apache.dolphinscheduler.common.constants.Constants;
-import org.apache.dolphinscheduler.common.utils.PropertyUtils;
-
-import java.util.concurrent.Executor;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.scheduling.annotation.EnableAsync;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
-
-@Configuration
-@EnableAsync
-public class RemoteLogHandleThreadPool {
-
- @Bean
- public Executor remoteLogHandleExecutor() {
- ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-
executor.setCorePoolSize(PropertyUtils.getInt(Constants.REMOTE_LOGGING_THREAD_POOL_SIZE,
10));
-
executor.setMaxPoolSize(PropertyUtils.getInt(Constants.REMOTE_LOGGING_THREAD_POOL_SIZE,
10));
- executor.setThreadNamePrefix("remote-logging-");
- executor.initialize();
-
- return executor;
- }
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/PreviousTaskNode.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/PreviousTaskNode.java
deleted file mode 100644
index f439184982..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/PreviousTaskNode.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.model;
-
-public class PreviousTaskNode {
-
- /**
- * code
- */
- private long code;
-
- /**
- * name
- */
- private String name;
-
- /**
- * version
- */
- private int version;
-
- public PreviousTaskNode() {
-
- }
-
- public PreviousTaskNode(long code, String name, int version) {
- this.code = code;
- this.name = name;
- this.version = version;
- }
-
- public long getCode() {
- return code;
- }
-
- public void setCode(long code) {
- this.code = code;
- }
-
- public String getName() {
- return name;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- public int getVersion() {
- return version;
- }
-
- public void setVersion(int version) {
- this.version = version;
- }
-}
diff --git
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/WorkerServerModel.java
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/WorkerServerModel.java
deleted file mode 100644
index f78edc0548..0000000000
---
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/WorkerServerModel.java
+++ /dev/null
@@ -1,62 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.common.model;
-
-import java.util.Date;
-import java.util.Set;
-
-import lombok.Data;
-
-@Data
-public class WorkerServerModel {
-
- /**
- * id
- */
- private int id;
-
- /**
- * host
- */
- private String host;
-
- /**
- * port
- */
- private int port;
-
- /**
- * worker directories in zookeeper
- */
- private Set<String> zkDirectories;
-
- /**
- * resource info about CPU and memory
- */
- private String resInfo;
-
- /**
- * create time
- */
- private Date createTime;
-
- /**
- * last heart beat time
- */
- private Date lastHeartbeatTime;
-}
