This is an automated email from the ASF dual-hosted git repository.
guanhuali pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/master by this push:
new 6a388a9b54 [MINOR] Fix log message in YarnAppMonitor (#4695)
6a388a9b54 is described below
commit 6a388a9b5474adc1bd15690850403d368a758ec6
Author: Cheng Pan <[email protected]>
AuthorDate: Sun Nov 19 08:45:50 2023 -0600
[MINOR] Fix log message in YarnAppMonitor (#4695)
---
.../src/main/java/org/apache/zeppelin/interpreter/YarnAppMonitor.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/YarnAppMonitor.java
b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/YarnAppMonitor.java
index 270539841b..598c69e2ab 100644
---
a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/YarnAppMonitor.java
+++
b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/YarnAppMonitor.java
@@ -82,11 +82,11 @@ public class YarnAppMonitor {
String yarnDiagnostics = appReport.getDiagnostics();
interpreterManagedProcess.processStopped("Yarn
diagnostics: " + yarnDiagnostics);
iter.remove();
- LOGGER.info("Remove {} from YarnAppMonitor, because its
state is {}", appId ,
+ LOGGER.info("Remove {} from YarnAppMonitor, because its
state is {}", appId,
appReport.getYarnApplicationState());
} else if (appReport.getYarnApplicationState() ==
YarnApplicationState.FINISHED) {
iter.remove();
- LOGGER.info("Remove {} from YarnAppMonitor, because its
state is ", appId,
+ LOGGER.info("Remove {} from YarnAppMonitor, because its
state is {}", appId,
appReport.getYarnApplicationState());
}
}