This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 818118e2795 IGNITE-22998 Fix LongDestroyDurableBackgroundTaskTest
(#11489)
818118e2795 is described below
commit 818118e279531e538f4d5ff896c1ae9ddeac36f9
Author: Semyon Zikunov <[email protected]>
AuthorDate: Wed Aug 21 16:54:13 2024 +1000
IGNITE-22998 Fix LongDestroyDurableBackgroundTaskTest (#11489)
---
.../cache/persistence/db/LongDestroyDurableBackgroundTaskTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/LongDestroyDurableBackgroundTaskTest.java
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/LongDestroyDurableBackgroundTaskTest.java
index d3faef4cc4c..88b9ac06b94 100644
---
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/LongDestroyDurableBackgroundTaskTest.java
+++
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/LongDestroyDurableBackgroundTaskTest.java
@@ -358,7 +358,7 @@ public class LongDestroyDurableBackgroundTaskTest extends
GridCommonAbstractTest
*
* @param ignite Ignite instance.
*/
- private void validateIndexes(Ignite ignite) {
+ private void validateIndexes(Ignite ignite) throws Exception {
Set<UUID> nodeIds = new HashSet<>();
nodeIds.add(grid(RESTARTED_NODE_NUM).cluster().localNode().id());
@@ -376,7 +376,7 @@ public class LongDestroyDurableBackgroundTaskTest extends
GridCommonAbstractTest
taskArg.checkSizes(true);
ValidateIndexesTaskResult taskRes =
- ignite.compute().execute(ValidateIndexesTask.class.getName(), new
VisorTaskArgument<>(nodeIds, taskArg, false));
+ ignite.compute().execute(ValidateIndexesTask.class, new
VisorTaskArgument<>(nodeIds, taskArg, false)).result();
if (!taskRes.exceptions().isEmpty()) {
for (Map.Entry<ValidateIndexesTaskResult.NodeInfo, Exception> e :
taskRes.exceptions().entrySet())
