This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.4
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.4 by this push:
new fb35ec938 [Improve] add yarn api error log for debug some problems
(#3622)
fb35ec938 is described below
commit fb35ec938230bc6b7dd73d1a807b41c3baf08d90
Author: ouyangwulin <[email protected]>
AuthorDate: Fri Mar 22 14:26:50 2024 +0800
[Improve] add yarn api error log for debug some problems (#3622)
Co-authored-by: [email protected] <[email protected]>
---
.../streampark/console/core/service/impl/ApplicationServiceImpl.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
index 384bbd292..9f6eaac73 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
@@ -1948,6 +1948,7 @@ public class ApplicationServiceImpl extends
ServiceImpl<ApplicationMapper, Appli
.filter(report -> report.getName().equals(appName))
.collect(Collectors.toList());
} catch (Exception e) {
+ log.error(Utils.stringifyException(e));
throw new RuntimeException("The yarn api is abnormal. Ensure that yarn
is running properly.");
}
}