Amelchev Nikita created IGNITE-17503:
----------------------------------------
Summary: Transmission sender fails if receiver's pool is busy.
Key: IGNITE-17503
URL: https://issues.apache.org/jira/browse/IGNITE-17503
Project: Ignite
Issue Type: Bug
Reporter: Amelchev Nikita
Reproducer:
{noformat}
// do as much as a pool size.
rcv.getExecutorService().submit(() -> doSleep(10000));
try (TransmissionSender sender = openTransmissionSender(rcvNodeId)) {
sender.send(file1); // throws SocketTimeoutException
}
{noformat}
Exception:
{noformat}
java.net.SocketTimeoutException: null
at
sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:211)
~[?:1.8.0_201]
at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
~[?:1.8.0_201]
at
java.io.ObjectInputStream$PeekInputStream.read(ObjectInputStream.java:2663)
~[?:1.8.0_201]
at
java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2679)
~[?:1.8.0_201]
at
java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:3156)
~[?:1.8.0_201]
at
java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:862)
~[?:1.8.0_201]
at java.io.ObjectInputStream.<init>(ObjectInputStream.java:358)
~[?:1.8.0_201]
at
org.apache.ignite.internal.managers.communication.GridIoManager$TransmissionSender.connect(GridIoManager.java:3262)
~[classes/:?]
at
org.apache.ignite.internal.managers.communication.GridIoManager$TransmissionSender.send(GridIoManager.java:3350)
[classes/:?]
at
org.apache.ignite.internal.managers.communication.GridIoManager$TransmissionSender.send(GridIoManager.java:3288)
[classes/:?]
at
org.apache.ignite.internal.managers.communication.GridIoManagerFileTransmissionSelfTest.testSendToBusy(GridIoManagerFileTransmissionSelfTest.java:967)
[test-classes/:?]
{noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
