|
|
@ -25,7 +25,7 @@ import org.apache.dolphinscheduler.common.utils.LoggerUtils; |
|
|
|
import org.apache.dolphinscheduler.plugin.task.api.ProcessUtils; |
|
|
|
import org.apache.dolphinscheduler.plugin.task.api.ProcessUtils; |
|
|
|
import org.apache.dolphinscheduler.plugin.task.api.TaskExecutionContext; |
|
|
|
import org.apache.dolphinscheduler.plugin.task.api.TaskExecutionContext; |
|
|
|
import org.apache.dolphinscheduler.plugin.task.api.TaskExecutionContextCacheManager; |
|
|
|
import org.apache.dolphinscheduler.plugin.task.api.TaskExecutionContextCacheManager; |
|
|
|
import org.apache.dolphinscheduler.server.worker.prc.WorkerRpcServer; |
|
|
|
import org.apache.dolphinscheduler.server.worker.rpc.WorkerRpcServer; |
|
|
|
import org.apache.dolphinscheduler.server.worker.registry.WorkerRegistryClient; |
|
|
|
import org.apache.dolphinscheduler.server.worker.registry.WorkerRegistryClient; |
|
|
|
import org.apache.dolphinscheduler.server.worker.runner.RetryReportTaskStatusThread; |
|
|
|
import org.apache.dolphinscheduler.server.worker.runner.RetryReportTaskStatusThread; |
|
|
|
import org.apache.dolphinscheduler.server.worker.runner.WorkerManagerThread; |
|
|
|
import org.apache.dolphinscheduler.server.worker.runner.WorkerManagerThread; |
|
|
|