This is an automated email from the ASF dual-hosted git repository.
wenjun 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 2981ad9935 [Improvement-18056] Remove unused code in dao module
(#18107)
2981ad9935 is described below
commit 2981ad9935224ae5c00320dda7f39f0cd58bf46b
Author: xiangzihao <[email protected]>
AuthorDate: Tue Mar 31 20:27:41 2026 +0800
[Improvement-18056] Remove unused code in dao module (#18107)
---
.../dao/entity/CycleDependency.java | 94 ---------
.../apache/dolphinscheduler/dao/entity/K8s.java | 59 ------
.../dolphinscheduler/dao/entity/MonitorRecord.java | 130 -------------
.../dao/entity/TaskAlertContent.java | 68 -------
.../dao/entity/ZookeeperRecord.java | 216 ---------------------
.../dao/entity/event/AbstractListenerEvent.java | 27 ---
.../ProcessDefinitionCreatedListenerEvent.java | 195 -------------------
.../ProcessDefinitionDeletedListenerEvent.java | 52 -----
.../ProcessDefinitionUpdatedListenerEvent.java | 195 -------------------
.../dao/entity/event/ProcessEndListenerEvent.java | 59 ------
.../dao/entity/event/ProcessFailListenerEvent.java | 59 ------
.../entity/event/ProcessStartListenerEvent.java | 58 ------
.../dao/entity/event/ServerDownListenerEvent.java | 45 -----
.../dao/entity/event/TaskEndListenerEvent.java | 59 ------
.../dao/entity/event/TaskFailListenerEvent.java | 59 ------
.../dao/entity/event/TaskStartListenerEvent.java | 59 ------
.../dolphinscheduler/dao/mapper/K8sMapper.java | 29 ---
.../dao/utils/BaseDBPerformance.java | 36 ----
.../dolphinscheduler/dao/utils/BeanContext.java | 69 -------
.../dao/utils/ResourceProcessDefinitionUtils.java | 100 ----------
...WorkflowDefinitionCreatedListenerEventTest.java | 48 -----
...WorkflowDefinitionUpdatedListenerEventTest.java | 48 -----
.../utils/ResourceWorkflowDefinitionUtilsTest.java | 43 ----
23 files changed, 1807 deletions(-)
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/CycleDependency.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/CycleDependency.java
deleted file mode 100644
index 109a204f11..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/CycleDependency.java
+++ /dev/null
@@ -1,94 +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.dao.entity;
-
-import org.apache.dolphinscheduler.common.enums.CycleEnum;
-
-import java.util.Date;
-
-/**
- * cycle dependency
- */
-public class CycleDependency {
-
- /**
- * process define id
- */
- private int processDefineId;
- /**
- * last schedule time
- */
- private Date lastScheduleTime;
- /**
- * expiration time
- */
- private Date expirationTime;
- /**
- * cycle enum
- */
- private CycleEnum cycleEnum;
-
- public CycleDependency(int processDefineId, Date lastScheduleTime, Date
expirationTime, CycleEnum cycleEnum) {
- this.processDefineId = processDefineId;
- this.lastScheduleTime = lastScheduleTime;
- this.expirationTime = expirationTime;
- this.cycleEnum = cycleEnum;
- }
-
- public int getProcessDefineId() {
- return processDefineId;
- }
-
- public void setProcessDefineId(int processDefineId) {
- this.processDefineId = processDefineId;
- }
-
- public Date getLastScheduleTime() {
- return lastScheduleTime;
- }
-
- public void setLastScheduleTime(Date lastScheduleTime) {
- this.lastScheduleTime = lastScheduleTime;
- }
-
- public Date getExpirationTime() {
- return expirationTime;
- }
-
- public void setExpirationTime(Date expirationTime) {
- this.expirationTime = expirationTime;
- }
-
- public CycleEnum getCycleEnum() {
- return cycleEnum;
- }
-
- public void setCycleEnum(CycleEnum cycleEnum) {
- this.cycleEnum = cycleEnum;
- }
-
- @Override
- public String toString() {
- return "CycleDependency{"
- + "processDefineId=" + processDefineId
- + ", lastScheduleTime=" + lastScheduleTime
- + ", expirationTime=" + expirationTime
- + ", cycleEnum=" + cycleEnum
- + '}';
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/K8s.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/K8s.java
deleted file mode 100644
index 7a3086cff5..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/K8s.java
+++ /dev/null
@@ -1,59 +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.dao.entity;
-
-import java.util.Date;
-
-import lombok.Data;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-
-@Data
-@TableName("t_ds_k8s")
-public class K8s {
-
- /**
- * id
- */
- @TableId(value = "id", type = IdType.AUTO)
- private Integer id;
- /**
- * k8s name
- */
- @TableField(value = "k8s_name")
- private String k8sName;
- /**
- * k8s client config(yaml or json)
- */
- @TableField(value = "k8s_config")
- private String k8sConfig;
-
- /**
- * create_time
- */
- @TableField("create_time")
- private Date createTime;
- /**
- * update_time
- */
- @TableField("update_time")
- private Date updateTime;
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/MonitorRecord.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/MonitorRecord.java
deleted file mode 100644
index 80cd06d528..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/MonitorRecord.java
+++ /dev/null
@@ -1,130 +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.dao.entity;
-
-import org.apache.dolphinscheduler.common.enums.Flag;
-import org.apache.dolphinscheduler.spi.enums.DbType;
-
-import java.util.Date;
-
-/**
- * monitor record for database
- */
-public class MonitorRecord {
-
- private DbType dbType;
-
- /**
- * is normal or not , 1: normal
- */
- private Flag state;
-
- /**
- * max connections
- */
- private long maxConnections;
-
- /**
- * max used connections
- */
- private long maxUsedConnections;
-
- /**
- * threads connections
- */
- private long threadsConnections;
-
- /**
- * threads running connections
- */
- private long threadsRunningConnections;
-
- /**
- * start date
- */
- private Date date;
-
- public Flag getState() {
- return state;
- }
-
- public void setState(Flag state) {
- this.state = state;
- }
-
- public long getMaxConnections() {
- return maxConnections;
- }
-
- public void setMaxConnections(long maxConnections) {
- this.maxConnections = maxConnections;
- }
-
- public long getMaxUsedConnections() {
- return maxUsedConnections;
- }
-
- public void setMaxUsedConnections(long maxUsedConnections) {
- this.maxUsedConnections = maxUsedConnections;
- }
-
- public long getThreadsConnections() {
- return threadsConnections;
- }
-
- public void setThreadsConnections(long threadsConnections) {
- this.threadsConnections = threadsConnections;
- }
-
- public long getThreadsRunningConnections() {
- return threadsRunningConnections;
- }
-
- public void setThreadsRunningConnections(long threadsRunningConnections) {
- this.threadsRunningConnections = threadsRunningConnections;
- }
-
- public Date getDate() {
- return date;
- }
-
- public void setDate(Date date) {
- this.date = date;
- }
-
- @Override
- public String toString() {
- return "MonitorRecord{"
- + "state=" + state
- + ", dbType=" + dbType
- + ", maxConnections=" + maxConnections
- + ", maxUsedConnections=" + maxUsedConnections
- + ", threadsConnections=" + threadsConnections
- + ", threadsRunningConnections=" + threadsRunningConnections
- + ", date=" + date
- + '}';
- }
-
- public DbType getDbType() {
- return dbType;
- }
-
- public void setDbType(DbType dbType) {
- this.dbType = dbType;
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/TaskAlertContent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/TaskAlertContent.java
deleted file mode 100644
index d1490b8fde..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/TaskAlertContent.java
+++ /dev/null
@@ -1,68 +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.dao.entity;
-
-import org.apache.dolphinscheduler.plugin.task.api.enums.TaskExecutionStatus;
-
-import java.io.Serializable;
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-@JsonInclude(Include.NON_NULL)
-public class TaskAlertContent implements Serializable {
-
- @JsonProperty("taskInstanceId")
- private int taskInstanceId;
- @JsonProperty("taskName")
- private String taskName;
- @JsonProperty("taskType")
- private String taskType;
- @JsonProperty("processDefinitionId")
- private int processDefinitionId;
- @JsonProperty("processDefinitionName")
- private String processDefinitionName;
- @JsonProperty("processInstanceId")
- private int processInstanceId;
- @JsonProperty("processInstanceName")
- private String processInstanceName;
- @JsonProperty("state")
- private TaskExecutionStatus state;
- @JsonProperty("startTime")
- private Date startTime;
- @JsonProperty("endTime")
- private Date endTime;
- @JsonProperty("host")
- private String host;
- @JsonProperty("taskPriority")
- private String taskPriority;
- @JsonProperty("logPath")
- private String logPath;
-
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/ZookeeperRecord.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/ZookeeperRecord.java
deleted file mode 100644
index 4404b1da1e..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/ZookeeperRecord.java
+++ /dev/null
@@ -1,216 +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.dao.entity;
-
-import java.util.Date;
-
-/**
- * monitor record for zookeeper
- */
-public class ZookeeperRecord {
-
- /**
- * hostname
- */
- private String hostname;
-
- /**
- * connections
- */
- private int connections;
-
- /**
- * max connections
- */
- private int watches;
-
- /**
- * sent
- */
- private long sent;
-
- /**
- * received
- */
- private long received;
-
- /**
- * mode: leader or follower
- */
- private String mode;
-
- /**
- * min Latency
- */
- private float minLatency;
-
- /**
- * avg Latency
- */
- private float avgLatency;
-
- /**
- * max Latency
- */
- private float maxLatency;
-
- /**
- * node count
- */
- private int nodeCount;
-
- /**
- * date
- */
- private Date date;
-
- /**
- * is normal or not, 1:normal
- */
- private int state;
-
- public ZookeeperRecord(String hostname, int connections, int watches, long
sent, long received, String mode,
- float minLatency, float avgLatency, float
maxLatency, int nodeCount, int state, Date date) {
- this.hostname = hostname;
- this.connections = connections;
- this.watches = watches;
- this.sent = sent;
- this.received = received;
- this.mode = mode;
- this.minLatency = minLatency;
- this.avgLatency = avgLatency;
- this.maxLatency = maxLatency;
- this.nodeCount = nodeCount;
- this.state = state;
- this.date = date;
- }
-
- public String getHostname() {
- return hostname;
- }
-
- public void setHostname(String hostname) {
- this.hostname = hostname;
- }
-
- public int getConnections() {
- return connections;
- }
-
- public void setConnections(int connections) {
- this.connections = connections;
- }
-
- public int getWatches() {
- return watches;
- }
-
- public void setWatches(int watches) {
- this.watches = watches;
- }
-
- public long getSent() {
- return sent;
- }
-
- public void setSent(long sent) {
- this.sent = sent;
- }
-
- public long getReceived() {
- return received;
- }
-
- public void setReceived(long received) {
- this.received = received;
- }
-
- public String getMode() {
- return mode;
- }
-
- public void setMode(String mode) {
- this.mode = mode;
- }
-
- public float getMinLatency() {
- return minLatency;
- }
-
- public void setMinLatency(float minLatency) {
- this.minLatency = minLatency;
- }
-
- public float getAvgLatency() {
- return avgLatency;
- }
-
- public void setAvgLatency(float avgLatency) {
- this.avgLatency = avgLatency;
- }
-
- public float getMaxLatency() {
- return maxLatency;
- }
-
- public void setMaxLatency(int maxLatency) {
- this.maxLatency = maxLatency;
- }
-
- public int getNodeCount() {
- return nodeCount;
- }
-
- public void setNodeCount(int nodeCount) {
- this.nodeCount = nodeCount;
- }
-
- public int getState() {
- return state;
- }
-
- public void setState(int state) {
- this.state = state;
- }
-
- public Date getDate() {
- return date;
- }
-
- public void setDate(Date date) {
- this.date = date;
- }
-
- @Override
- public String toString() {
- return "ZookeeperRecord{" +
- "hostname='" + hostname + '\'' +
- ", connections=" + connections +
- ", watches=" + watches +
- ", sent=" + sent +
- ", received=" + received +
- ", mode='" + mode + '\'' +
- ", minLatency=" + minLatency +
- ", avgLatency=" + avgLatency +
- ", maxLatency=" + maxLatency +
- ", nodeCount=" + nodeCount +
- ", date=" + date +
- ", state=" + state +
- '}';
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/AbstractListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/AbstractListenerEvent.java
deleted file mode 100644
index c2e9501bd3..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/AbstractListenerEvent.java
+++ /dev/null
@@ -1,27 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-
-public interface AbstractListenerEvent {
-
- ListenerEventType getEventType();
-
- String getTitle();
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionCreatedListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionCreatedListenerEvent.java
deleted file mode 100644
index 9484ef78bb..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionCreatedListenerEvent.java
+++ /dev/null
@@ -1,195 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.Flag;
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.common.enums.ReleaseState;
-import org.apache.dolphinscheduler.common.enums.WorkflowExecutionTypeEnum;
-import org.apache.dolphinscheduler.dao.entity.TaskDefinitionLog;
-import org.apache.dolphinscheduler.dao.entity.WorkflowDefinition;
-import org.apache.dolphinscheduler.dao.entity.WorkflowTaskRelationLog;
-import org.apache.dolphinscheduler.plugin.task.api.model.Property;
-
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ProcessDefinitionCreatedListenerEvent implements
AbstractListenerEvent {
-
- /**
- * id
- */
- private Integer id;
-
- /**
- * code
- */
- private long code;
-
- /**
- * name
- */
- private String name;
-
- /**
- * version
- */
- private int version;
-
- /**
- * release state : online/offline
- */
- private ReleaseState releaseState;
-
- /**
- * project code
- */
- private long projectCode;
-
- /**
- * description
- */
- private String description;
-
- /**
- * user defined parameters
- */
- private String globalParams;
-
- /**
- * user defined parameter list
- */
- private List<Property> globalParamList;
-
- /**
- * user define parameter map
- */
- private Map<String, String> globalParamMap;
-
- /**
- * create time
- */
- private Date createTime;
-
- /**
- * update time
- */
- private Date updateTime;
-
- /**
- * process is valid: yes/no
- */
- private Flag flag;
-
- /**
- * process user id
- */
- private int userId;
-
- /**
- * create user name
- */
- private String userName;
-
- /**
- * project name
- */
- private String projectName;
-
- /**
- * locations array for web
- */
- private String locations;
-
- /**
- * schedule release state : online/offline
- */
- private ReleaseState scheduleReleaseState;
-
- /**
- * process warning time out. unit: minute
- */
- private int timeout;
-
- /**
- * modify user name
- */
- private String modifyBy;
-
- /**
- * warningGroupId
- */
- private Integer warningGroupId;
-
- /**
- * execution type
- */
- private WorkflowExecutionTypeEnum executionType;
-
- /**
- * task definitions
- */
- List<TaskDefinitionLog> taskDefinitionLogs;
-
- /**
- *
- */
- List<WorkflowTaskRelationLog> taskRelationList;
-
- public ProcessDefinitionCreatedListenerEvent(WorkflowDefinition
workflowDefinition) {
- this.setId(workflowDefinition.getId());
- this.setCode(workflowDefinition.getCode());
- this.setName(workflowDefinition.getName());
- this.setVersion(workflowDefinition.getVersion());
- this.setReleaseState(workflowDefinition.getReleaseState());
- this.setProjectCode(workflowDefinition.getProjectCode());
- this.setDescription(workflowDefinition.getDescription());
- this.setGlobalParams(workflowDefinition.getGlobalParams());
- this.setGlobalParamList(workflowDefinition.getGlobalParamList());
- this.setGlobalParamMap(workflowDefinition.getGlobalParamMap());
- this.setCreateTime(workflowDefinition.getCreateTime());
- this.setUpdateTime(workflowDefinition.getUpdateTime());
- this.setFlag(workflowDefinition.getFlag());
- this.setUserId(workflowDefinition.getUserId());
- this.setUserName(workflowDefinition.getUserName());
- this.setProjectName(workflowDefinition.getProjectName());
- this.setLocations(workflowDefinition.getLocations());
-
this.setScheduleReleaseState(workflowDefinition.getScheduleReleaseState());
- this.setTimeout(workflowDefinition.getTimeout());
- this.setModifyBy(workflowDefinition.getModifyBy());
- this.setWarningGroupId(workflowDefinition.getWarningGroupId());
- this.setExecutionType(workflowDefinition.getExecutionType());
- }
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.PROCESS_DEFINITION_CREATED;
- }
-
- @Override
- public String getTitle() {
- return String.format("process definition created:%s", this.name);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionDeletedListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionDeletedListenerEvent.java
deleted file mode 100644
index a42e81de68..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionDeletedListenerEvent.java
+++ /dev/null
@@ -1,52 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ProcessDefinitionDeletedListenerEvent implements
AbstractListenerEvent {
-
- private Integer projectId;
- private Long projectCode;
- private String projectName;
- private String owner;
- private Integer id;
- private Long code;
- private String name;
- private Integer userId;
- private String modifiedBy;
- private Date eventTime;
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.PROCESS_DEFINITION_DELETED;
- }
-
- @Override
- public String getTitle() {
- return String.format("process definition deleted:%s", this.name);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionUpdatedListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionUpdatedListenerEvent.java
deleted file mode 100644
index 48adbd9b4e..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessDefinitionUpdatedListenerEvent.java
+++ /dev/null
@@ -1,195 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.Flag;
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.common.enums.ReleaseState;
-import org.apache.dolphinscheduler.common.enums.WorkflowExecutionTypeEnum;
-import org.apache.dolphinscheduler.dao.entity.TaskDefinitionLog;
-import org.apache.dolphinscheduler.dao.entity.WorkflowDefinition;
-import org.apache.dolphinscheduler.dao.entity.WorkflowTaskRelationLog;
-import org.apache.dolphinscheduler.plugin.task.api.model.Property;
-
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ProcessDefinitionUpdatedListenerEvent implements
AbstractListenerEvent {
-
- /**
- * id
- */
- private Integer id;
-
- /**
- * code
- */
- private long code;
-
- /**
- * name
- */
- private String name;
-
- /**
- * version
- */
- private int version;
-
- /**
- * release state : online/offline
- */
- private ReleaseState releaseState;
-
- /**
- * project code
- */
- private long projectCode;
-
- /**
- * description
- */
- private String description;
-
- /**
- * user defined parameters
- */
- private String globalParams;
-
- /**
- * user defined parameter list
- */
- private List<Property> globalParamList;
-
- /**
- * user define parameter map
- */
- private Map<String, String> globalParamMap;
-
- /**
- * create time
- */
- private Date createTime;
-
- /**
- * update time
- */
- private Date updateTime;
-
- /**
- * process is valid: yes/no
- */
- private Flag flag;
-
- /**
- * process user id
- */
- private int userId;
-
- /**
- * create user name
- */
- private String userName;
-
- /**
- * project name
- */
- private String projectName;
-
- /**
- * locations array for web
- */
- private String locations;
-
- /**
- * schedule release state : online/offline
- */
- private ReleaseState scheduleReleaseState;
-
- /**
- * process warning time out. unit: minute
- */
- private int timeout;
-
- /**
- * modify user name
- */
- private String modifyBy;
-
- /**
- * warningGroupId
- */
- private Integer warningGroupId;
-
- /**
- * execution type
- */
- private WorkflowExecutionTypeEnum executionType;
-
- /**
- * task definitions
- */
- List<TaskDefinitionLog> taskDefinitionLogs;
-
- /**
- *
- */
- List<WorkflowTaskRelationLog> taskRelationList;
-
- public ProcessDefinitionUpdatedListenerEvent(WorkflowDefinition
workflowDefinition) {
- this.setId(workflowDefinition.getId());
- this.setCode(workflowDefinition.getCode());
- this.setName(workflowDefinition.getName());
- this.setVersion(workflowDefinition.getVersion());
- this.setReleaseState(workflowDefinition.getReleaseState());
- this.setProjectCode(workflowDefinition.getProjectCode());
- this.setDescription(workflowDefinition.getDescription());
- this.setGlobalParams(workflowDefinition.getGlobalParams());
- this.setGlobalParamList(workflowDefinition.getGlobalParamList());
- this.setGlobalParamMap(workflowDefinition.getGlobalParamMap());
- this.setCreateTime(workflowDefinition.getCreateTime());
- this.setUpdateTime(workflowDefinition.getUpdateTime());
- this.setFlag(workflowDefinition.getFlag());
- this.setUserId(workflowDefinition.getUserId());
- this.setUserName(workflowDefinition.getUserName());
- this.setProjectName(workflowDefinition.getProjectName());
- this.setLocations(workflowDefinition.getLocations());
-
this.setScheduleReleaseState(workflowDefinition.getScheduleReleaseState());
- this.setTimeout(workflowDefinition.getTimeout());
- this.setModifyBy(workflowDefinition.getModifyBy());
- this.setWarningGroupId(workflowDefinition.getWarningGroupId());
- this.setExecutionType(workflowDefinition.getExecutionType());
- }
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.PROCESS_DEFINITION_UPDATED;
- }
-
- @Override
- public String getTitle() {
- return String.format("process definition updated:%s", this.name);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessEndListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessEndListenerEvent.java
deleted file mode 100644
index 19ac3d824f..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessEndListenerEvent.java
+++ /dev/null
@@ -1,59 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.CommandType;
-import org.apache.dolphinscheduler.common.enums.Flag;
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.common.enums.WorkflowExecutionStatus;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ProcessEndListenerEvent implements AbstractListenerEvent {
-
- private Long projectCode;
- private String projectName;
- private String owner;
- private Integer processId;
- private Long processDefinitionCode;
- private String processName;
- private CommandType processType;
- private WorkflowExecutionStatus processState;
- private Flag recovery;
- private Integer runTimes;
- private Date processStartTime;
- private Date processEndTime;
- private String processHost;
-
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.PROCESS_END;
- }
-
- @Override
- public String getTitle() {
- return String.format("process end: %s", processName);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessFailListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessFailListenerEvent.java
deleted file mode 100644
index 6910347410..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessFailListenerEvent.java
+++ /dev/null
@@ -1,59 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.CommandType;
-import org.apache.dolphinscheduler.common.enums.Flag;
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.common.enums.WorkflowExecutionStatus;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ProcessFailListenerEvent implements AbstractListenerEvent {
-
- private Long projectCode;
- private String projectName;
- private String owner;
- private Integer processId;
- private Long processDefinitionCode;
- private String processName;
- private CommandType processType;
- private WorkflowExecutionStatus processState;
- private Flag recovery;
- private Integer runTimes;
- private Date processStartTime;
- private Date processEndTime;
- private String processHost;
-
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.PROCESS_FAIL;
- }
-
- @Override
- public String getTitle() {
- return String.format("process fail: %s", processName);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessStartListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessStartListenerEvent.java
deleted file mode 100644
index 3fc96ba32d..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ProcessStartListenerEvent.java
+++ /dev/null
@@ -1,58 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.CommandType;
-import org.apache.dolphinscheduler.common.enums.Flag;
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.common.enums.WorkflowExecutionStatus;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ProcessStartListenerEvent implements AbstractListenerEvent {
-
- private Long projectCode;
- private String projectName;
- private String owner;
- private Long processDefinitionCode;
- private String processDefinitionName;
- private Integer processId;
- private String processName;
- private CommandType processType;
- private WorkflowExecutionStatus processState;
- private Integer runTimes;
- private Flag recovery;
- private Date processStartTime;
-
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.PROCESS_START;
- }
-
- @Override
- public String getTitle() {
- return String.format("process start: %s", processName);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ServerDownListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ServerDownListenerEvent.java
deleted file mode 100644
index 5fdf475c54..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/ServerDownListenerEvent.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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ServerDownListenerEvent implements AbstractListenerEvent {
-
- private String type;
- private String host;
- private Date eventTime;
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.SERVER_DOWN;
- }
-
- @Override
- public String getTitle() {
- return String.format("%s server down: %s", type, host);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskEndListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskEndListenerEvent.java
deleted file mode 100644
index 2718d7ef0e..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskEndListenerEvent.java
+++ /dev/null
@@ -1,59 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.plugin.task.api.enums.TaskExecutionStatus;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class TaskEndListenerEvent implements AbstractListenerEvent {
-
- private long projectCode;
- private String projectName;
- private String owner;
- private long processId;
- private long processDefinitionCode;
- private String processName;
- private int taskInstanceId;
- private long taskCode;
- private String taskName;
- private String taskType;
- private TaskExecutionStatus taskState;
- private Date taskStartTime;
- private Date taskEndTime;
- private String taskHost;
- private String logPath;
-
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.TASK_END;
- }
-
- @Override
- public String getTitle() {
- return String.format("task end: %s", taskName);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskFailListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskFailListenerEvent.java
deleted file mode 100644
index a7c4117a70..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskFailListenerEvent.java
+++ /dev/null
@@ -1,59 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.plugin.task.api.enums.TaskExecutionStatus;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class TaskFailListenerEvent implements AbstractListenerEvent {
-
- private long projectCode;
- private String projectName;
- private String owner;
- private long processId;
- private long processDefinitionCode;
- private String processName;
- private int taskInstanceId;
- private long taskCode;
- private String taskName;
- private String taskType;
- private TaskExecutionStatus taskState;
- private Date taskStartTime;
- private Date taskEndTime;
- private String taskHost;
- private String logPath;
-
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.TASK_FAIL;
- }
-
- @Override
- public String getTitle() {
- return String.format("task fail: %s", taskName);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskStartListenerEvent.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskStartListenerEvent.java
deleted file mode 100644
index afd5cbff7e..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/event/TaskStartListenerEvent.java
+++ /dev/null
@@ -1,59 +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.dao.entity.event;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.plugin.task.api.enums.TaskExecutionStatus;
-
-import java.util.Date;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class TaskStartListenerEvent implements AbstractListenerEvent {
-
- private long projectCode;
- private String projectName;
- private String owner;
- private long processId;
- private long processDefinitionCode;
- private String processName;
- private int taskInstanceId;
- private long taskCode;
- private String taskName;
- private String taskType;
- private TaskExecutionStatus taskState;
- private Date taskStartTime;
- private Date taskEndTime;
- private String taskHost;
- private String logPath;
-
- @Override
- public ListenerEventType getEventType() {
- return ListenerEventType.TASK_START;
- }
-
- @Override
- public String getTitle() {
- return String.format("task start: %s", taskName);
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/K8sMapper.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/K8sMapper.java
deleted file mode 100644
index bcf617b988..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/K8sMapper.java
+++ /dev/null
@@ -1,29 +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.dao.mapper;
-
-import org.apache.dolphinscheduler.dao.entity.K8s;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-
-/**
- * k8s mapper interface
- */
-public interface K8sMapper extends BaseMapper<K8s> {
-
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/BaseDBPerformance.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/BaseDBPerformance.java
deleted file mode 100644
index 4ba722d245..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/BaseDBPerformance.java
+++ /dev/null
@@ -1,36 +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.dao.utils;
-
-import org.apache.dolphinscheduler.dao.entity.MonitorRecord;
-
-import java.sql.Connection;
-
-/**
- * db performance abstract class
- */
-public abstract class BaseDBPerformance {
-
- /**
- * return the current database performance
- * @param conn connection
- * @return MonitorRecord
- */
- protected abstract MonitorRecord getMonitorRecord(Connection conn);
-
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/BeanContext.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/BeanContext.java
deleted file mode 100644
index 78a333488c..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/BeanContext.java
+++ /dev/null
@@ -1,69 +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.dao.utils;
-
-import org.springframework.beans.BeansException;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ApplicationContextAware;
-import org.springframework.stereotype.Component;
-
-/**
- * bean context
- */
-@Component
-public class BeanContext implements ApplicationContextAware {
-
- private static ApplicationContext applicationContext;
-
- public static ApplicationContext getApplicationContext() {
- return applicationContext;
- }
-
- /**
- * get bean
- * @param name class name
- * @param <T> generic
- * @return target object
- * @throws BeansException if error throws BeansException
- */
- @SuppressWarnings("unchecked")
- public static <T> T getBean(String name) throws BeansException {
- return (T) applicationContext.getBean(name);
- }
-
- /**
- * get bean
- * @param clazz clazz
- * @param <T> generic
- * @return target object
- * @throws BeansException if error throws BeansException
- */
- public static <T> T getBean(Class<T> clazz) throws BeansException {
- return applicationContext.getBean(clazz);
- }
-
- /**
- * set applicationcontext
- * @param applicationContext applicationContext
- * @throws BeansException if error throws BeansException
- */
- @Override
- public void setApplicationContext(ApplicationContext applicationContext)
throws BeansException {
- BeanContext.applicationContext = applicationContext;
- }
-}
diff --git
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtils.java
b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtils.java
deleted file mode 100644
index 2377d92471..0000000000
---
a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtils.java
+++ /dev/null
@@ -1,100 +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.dao.utils;
-
-import org.apache.commons.collections4.CollectionUtils;
-
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-/**
- * resource process definition utils
- */
-public class ResourceProcessDefinitionUtils {
-
- /**
- * get resource process map key is resource id,value is the set of process
definition code
- *
- * @param resourceList the map key is process definition code and value is
resource_ids
- * @return resource process definition map (resourceId ->
processDefinitionCodes)
- */
- public static Map<Integer, Set<Long>>
getResourceProcessDefinitionMap(List<Map<String, Object>> resourceList) {
-
- // resourceId -> processDefinitionCodes
- Map<Integer, Set<Long>> resourceResult = new HashMap<>();
-
- if (CollectionUtils.isNotEmpty(resourceList)) {
- for (Map<String, Object> resourceMap : resourceList) {
- Long code = (Long) resourceMap.get("code");
- String[] resourceIds = ((String)
resourceMap.get("resource_ids"))
- .split(",");
-
- Set<Integer> resourceIdSet =
-
Arrays.stream(resourceIds).map(Integer::parseInt).collect(Collectors.toSet());
- for (Integer resourceId : resourceIdSet) {
- Set<Long> codeSet;
- if (resourceResult.containsKey(resourceId)) {
- codeSet = resourceResult.get(resourceId);
- } else {
- codeSet = new HashSet<>();
- }
- codeSet.add(code);
- resourceResult.put(resourceId, codeSet);
- }
-
- }
- }
-
- return resourceResult;
- }
-
- public static <T> Map<Integer, Set<T>>
getResourceObjectMap(List<Map<String, Object>> resourceList,
- String
objectName, Class<T> clazz) {
- // resourceId -> task ids or code depends on the objectName
- Map<Integer, Set<T>> resourceResult = new HashMap<>();
-
- if (CollectionUtils.isNotEmpty(resourceList)) {
- for (Map<String, Object> resourceMap : resourceList) {
- // get resName and resource_id_news, td_id
- T taskId = (T) resourceMap.get(objectName);
- String[] resourceIds = ((String)
resourceMap.get("resource_ids"))
- .split(",");
-
- Set<Integer> resourceIdSet =
-
Arrays.stream(resourceIds).map(Integer::parseInt).collect(Collectors.toSet());
- for (Integer resourceId : resourceIdSet) {
- Set<T> codeSet;
- if (resourceResult.containsKey(resourceId)) {
- codeSet = resourceResult.get(resourceId);
- } else {
- codeSet = new HashSet<>();
- }
- codeSet.add(taskId);
- resourceResult.put(resourceId, codeSet);
- }
- }
- }
-
- return resourceResult;
- }
-}
diff --git
a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/entity/WorkflowDefinitionCreatedListenerEventTest.java
b/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/entity/WorkflowDefinitionCreatedListenerEventTest.java
deleted file mode 100644
index c75700bb88..0000000000
---
a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/entity/WorkflowDefinitionCreatedListenerEventTest.java
+++ /dev/null
@@ -1,48 +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.dao.entity;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.common.enums.ReleaseState;
-import
org.apache.dolphinscheduler.dao.entity.event.ProcessDefinitionCreatedListenerEvent;
-
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Test;
-
-public class WorkflowDefinitionCreatedListenerEventTest {
-
- @Test
- public void testBuildProcessDefinitionUpdatedListenerEvent() {
- int id = 1;
- long code = 1L;
- String name = "testName";
- ReleaseState releaseState = ReleaseState.OFFLINE;
- WorkflowDefinition workflowDefinition = new WorkflowDefinition();
- workflowDefinition.setId(id);
- workflowDefinition.setCode(code);
- workflowDefinition.setName(name);
- workflowDefinition.setReleaseState(releaseState);
- ProcessDefinitionCreatedListenerEvent event = new
ProcessDefinitionCreatedListenerEvent(workflowDefinition);
- Assertions.assertEquals(event.getEventType(),
ListenerEventType.PROCESS_DEFINITION_CREATED);
- Assertions.assertEquals(event.getId(), id);
- Assertions.assertEquals(event.getCode(), code);
- Assertions.assertEquals(event.getName(), name);
- Assertions.assertEquals(event.getReleaseState(), releaseState);
- Assertions.assertEquals(String.format("process definition created:%s",
name), event.getTitle());
- }
-}
diff --git
a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/entity/WorkflowDefinitionUpdatedListenerEventTest.java
b/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/entity/WorkflowDefinitionUpdatedListenerEventTest.java
deleted file mode 100644
index 1a104ec5d3..0000000000
---
a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/entity/WorkflowDefinitionUpdatedListenerEventTest.java
+++ /dev/null
@@ -1,48 +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.dao.entity;
-
-import org.apache.dolphinscheduler.common.enums.ListenerEventType;
-import org.apache.dolphinscheduler.common.enums.ReleaseState;
-import
org.apache.dolphinscheduler.dao.entity.event.ProcessDefinitionUpdatedListenerEvent;
-
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Test;
-
-public class WorkflowDefinitionUpdatedListenerEventTest {
-
- @Test
- public void testBuildProcessDefinitionUpdatedListenerEvent() {
- int id = 1;
- long code = 1L;
- String name = "testName";
- ReleaseState releaseState = ReleaseState.OFFLINE;
- WorkflowDefinition workflowDefinition = new WorkflowDefinition();
- workflowDefinition.setId(id);
- workflowDefinition.setCode(code);
- workflowDefinition.setName(name);
- workflowDefinition.setReleaseState(releaseState);
- ProcessDefinitionUpdatedListenerEvent event = new
ProcessDefinitionUpdatedListenerEvent(workflowDefinition);
- Assertions.assertEquals(event.getEventType(),
ListenerEventType.PROCESS_DEFINITION_UPDATED);
- Assertions.assertEquals(event.getId(), id);
- Assertions.assertEquals(event.getCode(), code);
- Assertions.assertEquals(event.getName(), name);
- Assertions.assertEquals(event.getReleaseState(), releaseState);
- Assertions.assertEquals(String.format("process definition updated:%s",
name), event.getTitle());
- }
-}
diff --git
a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/ResourceWorkflowDefinitionUtilsTest.java
b/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/ResourceWorkflowDefinitionUtilsTest.java
deleted file mode 100644
index 0e1a8f0afb..0000000000
---
a/dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/ResourceWorkflowDefinitionUtilsTest.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.dao.utils;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Test;
-
-/**
- * resource process definition utils test
- */
-public class ResourceWorkflowDefinitionUtilsTest {
-
- @Test
- public void getResourceProcessDefinitionMapTest() {
- List<Map<String, Object>> mapList = new ArrayList<>();
- Map<String, Object> map = new HashMap<>();
- map.put("code", 1L);
- map.put("resource_ids", "1,2,3");
- mapList.add(map);
-
Assertions.assertNotNull(ResourceProcessDefinitionUtils.getResourceProcessDefinitionMap(mapList));
- }
-
-}
