diff --git a/spark-operator/src/test/java/org/apache/spark/k8s/operator/metrics/source/KubernetesMetricsInterceptorTest.java b/spark-operator/src/test/java/org/apache/spark/k8s/operator/metrics/source/KubernetesMetricsInterceptorTest.java index 9cf56812..3ad89fc0 100644 --- a/spark-operator/src/test/java/org/apache/spark/k8s/operator/metrics/source/KubernetesMetricsInterceptorTest.java +++ b/spark-operator/src/test/java/org/apache/spark/k8s/operator/metrics/source/KubernetesMetricsInterceptorTest.java @@ -97,6 +97,7 @@ void testMetricsEnabled() { Meter metric = (Meter) metrics2.get(name); Assertions.assertEquals(metric.getCount(), 1); }); + Assertions.assertEquals(((Meter) metrics2.get("http.request")).getCount(), 2); client.resource(sparkApplication).delete(); } } @@ -122,6 +123,7 @@ void testWhenKubernetesServerNotWorking() { Assertions.assertEquals(12, map.size()); Meter metric = (Meter) map.get("failed"); Assertions.assertEquals(metric.getCount(), retry + 1); + Assertions.assertEquals(((Meter) map.get("http.request")).getCount(), retry + 1); } }