You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2024/03/24 03:23:02 UTC
(incubator-streampark) 01/01: [Improve] update guava.version to 33.1.0
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 <be...@gmail.com>
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
}
}