File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/metrics Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change 5252import static org .apache .flink .kubernetes .operator .metrics .KubernetesClientMetrics .KUBE_CLIENT_GROUP ;
5353import static org .apache .flink .kubernetes .operator .metrics .KubernetesClientMetrics .METER ;
5454import static org .assertj .core .api .Assertions .assertThat ;
55+ import static org .assertj .core .api .Assertions .byLessThan ;
5556import static org .assertj .core .api .InstanceOfAssertFactories .LONG ;
5657import static org .awaitility .Awaitility .await ;
5758import static org .junit .jupiter .api .Assertions .assertFalse ;
@@ -356,17 +357,20 @@ void testAPIServerIsDown() {
356357 }
357358
358359 private static void assertRateIsZero (TestingMetricListener listener , String meterId ) {
359- assertPositiveRate (listener , meterId , meter -> assertThat (meter .getRate ()).isEqualTo (0.0 ));
360+ assertRate (
361+ listener ,
362+ meterId ,
363+ meter -> assertThat (meter .getRate ()).isCloseTo (0.0 , byLessThan (0.00001 )));
360364 }
361365
362366 private static void assertPositiveRate (TestingMetricListener listener , String meterId ) {
363- assertPositiveRate (
367+ assertRate (
364368 listener ,
365369 meterId ,
366370 meter -> assertThat (meter .getRate ()).isGreaterThanOrEqualTo (0.01 ));
367371 }
368372
369- private static void assertPositiveRate (
373+ private static void assertRate (
370374 TestingMetricListener listener , String meterId , Consumer <Meter > meterConsumer ) {
371375 assertThat (listener .getMeter (listener .getMetricId (meterId )))
372376 .hasValueSatisfying (meterConsumer );
You can’t perform that action at this time.
0 commit comments