Vertx内置ClusterHealthCheck过程阻止Vertx线程

Question

我在健康检查中使用ClusterHealthCheck过程，并且在日志中看到Vertx Thread被阻止的异常。我需要将健康检查作为阻塞代码执行吗？

下面是我用来创建健康检查的代码，

Handler<Promise<Status>> procedure = ClusterHealthCheck.createProcedure(vertx);
HealthChecks checks = HealthChecks.create(vertx).register("cluster-health", procedure);

低于例外

23:00:18.396 [vertx-blocked-thread-checker] WARN  io.vertx.core.impl.BlockedThreadChecker - tx.id= Thread Thread[vert.x-eventloop-thread-1,5,main] has been blocked for 5194 ms, time limit is 2000 ms
io.vertx.core.VertxException: Thread blocked
    at sun.misc.Unsafe.park(Native Method) ~[?:1.8.0_292]
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:304) ~[?:1.8.0_292]
    at com.hazelcast.spi.impl.AbstractInvocationFuture.joinInternal(AbstractInvocationFuture.java:575) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.internal.partition.impl.PartitionReplicaStateChecker.hasOnGoingMigrationMaster(PartitionReplicaStateChecker.java:309) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.internal.partition.impl.PartitionReplicaStateChecker.getPartitionServiceState(PartitionReplicaStateChecker.java:93) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.internal.partition.impl.InternalPartitionServiceImpl.isMemberStateSafe(InternalPartitionServiceImpl.java:929) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.internal.partition.operation.SafeStateCheckOperation.run(SafeStateCheckOperation.java:38) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:184) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:227) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:216) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:406) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:433) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:596) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:581) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:540) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:237) ~[app.jar:1.0.0-SNAPSHOT]
    at com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl.invokeOnTarget(OperationServiceImpl.java:343) ~[app.jar:1.0.0-SNAPSHOT]

我查看了ClusterHealthCheck类，它看起来很简单，从集群管理器获取分区服务并获取集群状态，但不确定为什么需要5秒钟以上才能完成。

我使用的是vertx 4.0.3、hazelcast 4.0.2，应用程序在K8s中运行。

Answer 1

该问题已在Vert. x 4.1.1中修复。

如果节点状况不佳（例如内存不足），则可能会阻止该操作。