[
https://issues.apache.org/jira/browse/IGNITE-27180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Sapego updated IGNITE-27180:
---------------------------------
Summary: Java Client: Partition awareness request fails with "connection
refused" after node shutdown gracefully (was: Java thin. Partition awareness
request fails with "connection refused" after node shutdown gracefully)
> Java Client: 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, thin clients ai3
> Reporter: Pavel Pereslegin
> Assignee: Pavel Tupitsyn
> Priority: Major
> Labels: ignite-3
> Attachments: ItThinConnectionFailoverTest.java
>
>
> 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;
> 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()
> .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); // fails with "Connection refused"
> }
> }
> }
> }
> {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)
