[IGNITE-13719] Thin client silently closes channel after inactivity

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.9
• Fix Version/s: 2.10, 2.9.1
• Release Note: Java thin: fix unexpected channel close due to inactivity
• Ignite Flags: Docs Required, Release Notes Required
• Assignee: Aleksey Plekhanov
• Reporter: jifwin
• Created: 18/Nov/20 09:58
• Updated: 02/Dec/20 19:42
• Resolved: 19/Nov/20 13:51

Description

The following code works fine with ignite-core 2.8.0, but fails with 2.9.0 (see the exception below). It looks like timeout is applied to client receiver thread. When it's not used for a while it gets closed silently. 

public class IgniteDemo
{
    public static final int TIMEOUT = 1000;

    public static void main(String[] args) throws InterruptedException
    {
        new IgniteDemo().run();
    }

    public void run() throws InterruptedException
    {
        final Ignite igniteServer = Ignition.start();

        final ClientConfiguration cfg = new ClientConfiguration().setAddresses("127.0.0.1:10800");
        cfg.setTimeout(TIMEOUT);
        final IgniteClient igniteClient = Ignition.startClient(cfg);
        final ClientCache<Object, Object> cache = igniteClient.getOrCreateCache("test");

        Thread.sleep(TIMEOUT);
        cache.put(1, 1);

        Thread.sleep(TIMEOUT);
        cache.put(2, 2);
    }
}

 
Exception in thread "main" org.apache.ignite.client.ClientConnectionException: Channel is closedException in thread "main" org.apache.ignite.client.ClientConnectionException: Channel is closed at org.apache.ignite.internal.client.thin.TcpClientChannel.send(TcpClientChannel.java:236) at org.apache.ignite.internal.client.thin.TcpClientChannel.service(TcpClientChannel.java:217) at org.apache.ignite.internal.client.thin.ReliableChannel.service(ReliableChannel.java:198) at org.apache.ignite.internal.client.thin.ReliableChannel.affinityService(ReliableChannel.java:261) at org.apache.ignite.internal.client.thin.TcpClientCache.cacheSingleKeyOperation(TcpClientCache.java:508) at org.apache.ignite.internal.client.thin.TcpClientCache.put(TcpClientCache.java:127) at IgniteDemo.run(IgniteDemo.java:26) at IgniteDemo.main(IgniteDemo.java:13)

Issue Links

• is blocked by: IGNITE-13496 Java thin: Use non-blocking socket IO
• links to: GitHub Pull Request #8480
• links to: TC thin client