Hi igniters!

I've a little problem as indicated in the subject: Failed to process
selector key

*Ignite version*: 2.14.0

*Node configuration*: 2 Nodes running on same PC (IPV4) using localhost and
255 available ports:

TcpDiscoveryMulticastIpFinder ipFinder = new TcpDiscoveryMulticastIpFinder();
    ipFinder.setAddresses(Collections.singletonList("127.0.0.1"));

Also 2 different working dirs, Threadpool 16, 2 caches (one atomic, one
transactional)

*What happens*: Using ExecutorService i submit 8 threads to pool. Class run
correctly (4 on each node) and execute tasks as expected.

But during execution raise, repeatedly and with some frequency, the
following exception on both nodes: GRAVE: "Failed to process selector key".

*The application generates a high computational load. A simple "for loop"
with a sleep gives no error*

Full stack follows:

GRAVE: Failed to process selector key [ses=GridSelectorNioSessionImpl
[worker=DirectNioClientWorker [super=AbstractNioClientWorker [idx=3,
bytesRcvd=97567668, bytesSent=100128669, bytesRcvd0=0, bytesSent0=0,
select=true, super=GridWorker [name=grid-nio-worker-tcp-comm-3,
igniteInstanceName=TcpCommunicationSpi, finished=false,
heartbeatTs=1675265761563, hashCode=2143442267, interrupted=false,
runner=grid-nio-worker-tcp-comm-3-#26%TcpCommunicationSpi%]]],
writeBuf=java.nio.DirectByteBuffer[pos=0 lim=32768 cap=32768],
readBuf=java.nio.DirectByteBuffer[pos=0 lim=32768 cap=32768],
inRecovery=GridNioRecoveryDescriptor [acked=1690656, resendCnt=0,
rcvCnt=1696452, sentCnt=1691375, reserved=true, lastAck=1696448,
nodeLeft=false, node=TcpDiscoveryNode
[id=cd1ffdf0-b9b3-49ef-a9e3-db1676fad428,
consistentId=0:0:0:0:0:0:0:1,127.0.0.1,192.168.178.30,192.168.56.1:47500,
addrs=ArrayList [0:0:0:0:0:0:0:1, 127.0.0.1, 192.168.178.30,
192.168.56.1], sockAddrs=HashSet
[host.docker.internal/192.168.178.30:47500, /0:0:0:0:0:0:0:1:47500,
WOPR/192.168.56.1:47500, /127.0.0.1:47500], discPort=47500, order=1,
intOrder=1, lastExchangeTime=1675265584899, loc=false,
ver=2.14.0#20220929-sha1:951e8deb, isClient=false], connected=true,
connectCnt=69, queueLimit=4096, reserveCnt=101,
pairedConnections=false], outRecovery=GridNioRecoveryDescriptor
[acked=1690656, resendCnt=0, rcvCnt=1696452, sentCnt=1691375,
reserved=true, lastAck=1696448, nodeLeft=false, node=TcpDiscoveryNode
[id=cd1ffdf0-b9b3-49ef-a9e3-db1676fad428,
consistentId=0:0:0:0:0:0:0:1,127.0.0.1,192.168.178.30,192.168.56.1:47500,
addrs=ArrayList [0:0:0:0:0:0:0:1, 127.0.0.1, 192.168.178.30,
192.168.56.1], sockAddrs=HashSet
[host.docker.internal/192.168.178.30:47500, /0:0:0:0:0:0:0:1:47500,
WOPR/192.168.56.1:47500, /127.0.0.1:47500], discPort=47500, order=1,
intOrder=1, lastExchangeTime=1675265584899, loc=false,
ver=2.14.0#20220929-sha1:951e8deb, isClient=false], connected=true,
connectCnt=69, queueLimit=4096, reserveCnt=101,
pairedConnections=false], closeSocket=true,
outboundMessagesQueueSizeMetric=o.a.i.i.processors.metric.impl.LongAdderMetric@69a257d1,
super=GridNioSessionImpl [locAddr=/0:0:0:0:0:0:0:1:47101,
rmtAddr=/0:0:0:0:0:0:0:1:56361, createTime=1675265760336, closeTime=0,
bytesSent=8479762, bytesRcvd=7459908, bytesSent0=0, bytesRcvd0=0,
sndSchedTime=1675265760336, lastSndTime=1675265761545,
lastRcvTime=1675265761563, readsPaused=false,
filterChain=FilterChain[filters=[GridNioCodecFilter
[parser=o.a.i.i.util.nio.GridDirectParser@b329ba4, directMode=true],
GridConnectionBytesVerifyFilter], accepted=true,
markedForClose=true]]]
java.io.IOException: Connessione in corso interrotta forzatamente
dall'host remoto
        at java.base/sun.nio.ch.SocketDispatcher.write0(Native Method)
        at java.base/sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:51)
        at java.base/sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:113)
        at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:58)
        at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:50)
        at 
java.base/sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:466)
        at 
org.apache.ignite.internal.util.nio.GridNioServer$DirectNioClientWorker.processWrite0(GridNioServer.java:1715)
        at 
org.apache.ignite.internal.util.nio.GridNioServer$DirectNioClientWorker.processWrite(GridNioServer.java:1407)
        at 
org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2511)
        at 
org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.bodyInternal(GridNioServer.java:2273)
        at 
org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.body(GridNioServer.java:1910)
        at 
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:125)
        at java.base/java.lang.Thread.run(Thread.java:834)
Expected: I read that it could be a configuration problem but I don't
understand how to fix it.

The configuration seems simple but and even if the execution is without
calculation errors i would like to avoid this exception.

Any ideas?

Thanks for support!

Paolo

Reply via email to