sun.misc.Unsafe.park(Native Method)

[bandaru...@gaiansolutions.com]

[SpringBoot Application] I am trying to delete a key from Hazelcast Map from a async Method. Inside the Delete Method of MapStore class i am trying to put that key into a topic and calling Publish(). But sometimes i am getting this error sun.misc.Unsafe.park(Native Method).  I am adding the stack trace below. 

sun.misc.Unsafe.park(Native Method)

java.util.concurrent.locks.LockSupport.park(LockSupport.java:304)

com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:160)

com.hazelcast.client.spi.ClientProxy.invokeOnPartition(ClientProxy.java:225)

com.hazelcast.client.proxy.PartitionSpecificClientProxy.invokeOnPartition(PartitionSpecificClientProxy.java:49)

com.hazelcast.client.proxy.ClientTopicProxy.publish(ClientTopicProxy.java:52)

com.gaian.adwize.cache.mapstore.CampaignMapStore.delete(CampaignMapStore.java:95)

com.gaian.adwize.cache.mapstore.CampaignMapStore.delete(CampaignMapStore.java:36)

com.hazelcast.map.impl.MapStoreWrapper.delete(MapStoreWrapper.java:115)

com.hazelcast.map.impl.mapstore.writethrough.WriteThroughStore.remove(WriteThroughStore.java:56)

com.hazelcast.map.impl.mapstore.writethrough.WriteThroughStore.remove(WriteThroughStore.java:28)

com.hazelcast.map.impl.recordstore.DefaultRecordStore.delete(DefaultRecordStore.java:565)

com.hazelcast.map.impl.operation.DeleteOperation.run(DeleteOperation.java:38)

com.hazelcast.spi.Operation.call(Operation.java:148)

com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:202)

com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:191)

com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:406)

com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:433)

com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:581)

com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:566)

com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:525)

com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:215)

com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:60)

com.hazelcast.client.impl.protocol.task.AbstractPartitionMessageTask.processMessage(AbstractPartitionMessageTask.java:67)

com.hazelcast.client.impl.protocol.task.AbstractMessageTask.initializeAndProcessMessage(AbstractMessageTask.java:130)

com.hazelcast.client.impl.protocol.task.AbstractMessageTask.run(AbstractMessageTask.java:110)

com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:155)

com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:125)

com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.run(OperationThread.java:100)

[bandaru...@gaiansolutions.com]

Any help from the community members will be really helpful. Thanks. 

[Lukáš Herman]

Hi,

you are trying to invoke operation on the same partition thread, which is calling delete, so it results in deadlock. It is generally bad idea to call any Hazelcast API from inside MapStore. Redesign your solution.

regards

LH 

Dne úterý 26. března 2019 13:35:14 UTC+1 bandar...@gaiansolutions.com napsal(a):