Hi We are on ignite 1.5.0-final and are recently facing this issue from the
client side broadcaasting a job to a random remote server node. how can we
avoid this and what is causing this?
We can 20 parallel clients for load testing, and 15 completed with no
issues, 5 got stuck here.
code that calls the below and hangs from client side, it hangs at this line
serverCompute.broadcast(new OrderHolderSaveRunnable(ignite,
orderHolderList));
public Boolean processOrderHolders(List<OrderHolder> orderHolderList)
throws Exception {
ClusterGroup serverGroup =
ignite.cluster().forServers().forRandom();
IgniteCompute serverCompute = ignite.compute(serverGroup);
try {
serverCompute.broadcast(new
OrderHolderSaveRunnable(ignite,
orderHolderList));
} catch(Exception e) {
logger.error(e,e);
throw e;
}
return true;
}
Thread dump
Name: main
State: WAITING on
org.apache.ignite.internal.ComputeTaskInternalFuture@3fd1be52
Total blocked: 5 Total waited: 5,975
Stack trace:
sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:157)
org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:115)
org.apache.ignite.internal.AsyncSupportAdapter.saveOrGet(AsyncSupportAdapter.java:112)
org.apache.ignite.internal.IgniteComputeImpl.broadcast(IgniteComputeImpl.java:250)
com.tudor.datagridI.client.TradeOrderStoreHelper.processOrderHolders(TradeOrderStoreHelper.java:37)
com.tudor.datagridI.TradingDataAccessImpl.saveOrders(TradingDataAccessImpl.java:399)
orderserver.client.GridClient.updateOrderHoldersInGrid(GridClient.java:138)
orderserver.Order.save(Order.java:3619)
- locked orderserver.Order@732871ce
orderserver.Order.save(Order.java:3563)
- locked orderserver.Order@732871ce
izi.izi_data_grid_ignite_test.OrderBooker.bookRegularOrder(OrderBooker.java:111)
izi.izi_data_grid_ignite_test.OrderBooker.bookOrder(OrderBooker.java:33)
izi.izi_data_grid_ignite_test.Main.bookOrders(Main.java:47)
izi.izi_data_grid_ignite_test.Main.runExc(Main.java:83)
izi.izi_data_grid_ignite_test.Main.run(Main.java:35)
izi.izi_data_grid_ignite_test.Runner.run(Runner.java:37)
izi.izi_data_grid_ignite_test.Runner.main(Runner.java:17)
Any help is greatly appreciated.
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/IgniteCompute-broadcast-stuck-tp7255.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
