Skip to content

Commit

Permalink
IGNITE-49 Fixed tests.
Browse files Browse the repository at this point in the history
  • Loading branch information
niktikhonov committed Jan 21, 2015
1 parent e7e87fe commit 88d705d
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 224 deletions.
Expand Up @@ -90,20 +90,20 @@ protected void processTest(IgniteDeploymentMode depMode) throws Throwable {
ignite1.compute().localDeployTask(loadTaskClass(), loadTaskClass().getClassLoader());
ignite2.compute().localDeployTask(loadTaskClass(), loadTaskClass().getClassLoader());

ComputeTaskFuture<int[]> fut1 = executeAsync(ignite1.compute(), TASK_NAME, Arrays.<UUID>asList(
ComputeTaskFuture<Integer> fut1 = executeAsync(ignite1.compute(), TASK_NAME, Arrays.<UUID>asList(
ignite1.cluster().localNode().id(),
ignite2.cluster().localNode().id(),
ignite3.cluster().localNode().id()));

ComputeTaskFuture<int[]> fut2 = executeAsync(ignite2.compute(), TASK_NAME, Arrays.<UUID>asList(
ComputeTaskFuture<Integer> fut2 = executeAsync(ignite2.compute(), TASK_NAME, Arrays.<UUID>asList(
ignite1.cluster().localNode().id(),
ignite2.cluster().localNode().id(),
ignite3.cluster().localNode().id()));

int[] res1 = fut1.get();
int[] res2 = fut2.get();
Integer res1 = fut1.get();
Integer res2 = fut2.get();

if (res1 == null || res2 == null || res1.length != 2 || res2.length != 2)
if (res1 == null || res2 == null)
throw new IgniteCheckedException("Received wrong result.");
}
}
Expand Down

This file was deleted.

This file was deleted.

0 comments on commit 88d705d

Please sign in to comment.