This is an automated email from the ASF dual-hosted git repository.
xincheng 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 5c569b705c [fix-15907] Fix get remote shell exit code is incorrect
(#15911)
5c569b705c is described below
commit 5c569b705cad84be0b017dc94dfdd979318e3279
Author: Zzih96 <[email protected]>
AuthorDate: Thu May 9 14:15:06 2024 +0800
[fix-15907] Fix get remote shell exit code is incorrect (#15911)
* ./mvnw spotless:apply
* Update
dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java
Co-authored-by: Wenjun Ruan <[email protected]>
---------
Co-authored-by: 詹子恒 <[email protected]>
Co-authored-by: Wenjun Ruan <[email protected]>
Co-authored-by: Rick Cheng <[email protected]>
---
.../apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java
index 307023043a..814826a6bb 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java
@@ -131,7 +131,7 @@ public class RemoteExecutor implements AutoCloseable {
int exitCode = -1;
log.info("Remote shell task run status: {}", logLine);
if (logLine.contains(STATUS_TAG_MESSAGE)) {
- String status = logLine.replace(STATUS_TAG_MESSAGE, "").trim();
+ String status = StringUtils.substringAfter(logLine,
STATUS_TAG_MESSAGE);
if (status.equals("0")) {
log.info("Remote shell task success");
exitCode = 0;
