One or more nodes have left the cluster while replicating command TxCompletionNotificationCommand

[tomas11]

Hello

Why this exception is happening - One or more nodes have left the cluster while replicating command TxCompletionNotificationCommand?

I come into this by using  @ViewChanged annotation. In this listener when some node leaves cluster a want to put new entry into the cache. And that exception happen.

I think it is because view of node which had left has not been replicated.

Can I know when replication (because of node which had left) is finished and I can do put into cache? Is there such Listener for that?

Thanks

[pruivo]

Hi tomas11,

you can use the @DataRehashed. it is triggered before and after the state transfer.

Cheers,

Pedro

[tomas11]

Hi Pedro

Thanks for suggestion. I've tried to use @DataRehashed annotation but it was not invoked during one of cluster member leave from cluster.

Do you have an idea why @DataRehashed is not working?

Thanks

[pruivo]

Hi tomas11,

Are you registering the notification in the cache object? E.g:

cache.addListener(new MyDataRehashListener());

Cheers,

Pedro

[tomas11]

Hi Pedro

That's true but this one not works for example in case that we have 2 nodes and numOwners=2.

When one of this two nodes leaves the cluster @DataRehashed won't happen and I am not notified about change. In that case @ViewChanged is fine but I get in troubles as mentioned above.

Tomas

[pruivo]

Hi Tomas,

you are right. the @DataRehashed is not invoked when the consistent hash is balanced (i.e. no data needs to be transferred between nodes).

can you try with @TopologyChanged? the method will be invoked with TopologyChangedEvent<K,V> and you have access to the old and new consistent hash.

Note: the event can be triggered multiple times and the consistent hash can contain exactly the same members. this happens when only the routing table is changed.

Let me know if works.

Cheers,

Pedro

[tomas11]

Hi Pedro

Sorry for late answer. But issue is still there. I am still getting exception

org.infinispan.remoting.transport.jgroups.SuspectException: One or more nodes have left the cluster while replicating command TxCompletionNotificationCommand

when I am trying to put something into cache in @TopologyChanged listener.

I am still missing an option how can I put something into cache while replication is not finished (e.g. when some node leave cluster).

Any idea will be appreciated.

Thanks