hazelcast bölümü bir sahibi istisna

Question

Bir hazelcast konuya mesaj göndermek çalıştığımda aşağıdaki özel durum alıyorum yoktur. Bir hazelcast düğüme bir hazelcast istemcisi Kullanma (hazelcast 3.6) Bunun ne olabileceği konusunda

herhangi bir düşünce? Bu oldukça kullanıyorum kutu sunucusu ve istemci yapılandırması bir temel.

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 bir konu mesaj göndermek için bir bölüm tablo almaya çalışırken istemci kapandı düşündürmektedir. Müşterinin neden kapanmaya karar verdiğine odaklanmalısınız.