You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by we...@apache.org on 2022/08/31 07:25:09 UTC
[dolphinscheduler] branch dev updated (5fabce783a -> 03e1e6fe45)
This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
from 5fabce783a [DOC] improve zk digest doc (#11703)
add 03e1e6fe45 [Bug] [Worker] Optimize the getAppId method to avoid worker OOM when kill task (#11701)
No new revisions were added by this update.
Summary of changes:
.../dolphinscheduler/common/utils/LoggerUtils.java | 47 ++++----------
.../server/log/LoggerRequestProcessor.java | 12 ++++
.../remote/command/CommandType.java | 27 +-------
...estCommand.java => GetAppIdRequestCommand.java} | 20 ++----
...seCommand.java => GetAppIdResponseCommand.java} | 20 ++----
.../dolphinscheduler/rpc/remote/NettyClient.java | 2 +-
.../server/utils/ProcessUtils.java | 35 ++++------
.../service/log/LogClientService.java | 31 ++++++++-
.../plugin/task/api/AbstractCommandExecutor.java | 19 ++----
.../plugin/task/api/utils/LogUtils.java | 75 ++++++++++++++++++++++
.../{RetryUtilsTest.java => LogUtilsTest.java} | 25 ++++----
.../src/test/resources/appId.txt | 29 +++++++++
.../server/worker/config/WorkerConfig.java | 2 +-
.../server/worker/processor/TaskKillProcessor.java | 48 +++++++-------
.../server/worker/rpc/WorkerRpcServer.java | 1 +
15 files changed, 229 insertions(+), 164 deletions(-)
copy dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/log/{ViewLogRequestCommand.java => GetAppIdRequestCommand.java} (82%)
copy dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/log/{RemoveTaskLogResponseCommand.java => GetAppIdResponseCommand.java} (80%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/utils/LogUtils.java
copy dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/plugin/task/api/utils/{RetryUtilsTest.java => LogUtilsTest.java} (66%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/resources/appId.txt