[hotfix] Fix testfail due to data race with after migration to Fabric8 interceptor

Author: aplyusnin

flink-autoscaler/src/test/java/org/apache/flink/autoscaler/RestApiMetricsCollectorTest.java

@@ -160,6 +160,7 @@ public void testJmMetricCollection() throws Exception {
                             (c, e) ->
                                     new StandaloneClientHAServices(
                                             miniCluster.getRestAddress().get().toString()));
+            Thread.sleep(500);
             do {
                 var collector = new RestApiMetricsCollector<>();
                 Map<FlinkMetric, Metric> flinkMetricMetricMap =

flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/metrics/KubernetesClientMetricsTest.java

@@ -99,7 +99,7 @@ public class KubernetesClientMetricsTest {
 
     @Test
     @Order(1)
-    public void testMetricsDisabled() {
+    public void testMetricsDisabled() throws Exception {
         var configuration = new Configuration();
         configuration.set(
                 KubernetesOperatorMetricOptions.OPERATOR_KUBERNETES_CLIENT_METRICS_ENABLED, false);
@@ -112,6 +112,7 @@ public void testMetricsDisabled() {
 
         var deployment = TestUtils.buildApplicationCluster();
         kubernetesClient.resource(deployment).get();
+        Thread.sleep(500);
         assertFalse(listener.getCounter(listener.getMetricId(REQUEST_COUNTER_ID)).isPresent());
         assertFalse(listener.getMeter(listener.getMetricId(REQUEST_METER_ID)).isPresent());
         assertFalse(
@@ -125,7 +126,7 @@ public void testMetricsDisabled() {
 
     @Test
     @Order(2)
-    public void testMetricsEnabled() {
+    public void testMetricsEnabled() throws Exception {
         var configuration = new Configuration();
         var listener = new TestingMetricListener(configuration);
         var kubernetesClient =
@@ -165,6 +166,7 @@ public void testMetricsEnabled() {
                         .getMax());
 
         kubernetesClient.resource(deployment).createOrReplace();
+        Thread.sleep(500);
         assertEquals(
                 1, listener.getCounter(listener.getMetricId(REQUEST_COUNTER_ID)).get().getCount());
         assertEquals(
@@ -193,13 +195,15 @@ public void testMetricsEnabled() {
                         > 0);
 
         kubernetesClient.resource(deployment).delete();
+        Thread.sleep(500);
         assertEquals(
                 1,
                 listener.getCounter(listener.getMetricId(REQUEST_DELETE_COUNTER_ID))
                         .get()
                         .getCount());
 
         kubernetesClient.resource(deployment).delete();
+        Thread.sleep(500);
         assertEquals(
                 2,
                 listener.getCounter(listener.getMetricId(REQUEST_DELETE_COUNTER_ID))
@@ -304,7 +308,7 @@ public void onDelete(
 
     @Test
     @Order(3)
-    public void testMetricsHttpResponseCodeGroupsEnabled() {
+    public void testMetricsHttpResponseCodeGroupsEnabled() throws Exception {
         var configuration = new Configuration();
         configuration.set(
                 KubernetesOperatorMetricOptions
@@ -348,6 +352,7 @@ public void testMetricsHttpResponseCodeGroupsEnabled() {
                         .getMax());
 
         kubernetesClient.resource(deployment).createOrReplace();
+        Thread.sleep(500);
         assertEquals(
                 1, listener.getCounter(listener.getMetricId(REQUEST_COUNTER_ID)).get().getCount());
         assertEquals(
@@ -381,13 +386,15 @@ public void testMetricsHttpResponseCodeGroupsEnabled() {
                         > 0);
 
         kubernetesClient.resource(deployment).delete();
+        Thread.sleep(500);
         assertEquals(
                 1,
                 listener.getCounter(listener.getMetricId(REQUEST_DELETE_COUNTER_ID))
                         .get()
                         .getCount());
 
         kubernetesClient.resource(deployment).delete();
+        Thread.sleep(500);
         assertEquals(
                 2,
                 listener.getCounter(listener.getMetricId(REQUEST_DELETE_COUNTER_ID))