[jira] [Created] (IGNITE-27180) Java thin. Partition awareness request fails with connection refused after node shutdown gracefully

[Pavel Pereslegin (Jira)]

Pavel Pereslegin created IGNITE-27180:
-----------------------------------------

             Summary: Java thin. Partition awareness request fails with 
connection refused after node shutdown gracefully
                 Key: IGNITE-27180
                 URL: https://issues.apache.org/jira/browse/IGNITE-27180
             Project: Ignite
          Issue Type: Bug
          Components: platforms ai3
            Reporter: Pavel Pereslegin


h4. Scenario:

1. Thin client connected to 3 nodes
2. Run partition aware request
3. Stop one node gacefully
4. Ensure connections count = 2
5. Run partition aware request

h4. Expected:

Partition aware request completed successfully.
(but since the primary node has left, it can be sent to a random alive node).

h4. Actual:

Request fails with "Connection refused":

{noformat}
org.apache.ignite.client.IgniteClientConnectionException: IGN-CLIENT-1 Client 
failed to connect: Connection refused: /127.0.0.1:10800 
[endpoint=127.0.0.1:10800]
 TraceId:e1bfd0dd
  at 
java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:710)
  at 
org.apache.ignite.internal.util.ExceptionUtils$1.copy(ExceptionUtils.java:952)
  at 
org.apache.ignite.internal.util.ExceptionUtils$ExceptionFactory.createCopy(ExceptionUtils.java:886)
  at 
org.apache.ignite.internal.util.ExceptionUtils.copyExceptionWithCause(ExceptionUtils.java:688)
  at 
org.apache.ignite.internal.util.ViewUtils.copyExceptionWithCauseIfPossible(ViewUtils.java:91)
  at 
org.apache.ignite.internal.util.ViewUtils.ensurePublicException(ViewUtils.java:71)
  at org.apache.ignite.internal.util.ViewUtils.sync(ViewUtils.java:54)
  at 
org.apache.ignite.internal.client.table.ClientKeyValueView.put(ClientKeyValueView.java:270)
  at 
org.apache.ignite.internal.client.table.api.PublicApiClientKeyValueView.lambda$put$12(PublicApiClientKeyValueView.java:113)
  at 
org.apache.ignite.internal.thread.PublicApiThreading.lambda$execUserSyncOperation$1(PublicApiThreading.java:116)
  at 
org.apache.ignite.internal.thread.PublicApiThreading.executeWithRole(PublicApiThreading.java:144)
  at 
org.apache.ignite.internal.thread.PublicApiThreading.execUserSyncOperation(PublicApiThreading.java:102)
  at 
org.apache.ignite.internal.thread.PublicApiThreading.execUserSyncOperation(PublicApiThreading.java:115)
  at 
org.apache.ignite.internal.client.table.api.PublicApiClientViewBase.executeSyncOp(PublicApiClientViewBase.java:105)
  at 
org.apache.ignite.internal.client.table.api.PublicApiClientKeyValueView.put(PublicApiClientKeyValueView.java:113)
  at 
org.apache.ignite.internal.runner.app.client.ItThinConnectionFailoverTest.testStopNodePartitionAwarenessKeyValue(ItThinConnectionFailoverTest.java:49)
{noformat}

h4. Reproducer:

{code:java}
public class ItThinConnectionFailoverTest extends ClusterPerTestIntegrationTest 
{
    @Override
    protected int initialNodes() {
        return 0;
    }

    @Test
    void testStopNodePartitionAwarenessKeyValue() {
        int nodesCount = 3;
        long reconnectInterval = 1000;
        cluster.startAndInit(nodesCount, new int[]{2});

        String[] addresses = IntStream.range(0, nodesCount)
                .mapToObj(i -> "127.0.0.1:" + (10800 + i))
                .toArray(String[]::new);

        try (IgniteClient client = IgniteClient.builder()
                .backgroundReconnectInterval(reconnectInterval)
                .addresses(addresses).build()) {

            client.sql().executeScript("CREATE ZONE zone1 (REPLICAS 3) STORAGE 
PROFILES ['default'];"
                    + "CREATE TABLE t(id INT PRIMARY KEY, val INT) ZONE zone1");

            Awaitility.await().until(() -> client.connections().size(), is(3));

            KeyValueView<Integer, Integer> kvView = client.tables().table("t")
                    .keyValueView(Integer.class, Integer.class);

            for (int i = 0; i < 100; i++) {
                kvView.put(null, i, i);
            }

            cluster.stopNode(0);
            assertThat(client.connections().size(), is(2));

            for (int i = 100; i < 200; i++) {
                kvView.put(null, i, i);
            }
        }
    }
}
{code}

Note: this also affects SQL.please check related TODOs in the code (if exist)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)