This is an automated email from the ASF dual-hosted git repository.
ptupitsyn 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 648ba4004f IGNITE-19678 Fix remaining NPEs in ItMetaStorageServiceTest
(#2166)
648ba4004f is described below
commit 648ba4004f3fda2b2e484602fbc2bba3a196cb7d
Author: Alexander Polovtcev <[email protected]>
AuthorDate: Thu Jun 8 09:58:33 2023 +0300
IGNITE-19678 Fix remaining NPEs in ItMetaStorageServiceTest (#2166)
---
.../ignite/internal/metastorage/impl/ItMetaStorageServiceTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageServiceTest.java
b/modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageServiceTest.java
index be06fc06a2..bb8fb34feb 100644
---
a/modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageServiceTest.java
+++
b/modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItMetaStorageServiceTest.java
@@ -593,7 +593,7 @@ public class ItMetaStorageServiceTest {
long expRevUpperBound = 10;
- when(node.mockStorage.range(expKeyFrom.bytes(), expKeyTo.bytes(),
expRevUpperBound)).thenReturn(mock(Cursor.class));
+ when(node.mockStorage.range(expKeyFrom.bytes(), expKeyTo.bytes(),
expRevUpperBound)).thenReturn(emptyCursor());
node.metaStorageService.range(expKeyFrom, expKeyTo,
expRevUpperBound).subscribe(singleElementSubscriber());
@@ -612,7 +612,7 @@ public class ItMetaStorageServiceTest {
ByteArray expKeyTo = new ByteArray(new byte[]{3});
- when(node.mockStorage.range(expKeyFrom.bytes(),
expKeyTo.bytes())).thenReturn(mock(Cursor.class));
+ when(node.mockStorage.range(expKeyFrom.bytes(),
expKeyTo.bytes())).thenReturn(emptyCursor());
node.metaStorageService.range(expKeyFrom, expKeyTo,
false).subscribe(singleElementSubscriber());