This is an automated email from the ASF dual-hosted git repository. mpochatkin pushed a commit to branch IGNITE-22577 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit c37445ecc36ee625f870f615726b280faf15ebc1 Author: Mikhail Pochatkin <[email protected]> AuthorDate: Wed Aug 28 15:25:59 2024 +0300 IGNITE-22577 Enable compute tests --- .../ignite/internal/compute/ItComputeTestEmbedded.java | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItComputeTestEmbedded.java b/modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItComputeTestEmbedded.java index 790372d40b..81f5636974 100644 --- a/modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItComputeTestEmbedded.java +++ b/modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItComputeTestEmbedded.java @@ -65,7 +65,6 @@ import org.apache.ignite.lang.IgniteException; import org.apache.ignite.network.ClusterNode; import org.apache.ignite.table.KeyValueView; import org.apache.ignite.table.Table; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.Arguments; @@ -86,7 +85,7 @@ class ItComputeTestEmbedded extends ItComputeBaseTest { void cancelsJobLocally() { Ignite entryNode = node(0); - JobDescriptor job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); + JobDescriptor<CountDownLatch, String> job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); JobExecution<String> execution = entryNode.compute().submit(JobTarget.node(clusterNode(entryNode)), job, new CountDownLatch(1)); await().until(execution::stateAsync, willBe(jobStateWithStatus(EXECUTING))); @@ -102,7 +101,7 @@ class ItComputeTestEmbedded extends ItComputeBaseTest { var nodes = JobTarget.node(clusterNode(entryNode)); CountDownLatch countDownLatch = new CountDownLatch(1); - JobDescriptor job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); + JobDescriptor<CountDownLatch, String> job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); // Start 1 task in executor with 1 thread JobExecution<String> execution1 = entryNode.compute().submit(nodes, job, countDownLatch); @@ -126,11 +125,10 @@ class ItComputeTestEmbedded extends ItComputeBaseTest { } @Test - @Disabled("https://issues.apache.org/jira/browse/IGNITE-22577";) void cancelsJobRemotely() { Ignite entryNode = node(0); - JobDescriptor job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); + JobDescriptor<CountDownLatch, String> job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); JobExecution<String> execution = entryNode.compute().submit(JobTarget.node(clusterNode(node(1))), job, new CountDownLatch(1)); await().until(execution::stateAsync, willBe(jobStateWithStatus(EXECUTING))); @@ -144,7 +142,7 @@ class ItComputeTestEmbedded extends ItComputeBaseTest { void changeExecutingJobPriorityLocally() { Ignite entryNode = node(0); - JobDescriptor job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); + JobDescriptor<CountDownLatch, String> job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); JobExecution<String> execution = entryNode.compute().submit(JobTarget.node(clusterNode(entryNode)), job, new CountDownLatch(1)); await().until(execution::stateAsync, willBe(jobStateWithStatus(EXECUTING))); @@ -153,11 +151,10 @@ class ItComputeTestEmbedded extends ItComputeBaseTest { } @Test - @Disabled("https://issues.apache.org/jira/browse/IGNITE-22577";) void changeExecutingJobPriorityRemotely() { Ignite entryNode = node(0); - JobDescriptor job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); + JobDescriptor<CountDownLatch, String> job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); JobExecution<String> execution = entryNode.compute().submit(JobTarget.node(clusterNode(node(1))), job, new CountDownLatch(1)); await().until(execution::stateAsync, willBe(jobStateWithStatus(EXECUTING))); @@ -171,7 +168,7 @@ class ItComputeTestEmbedded extends ItComputeBaseTest { JobTarget jobTarget = JobTarget.node(clusterNode(entryNode)); CountDownLatch countDownLatch = new CountDownLatch(1); - JobDescriptor job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); + JobDescriptor<CountDownLatch, String> job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); // Start 1 task in executor with 1 thread JobExecution<String> execution1 = entryNode.compute().submit(jobTarget, job, countDownLatch); @@ -212,7 +209,7 @@ class ItComputeTestEmbedded extends ItComputeBaseTest { JobTarget jobTarget = JobTarget.node(clusterNode(entryNode)); CountDownLatch countDownLatch = new CountDownLatch(1); - JobDescriptor job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); + JobDescriptor<CountDownLatch, String> job = JobDescriptor.builder(WaitLatchJob.class).units(units()).build(); // Start 1 task in executor with 1 thread JobExecution<String> execution1 = entryNode.compute().submit(jobTarget, job, countDownLatch);
