(ignite-3) branch main updated: IGNITE-22577 Enable compute tests (#4298)

[mpochatkin]

This is an automated email from the ASF dual-hosted git repository.

mpochatkin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 8e90307a50 IGNITE-22577 Enable compute tests (#4298)
8e90307a50 is described below

commit 8e90307a50872d548c4d56941fc5d7b495954516
Author: Mikhail <pochat...@users.noreply.github.com>
AuthorDate: Mon Sep 16 14:23:49 2024 +0300

    IGNITE-22577 Enable compute tests (#4298)
---
 .../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);