[
https://issues.apache.org/jira/browse/IGNITE-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evgeny Stanilovsky updated IGNITE-23696:
----------------------------------------
Description:
Results of below test must not depend on execution node, but they depend:
place near test into ItComputeBaseTest:
{code:java}
@ParameterizedTest(name = "local: {0}")
@ValueSource(booleans = {true, false})
void cancelComputeSubmitWithCancelHandle(boolean local) {
Ignite entryNode = node(0);
Ignite executeNode = local ? node(0) : node(1);
JobDescriptor<Long, Void> job =
JobDescriptor.builder(SilentSleepJob.class).units(units()).build();
JobExecution<Void> execution =
entryNode.compute().submit(JobTarget.node(clusterNode(executeNode)), job, null);
IgniteTestUtils.await(execution.cancelAsync());
assertThat(execution.stateAsync(),
willBe(jobStateWithStatus(CANCELED)));
assertThat(execution.resultAsync(), willBe(nullValue()));
}
{code}
{code:java}
package org.apache.ignite.internal.compute;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CountDownLatch;
import org.apache.ignite.compute.ComputeJob;
import org.apache.ignite.compute.JobExecutionContext;
public class SilentSleepJob implements ComputeJob<Long, Void> {
@Override
public CompletableFuture<Void> executeAsync(JobExecutionContext
jobExecutionContext, Long timeout) {
try {
new CountDownLatch(1).await();
} catch (InterruptedException e) {
// no op.
}
return null;
}
}
{code}
was:
Results of near test must not depend on execution node, but they depend:
place near test into ItComputeBaseTest:
{code:java}
@ParameterizedTest(name = "local: {0}")
@ValueSource(booleans = {true, false})
void cancelComputeSubmitWithCancelHandle(boolean local) {
Ignite entryNode = node(0);
Ignite executeNode = local ? node(0) : node(1);
JobDescriptor<Long, Void> job =
JobDescriptor.builder(SilentSleepJob.class).units(units()).build();
JobExecution<Void> execution =
entryNode.compute().submit(JobTarget.node(clusterNode(executeNode)), job, null);
IgniteTestUtils.await(execution.cancelAsync());
assertThat(execution.stateAsync(),
willBe(jobStateWithStatus(CANCELED)));
assertThat(execution.resultAsync(), willBe(nullValue()));
}
{code}
{code:java}
package org.apache.ignite.internal.compute;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CountDownLatch;
import org.apache.ignite.compute.ComputeJob;
import org.apache.ignite.compute.JobExecutionContext;
public class SilentSleepJob implements ComputeJob<Long, Void> {
@Override
public CompletableFuture<Void> executeAsync(JobExecutionContext
jobExecutionContext, Long timeout) {
try {
new CountDownLatch(1).await();
} catch (InterruptedException e) {
// no op.
}
return null;
}
}
{code}
> Ignite compute, different return result for local and remote execution node
> ---------------------------------------------------------------------------
>
> Key: IGNITE-23696
> URL: https://issues.apache.org/jira/browse/IGNITE-23696
> Project: Ignite
> Issue Type: Bug
> Components: compute
> Affects Versions: 3.0.0-beta1
> Reporter: Evgeny Stanilovsky
> Priority: Major
> Labels: ignite-3
>
> Results of below test must not depend on execution node, but they depend:
> place near test into ItComputeBaseTest:
> {code:java}
> @ParameterizedTest(name = "local: {0}")
> @ValueSource(booleans = {true, false})
> void cancelComputeSubmitWithCancelHandle(boolean local) {
> Ignite entryNode = node(0);
> Ignite executeNode = local ? node(0) : node(1);
> JobDescriptor<Long, Void> job =
> JobDescriptor.builder(SilentSleepJob.class).units(units()).build();
> JobExecution<Void> execution =
> entryNode.compute().submit(JobTarget.node(clusterNode(executeNode)), job,
> null);
> IgniteTestUtils.await(execution.cancelAsync());
> assertThat(execution.stateAsync(),
> willBe(jobStateWithStatus(CANCELED)));
> assertThat(execution.resultAsync(), willBe(nullValue()));
> }
> {code}
> {code:java}
> package org.apache.ignite.internal.compute;
> import java.util.concurrent.CompletableFuture;
> import java.util.concurrent.CountDownLatch;
> import org.apache.ignite.compute.ComputeJob;
> import org.apache.ignite.compute.JobExecutionContext;
> public class SilentSleepJob implements ComputeJob<Long, Void> {
> @Override
> public CompletableFuture<Void> executeAsync(JobExecutionContext
> jobExecutionContext, Long timeout) {
> try {
> new CountDownLatch(1).await();
> } catch (InterruptedException e) {
> // no op.
> }
> return null;
> }
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
