This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dependency
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dependency by this push:
new 010188067 minor improvement
010188067 is described below
commit 010188067f8e563fb1b5a544bae199cbdabb7668
Author: benjobs <[email protected]>
AuthorDate: Fri Aug 4 18:33:59 2023 +0800
minor improvement
---
.../flink/kubernetes/v2/observer/RawClusterObserver.scala | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/main/scala/org/apache/streampark/flink/kubernetes/v2/observer/RawClusterObserver.scala
b/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/main/scala/org/apache/streampark/flink/kubernetes/v2/observer/RawClusterObserver.scala
index 26993e042..d4a7e12b7 100644
---
a/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/main/scala/org/apache/streampark/flink/kubernetes/v2/observer/RawClusterObserver.scala
+++
b/streampark-flink/streampark-flink-kubernetes-v2/streampark-flink-kubernetes-core/src/main/scala/org/apache/streampark/flink/kubernetes/v2/observer/RawClusterObserver.scala
@@ -98,15 +98,15 @@ case class RawClusterObserver(
.map { case (clusterOv, jmConfigs) =>
val totalJmMemory = FlinkMemorySizeParser
.parse(jmConfigs.getOrElse("jobmanager.memory.process.size", "0b"))
- .map(x => Try(x.mebiBytes).getOrElse(0))
+ .map(_.mebiBytes)
+ .map(e => Try(e.toInt).getOrElse(0))
.getOrElse(0)
- .toInt
val totalTmMemory = FlinkMemorySizeParser
.parse(jmConfigs.getOrElse("taskmanager.memory.process.size", "0b"))
- .map(x => Try(x.mebiBytes * clusterOv.taskManagers).getOrElse(0))
+ .map(_.mebiBytes * clusterOv.taskManagers)
+ .map(e => Try(e.toInt).getOrElse(0))
.getOrElse(0)
- .toInt
ClusterMetrics(
totalJmMemory = totalJmMemory,
