[jira] [Updated] (IGNITE-25640) Cancelled compute task status is FAILED

[Pavel Tupitsyn (Jira)]

     [ 
https://issues.apache.org/jira/browse/IGNITE-25640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pavel Tupitsyn updated IGNITE-25640:
------------------------------------
    Description: 
The following test fails (add to *ItThinClientComputeTest*):

{code:java}
    @Test
    void cancelComputeSubmitMapReduceAsyncWithCancelHandle() {
        IgniteClient entryNode = client();

        CancelHandle cancelHandle = CancelHandle.create();

        TaskExecution<Void> taskExec = entryNode.compute()
                
.submitMapReduce(TaskDescriptor.builder(InfiniteMapReduceTask.class).build(), 
null, cancelHandle.token());

        cancelHandle.cancel();

        assertThrows(ExecutionException.class, () -> 
taskExec.resultAsync().get(10, TimeUnit.SECONDS));

        TaskState taskState = taskExec.stateAsync().join();
        assertThat(taskState, is(taskStateWithStatus(TaskStatus.CANCELED)));
    }
{code}

Result:

{code}
java.lang.AssertionError: 
Expected: is a TaskState with status <CANCELED>, create time not null, start 
time anything and finish time anything
     but: status was <FAILED>, create time was <2025-06-10T16:06:15.701692Z>, 
start time was <2025-06-10T16:06:15.703917Z> and finish time was 
<2025-06-10T16:06:15.745732Z>
{code}

  was:
The following test fails:

{code:java}
    @Test
    void cancelComputeSubmitMapReduceAsyncWithCancelHandle() {
        IgniteClient entryNode = client();

        CancelHandle cancelHandle = CancelHandle.create();

        TaskExecution<Void> taskExec = entryNode.compute()
                
.submitMapReduce(TaskDescriptor.builder(InfiniteMapReduceTask.class).build(), 
null, cancelHandle.token());

        cancelHandle.cancel();

        assertThrows(ExecutionException.class, () -> 
taskExec.resultAsync().get(10, TimeUnit.SECONDS));

        TaskState taskState = taskExec.stateAsync().join();
        assertThat(taskState, is(taskStateWithStatus(TaskStatus.CANCELED)));
    }
{code}

Result:

{code}
java.lang.AssertionError: 
Expected: is a TaskState with status <CANCELED>, create time not null, start 
time anything and finish time anything
     but: status was <FAILED>, create time was <2025-06-10T16:06:15.701692Z>, 
start time was <2025-06-10T16:06:15.703917Z> and finish time was 
<2025-06-10T16:06:15.745732Z>
{code}


> Cancelled compute task status is FAILED
> ---------------------------------------
>
>                 Key: IGNITE-25640
>                 URL: https://issues.apache.org/jira/browse/IGNITE-25640
>             Project: Ignite
>          Issue Type: Bug
>          Components: compute ai3
>            Reporter: Pavel Tupitsyn
>            Priority: Major
>              Labels: ignite-3
>             Fix For: 3.1
>
>
> The following test fails (add to *ItThinClientComputeTest*):
> {code:java}
>     @Test
>     void cancelComputeSubmitMapReduceAsyncWithCancelHandle() {
>         IgniteClient entryNode = client();
>         CancelHandle cancelHandle = CancelHandle.create();
>         TaskExecution<Void> taskExec = entryNode.compute()
>                 
> .submitMapReduce(TaskDescriptor.builder(InfiniteMapReduceTask.class).build(), 
> null, cancelHandle.token());
>         cancelHandle.cancel();
>         assertThrows(ExecutionException.class, () -> 
> taskExec.resultAsync().get(10, TimeUnit.SECONDS));
>         TaskState taskState = taskExec.stateAsync().join();
>         assertThat(taskState, is(taskStateWithStatus(TaskStatus.CANCELED)));
>     }
> {code}
> Result:
> {code}
> java.lang.AssertionError: 
> Expected: is a TaskState with status <CANCELED>, create time not null, start 
> time anything and finish time anything
>      but: status was <FAILED>, create time was <2025-06-10T16:06:15.701692Z>, 
> start time was <2025-06-10T16:06:15.703917Z> and finish time was 
> <2025-06-10T16:06:15.745732Z>
> {code}



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