hazelcast 分区没有所有者异常

Question

当我尝试向 hazelcast 主题发送消息时，出现以下异常。使用 hazelcast 客户端连接 hazelcast 节点 (hazelcast 3.6)

有什么想法这可能是什么吗？它几乎是我正在使用的基本开箱即用服务器和客户端配置。

Caused by: java.util.concurrent.ExecutionException: com.hazelcast.client.HazelcastClientNotActiveException: Partition does not have owner. partitionId : 25
    at com.hazelcast.client.spi.impl.ClientInvocationFuture.resolveResponse(ClientInvocationFuture.java:146)
    at com.hazelcast.client.spi.impl.ClientInvocationFuture.get(ClientInvocationFuture.java:100)
    at com.hazelcast.client.util.ClientDelegatingFuture.get(ClientDelegatingFuture.java:118)
    at com.hazelcast.client.util.ClientDelegatingFuture.get(ClientDelegatingFuture.java:105)
    at com.hazelcast.client.proxy.ClientReliableTopicProxy.addWithBackoff(ClientReliableTopicProxy.java:128)
    at com.hazelcast.client.proxy.ClientReliableTopicProxy.publish(ClientReliableTopicProxy.java:102)
    ... 10 more

Caused by: com.hazelcast.client.HazelcastClientNotActiveException: Partition does not have owner. partitionId : 25
    at com.hazelcast.client.spi.impl.ClientInvocation.notifyException(ClientInvocation.java:180)
    at com.hazelcast.client.spi.impl.ClientInvocation.invoke(ClientInvocation.java:137)
    at com.hazelcast.client.proxy.ClientRingbufferProxy.addAsync(ClientRingbufferProxy.java:163)
    at com.hazelcast.client.proxy.ClientReliableTopicProxy.addWithBackoff(ClientReliableTopicProxy.java:128)
    at com.hazelcast.client.proxy.ClientReliableTopicProxy.publish(ClientReliableTopicProxy.java:102)
    at com.rbccm.sabre.dataloader.infra.msg.hazelcast.HzTopicPublisher.publish(HzTopicPublisher.java:34)
    at com.rbccm.sabre.dataloader.infra.monitor.MonitorMessagePublisher.publishExpectedFiles(MonitorMessagePublisher.java:21)
    at com.rbccm.sabre.dataloader.infra.DefaultLoadSequence.execute(DefaultLoadSequence.java:41)
    at com.rbccm.sabre.dataloader.DataLoaderServiceImpl.load(DataLoaderServiceImpl.java:30)
    at com.rbccm.sabre.dataloader.controller.DataLoaderController.load(DataLoaderController.java:80)
    at com.rbccm.sabre.dataloader.controller.ControllerRequestConsumer.consume(ControllerRequestConsumer.java:51)
    at com.rbccm.processmanager.common.pubsub.ProcessEventQueueHandler$1.run(ProcessEventQueueHandler.java:52)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
    at java.lang.Thread.run(Unknown Source)
    at ------ End remote and begin local stack-trace ------.(Unknown Source)
    at com.hazelcast.client.spi.impl.ClientInvocationFuture.resolveResponse(ClientInvocationFuture.java:133)
    ... 15 more

Answer 1

HazelcastClientNotActiveException 表明客户端在尝试获取分区表以发送主题消息时已关闭。您需要关注客户决定关闭的原因。