This is an automated email from the ASF dual-hosted git repository.
chufenggao 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 0d2ea3e27b Fix worker failover service comment (#14494)
0d2ea3e27b is described below
commit 0d2ea3e27b892f1e8b65dc02644810b0b72f9c64
Author: Eric Gao <[email protected]>
AuthorDate: Mon Jul 10 15:54:06 2023 +0800
Fix worker failover service comment (#14494)
---
.../dolphinscheduler/server/master/service/WorkerFailoverService.java | 2 --
1 file changed, 2 deletions(-)
diff --git
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/WorkerFailoverService.java
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/WorkerFailoverService.java
index 144eaa3d26..8b8160dba4 100644
---
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/WorkerFailoverService.java
+++
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/WorkerFailoverService.java
@@ -208,13 +208,11 @@ public class WorkerFailoverService {
@Nullable ProcessInstance
processInstance,
TaskInstance taskInstance) {
if (processInstance == null) {
- // This case should be happened.
log.error(
"Failover task instance error, cannot find the related
processInstance form memory, this case shouldn't happened");
return false;
}
if (taskInstance == null) {
- // This case should be happened.
log.error("Master failover task instance error, taskInstance is
null, this case shouldn't happened");
return false;
}