[flink] 03/09: [hotfix] Remove akka dependency in MetricUtilsTest

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit ae85de7fa7f06b3d3751405d1fe0b57b448ca7f4
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Thu Jul 1 10:15:54 2021 +0200

    [hotfix] Remove akka dependency in MetricUtilsTest
---
 .../apache/flink/runtime/metrics/util/MetricUtilsTest.java   | 12 +-----------
 1 file changed, 1 insertion(+), 11 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java
index 8f387e8..e3cc553 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java
@@ -28,7 +28,6 @@ import org.apache.flink.runtime.memory.MemoryManager;
 import org.apache.flink.runtime.metrics.MetricNames;
 import org.apache.flink.runtime.rpc.RpcService;
 import org.apache.flink.runtime.rpc.RpcSystem;
-import org.apache.flink.runtime.rpc.akka.AkkaRpcService;
 import org.apache.flink.runtime.taskexecutor.TaskManagerServices;
 import org.apache.flink.runtime.taskexecutor.TaskManagerServicesBuilder;
 import org.apache.flink.runtime.taskexecutor.slot.TestingTaskSlotTable;
@@ -40,7 +39,6 @@ import org.apache.flink.util.function.CheckedSupplier;
 
 import org.apache.flink.shaded.guava18.com.google.common.collect.Sets;
 
-import akka.actor.ActorSystem;
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Assume;
@@ -54,7 +52,6 @@ import java.util.List;
 import static 
org.apache.flink.runtime.metrics.util.MetricUtils.METRIC_GROUP_FLINK;
 import static 
org.apache.flink.runtime.metrics.util.MetricUtils.METRIC_GROUP_MANAGED_MEMORY;
 import static 
org.apache.flink.runtime.metrics.util.MetricUtils.METRIC_GROUP_MEMORY;
-import static org.hamcrest.CoreMatchers.instanceOf;
 import static org.hamcrest.Matchers.is;
 import static org.junit.Assert.assertThat;
 
@@ -83,17 +80,10 @@ public class MetricUtilsTest extends TestLogger {
         final RpcService rpcService =
                 MetricUtils.startRemoteMetricsRpcService(
                         configuration, "localhost", RpcSystem.load());
-        assertThat(rpcService, instanceOf(AkkaRpcService.class));
-
-        final ActorSystem actorSystem = ((AkkaRpcService) 
rpcService).getActorSystem();
 
         try {
             final int threadPriority =
-                    actorSystem
-                            .settings()
-                            .config()
-                            
.getInt("akka.actor.default-dispatcher.thread-priority");
-
+                    rpcService.execute(() -> 
Thread.currentThread().getPriority()).get();
             assertThat(threadPriority, is(expectedThreadPriority));
         } finally {
             rpcService.stopService().get();