You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sk...@apache.org on 2022/06/14 17:37:23 UTC
[ignite-3] branch main updated: IGNITE-17156 Fixed potential bug in ItRebalanceDistributedTest#testThreeQueuedRebalances. Fixes #877
This is an automated email from the ASF dual-hosted git repository.
sk0x50 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 97bd89532 IGNITE-17156 Fixed potential bug in ItRebalanceDistributedTest#testThreeQueuedRebalances. Fixes #877
97bd89532 is described below
commit 97bd895320c0681677370dac8a45ad6cc416dcd2
Author: Mirza Aliev <al...@gmail.com>
AuthorDate: Tue Jun 14 20:37:07 2022 +0300
IGNITE-17156 Fixed potential bug in ItRebalanceDistributedTest#testThreeQueuedRebalances. Fixes #877
Signed-off-by: Slava Koptilin <sl...@gmail.com>
---
.../internal/configuration/storage/ItRebalanceDistributedTest.java | 2 +-
.../java/org/apache/ignite/internal/test/WatchListenerInhibitor.java | 5 +++--
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/storage/ItRebalanceDistributedTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/storage/ItRebalanceDistributedTest.java
index 5f174f3a0..f6c1214cc 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/storage/ItRebalanceDistributedTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/storage/ItRebalanceDistributedTest.java
@@ -129,7 +129,7 @@ public class ItRebalanceDistributedTest {
node.start();
}
- nodes.get(0).cmgManager.initCluster(List.of(nodes.get(0).name), List.of(), "cluster");
+ nodes.get(0).cmgManager.initCluster(List.of(nodes.get(2).name), List.of(), "cluster");
}
@AfterEach
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/test/WatchListenerInhibitor.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/test/WatchListenerInhibitor.java
index 213b32ebc..8c6a8f076 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/test/WatchListenerInhibitor.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/test/WatchListenerInhibitor.java
@@ -34,6 +34,7 @@ import org.apache.ignite.internal.metastorage.client.WatchListener;
import org.apache.ignite.internal.metastorage.watch.AggregatedWatch;
import org.apache.ignite.internal.metastorage.watch.WatchAggregator;
import org.apache.ignite.internal.testframework.IgniteTestUtils;
+import org.jetbrains.annotations.NotNull;
import org.junit.platform.commons.util.ReflectionUtils;
import org.mockito.Mockito;
@@ -115,7 +116,7 @@ public class WatchListenerInhibitor implements WatchListener {
}
/** {@inheritDoc} */
- @Override public synchronized boolean onUpdate(WatchEvent evt) {
+ @Override public synchronized boolean onUpdate(@NotNull WatchEvent evt) {
if (!inhibit) {
return realListener.onUpdate(evt);
}
@@ -124,7 +125,7 @@ public class WatchListenerInhibitor implements WatchListener {
}
/** {@inheritDoc} */
- @Override public synchronized void onError(Throwable e) {
+ @Override public synchronized void onError(@NotNull Throwable e) {
realListener.onError(e);
}