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
commit 3b88e60a44d135cb6a53bbb8a20dff25b2aa67c6 Author: benjobs <[email protected]> AuthorDate: Sun Mar 24 11:22:48 2024 +0800 [Improve] update guava.version to 33.1.0 --- pom.xml | 2 +- .../streampark/console/core/service/impl/ApplicationServiceImpl.java | 4 ++-- .../org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pom.xml b/pom.xml index d943496a4..7d0fb5601 100644 --- a/pom.xml +++ b/pom.xml @@ -109,7 +109,7 @@ <logback.version>1.2.11</logback.version> <grpc.version>1.15.0</grpc.version> <jackson.version>2.13.5</jackson.version> - <guava.version>30.0-jre</guava.version> + <guava.version>33.1.0-jre</guava.version> <caffeine.version>2.8.6</caffeine.version> <mysql.version>8.0.27</mysql.version> <hikariCP.version>3.4.5</hikariCP.version> 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 9f6eaac73..2c4010d38 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,8 +1948,8 @@ 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."); + log.error("Failed to connect hadoop YARN, detail: {}", Utils.stringifyException(e)); + throw new RuntimeException("Failed to connect hadoop YARN. Ensure that hadoop yarn is running."); } } diff --git a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala index fac9213b6..f57060795 100644 --- a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala +++ b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala @@ -130,7 +130,7 @@ object KubernetesRetriever extends Logger { |error: $e |""".stripMargin ) - false + true } }
