diff --git a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/FlinkK8sWatchController.scala b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/FlinkK8sWatchController.scala index 01e67def03..162fca88cc 100644 --- a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/FlinkK8sWatchController.scala +++ b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/FlinkK8sWatchController.scala @@ -228,7 +228,11 @@ object K8sDeploymentEventCache { class MetricCache { private[this] lazy val cache: Cache[ClusterKey, FlinkMetricCV] = - Caffeine.newBuilder().build() + Caffeine + .newBuilder() + .expireAfterWrite(6, TimeUnit.HOURS) + .maximumSize(10_000) + .build() def put(k: ClusterKey, v: FlinkMetricCV): Unit = cache.put(k, v)