You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Igor (Jira)" <ji...@apache.org> on 2024/04/22 12:53:00 UTC

[jira] [Created] (IGNITE-22088) retryPolicy of IgniteClient doesn't work on transaction fail

Igor created IGNITE-22088:
-----------------------------

             Summary: retryPolicy of IgniteClient doesn't work on transaction fail
                 Key: IGNITE-22088
                 URL: https://issues.apache.org/jira/browse/IGNITE-22088
             Project: Ignite
          Issue Type: Bug
          Components: clients, thin client
    Affects Versions: 3.0.0-beta1
            Reporter: Igor


*Details:*
IgniteClient do not run retry with set retryPolicy on transaction lock. The default retry policy also doesn't work. The debugging also shows that no any code inside `RetryReadPolicy` is not used during transaction lock exception.


*Steps to reproduce:*

Run the next code:
{code:java}
AtomicInteger retriesCount = new AtomicInteger(0);

RetryReadPolicy retry = new RetryReadPolicy() {
    @Override
    public boolean shouldRetry(RetryPolicyContext context) {
        System.out.println("CHECK IF RETRY SHOULD HAPPEN");
        retriesCount.addAndGet(1);
        return super.shouldRetry(context);
    }
};

try (IgniteClient igniteClient1 = IgniteClient.builder().retryPolicy(retry).addresses("localhost:10800").build();
        IgniteClient igniteClient2 = IgniteClient.builder().addresses("localhost:10800").build()) {

    igniteClient1.sql().execute(null, "CREATE TABLE teachers(id INTEGER PRIMARY KEY, name VARCHAR(200))");

    Transaction tr1 = igniteClient1.transactions().begin();
    Transaction tr2 = igniteClient2.transactions().begin();

    igniteClient1.sql().execute(tr1, "INSERT INTO TEACHERS (id, name) VALUES (" + 3 + ", '" + "Pavel" + "')");

    SqlException exception = assertThrows(SqlException.class, () -> igniteClient2.sql().execute(tr2, "SELECT * FROM teachers"));

    assertTrue(exception.getMessage().contains("Failed to acquire a lock due to a possible deadlock "));
}

assertEquals(16, retriesCount.get()); {code}
*Expected:*
Executed without errors.

*Actual:*
Fails on the last step expected 16 retries, actual 0.



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