This is an automated email from the ASF dual-hosted git repository. apolovtsev 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 c2d9711e0e IGNITE-17626 Cleanup API for destroying indexes (#3244) c2d9711e0e is described below commit c2d9711e0ea33c79390bfaf2c5d877809b3e9339 Author: Alexander Polovtcev <alex.polovt...@gmail.com> AuthorDate: Thu Feb 22 10:28:51 2024 +0200 IGNITE-17626 Cleanup API for destroying indexes (#3244) --- .../ignite/internal/index/IndexManagerTest.java | 4 +-- .../internal/storage/engine/MvTableStorage.java | 4 +-- .../internal/storage/index/HashIndexStorage.java | 12 --------- .../index/ThreadAssertingHashIndexStorage.java | 10 -------- .../storage/AbstractMvTableStorageTest.java | 2 -- .../internal/storage/impl/TestMvTableStorage.java | 18 ++++++++----- .../index/AbstractHashIndexStorageTest.java | 30 ++++++++++------------ .../index/hash/PageMemoryHashIndexStorage.java | 6 ----- .../mv/AbstractPageMemoryMvPartitionStorage.java | 2 +- .../PersistentPageMemoryMvTableStorageTest.java | 8 ++++++ .../VolatilePageMemoryMvTableStorageTest.java | 8 ++++++ .../AbstractPageMemoryHashIndexStorageTest.java | 8 ++++++ .../ignite/internal/storage/rocksdb/HashIndex.java | 3 ++- .../rocksdb/index/RocksDbHashIndexStorage.java | 20 --------------- .../storage/rocksdb/RocksDbMvTableStorageTest.java | 8 ++++++ .../rocksdb/index/RocksDbHashIndexStorageTest.java | 9 +++++++ 16 files changed, 73 insertions(+), 79 deletions(-) diff --git a/modules/index/src/test/java/org/apache/ignite/internal/index/IndexManagerTest.java b/modules/index/src/test/java/org/apache/ignite/internal/index/IndexManagerTest.java index 10f8c94ebd..3dfdf67abd 100644 --- a/modules/index/src/test/java/org/apache/ignite/internal/index/IndexManagerTest.java +++ b/modules/index/src/test/java/org/apache/ignite/internal/index/IndexManagerTest.java @@ -216,7 +216,7 @@ public class IndexManagerTest extends BaseIgniteAbstractTest { verify(tableViewInternal, never()).unregisterIndex(anyInt()); } - @Disabled("https://issues.apache.org/jira/browse/IGNITE-17626") + @Disabled("https://issues.apache.org/jira/browse/IGNITE-21576") @Test void testDestroyIndex() throws Exception { createIndex(TABLE_NAME, INDEX_NAME); @@ -234,7 +234,7 @@ public class IndexManagerTest extends BaseIgniteAbstractTest { verify(mvTableStorage).destroyIndex(indexId); } - @Disabled("https://issues.apache.org/jira/browse/IGNITE-17626") + @Disabled("https://issues.apache.org/jira/browse/IGNITE-21576") @Test void testIndexDestroyedWithTable() throws Exception { createIndex(TABLE_NAME, INDEX_NAME); diff --git a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java index eb3e91ab62..2068045183 100644 --- a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java +++ b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java @@ -116,9 +116,9 @@ public interface MvTableStorage extends ManuallyCloseable { HashIndexStorage getOrCreateHashIndex(int partitionId, StorageHashIndexDescriptor indexDescriptor); /** - * Destroys the index under the given name and all data in it. + * Destroys the index with the given ID and all data in it. * - * <p>This method is a no-op if the index under the given name does not exist. + * <p>This method is a no-op if the index with the given ID does not exist. * * @param indexId Index ID. */ diff --git a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/HashIndexStorage.java b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/HashIndexStorage.java index 0b13c0994c..38dc0ceb3b 100644 --- a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/HashIndexStorage.java +++ b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/HashIndexStorage.java @@ -17,10 +17,7 @@ package org.apache.ignite.internal.storage.index; -import java.util.UUID; import org.apache.ignite.internal.storage.RowId; -import org.apache.ignite.internal.storage.StorageException; -import org.apache.ignite.internal.storage.engine.MvTableStorage; /** * Storage for a Hash Index. @@ -33,13 +30,4 @@ public interface HashIndexStorage extends IndexStorage { * Returns the Index Descriptor of this storage. */ StorageHashIndexDescriptor indexDescriptor(); - - /** - * Removes all data from this index. - * - * @throws StorageException If failed to destory index. - * @deprecated IGNITE-17626 Synchronous API should be removed. {@link MvTableStorage#destroyIndex(UUID)} must be the only public option. - */ - @Deprecated - void destroy() throws StorageException; } diff --git a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingHashIndexStorage.java b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingHashIndexStorage.java index 5e1ca534c1..aeff2b20c0 100644 --- a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingHashIndexStorage.java +++ b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingHashIndexStorage.java @@ -17,9 +17,6 @@ package org.apache.ignite.internal.storage.index; -import static org.apache.ignite.internal.worker.ThreadAssertions.assertThreadAllowsToWrite; - -import org.apache.ignite.internal.storage.StorageException; import org.apache.ignite.internal.worker.ThreadAssertions; /** @@ -41,11 +38,4 @@ public class ThreadAssertingHashIndexStorage extends ThreadAssertingIndexStorage public StorageHashIndexDescriptor indexDescriptor() { return indexStorage.indexDescriptor(); } - - @Override - public void destroy() throws StorageException { - assertThreadAllowsToWrite(); - - indexStorage.destroy(); - } } diff --git a/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/AbstractMvTableStorageTest.java b/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/AbstractMvTableStorageTest.java index 7a5b193692..84261c519d 100644 --- a/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/AbstractMvTableStorageTest.java +++ b/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/AbstractMvTableStorageTest.java @@ -85,7 +85,6 @@ import org.apache.ignite.internal.type.NativeTypes; import org.apache.ignite.internal.util.Cursor; import org.jetbrains.annotations.Nullable; import org.junit.jupiter.api.AfterEach; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; /** @@ -255,7 +254,6 @@ public abstract class AbstractMvTableStorageTest extends BaseMvStoragesTest { /** * Tests destroying an index. */ - @Disabled("https://issues.apache.org/jira/browse/IGNITE-17626") @Test public void testDestroyIndex() { MvPartitionStorage partitionStorage = getOrCreateMvPartition(PARTITION_ID); diff --git a/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestMvTableStorage.java b/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestMvTableStorage.java index b168858b64..285d5895e8 100644 --- a/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestMvTableStorage.java +++ b/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestMvTableStorage.java @@ -127,7 +127,7 @@ public class TestMvTableStorage implements MvTableStorage { mvPartitionStorage.destroy(); for (HashIndices hashIndices : hashIndicesById.values()) { - HashIndexStorage removedHashIndexStorage = hashIndices.storageByPartitionId.remove(mvPartitionStorage.partitionId); + TestHashIndexStorage removedHashIndexStorage = hashIndices.storageByPartitionId.remove(mvPartitionStorage.partitionId); if (removedHashIndexStorage != null) { removedHashIndexStorage.destroy(); @@ -135,10 +135,10 @@ public class TestMvTableStorage implements MvTableStorage { } for (SortedIndices sortedIndices : sortedIndicesById.values()) { - SortedIndexStorage removedSortedIndexStorage = sortedIndices.storageByPartitionId.remove(mvPartitionStorage.partitionId); + TestSortedIndexStorage removedSortedIndexStorage = sortedIndices.storageByPartitionId.remove(mvPartitionStorage.partitionId); if (removedSortedIndexStorage != null) { - ((TestSortedIndexStorage) removedSortedIndexStorage).destroy(); + removedSortedIndexStorage.destroy(); } } @@ -179,12 +179,16 @@ public class TestMvTableStorage implements MvTableStorage { @Override public CompletableFuture<Void> destroyIndex(int indexId) { - sortedIndicesById.remove(indexId); + HashIndices hashIndices = hashIndicesById.remove(indexId); - HashIndices hashIndex = hashIndicesById.remove(indexId); + if (hashIndices != null) { + hashIndices.storageByPartitionId.values().forEach(TestHashIndexStorage::destroy); + } - if (hashIndex != null) { - hashIndex.storageByPartitionId.values().forEach(HashIndexStorage::destroy); + SortedIndices sortedIndices = sortedIndicesById.remove(indexId); + + if (sortedIndices != null) { + sortedIndices.storageByPartitionId.values().forEach(TestSortedIndexStorage::destroy); } return nullCompletedFuture(); diff --git a/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/index/AbstractHashIndexStorageTest.java b/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/index/AbstractHashIndexStorageTest.java index 8d01b5d4be..0b3bc8c8b9 100644 --- a/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/index/AbstractHashIndexStorageTest.java +++ b/modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/index/AbstractHashIndexStorageTest.java @@ -19,9 +19,12 @@ package org.apache.ignite.internal.storage.index; import static java.util.stream.Collectors.toList; import static org.apache.ignite.internal.catalog.descriptors.CatalogIndexStatus.AVAILABLE; +import static org.apache.ignite.internal.testframework.matchers.CompletableFutureMatcher.willCompleteSuccessfully; import static org.hamcrest.CoreMatchers.is; import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.Matchers.empty; +import static org.hamcrest.Matchers.nullValue; +import static org.hamcrest.Matchers.sameInstance; import static org.mockito.ArgumentMatchers.anyInt; import static org.mockito.ArgumentMatchers.anyLong; import static org.mockito.ArgumentMatchers.eq; @@ -34,7 +37,6 @@ import org.apache.ignite.internal.catalog.descriptors.CatalogTableDescriptor; import org.apache.ignite.internal.storage.RowId; import org.apache.ignite.internal.storage.index.impl.BinaryTupleRowSerializer; import org.apache.ignite.sql.ColumnType; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; /** @@ -69,11 +71,15 @@ public abstract class AbstractHashIndexStorageTest extends AbstractIndexStorageT return index.indexDescriptor(); } - @Disabled("https://issues.apache.org/jira/browse/IGNITE-17626") @Test public void testDestroy() { HashIndexStorage index = createIndexStorage(INDEX_NAME, ColumnType.INT32, ColumnType.STRING); - var serializer = new BinaryTupleRowSerializer(indexDescriptor(index)); + + int indexId = index.indexDescriptor().id(); + + assertThat(tableStorage.getIndex(TEST_PARTITION, indexId), is(sameInstance(index))); + + var serializer = new BinaryTupleRowSerializer(index.indexDescriptor()); IndexRow row1 = serializer.serializeRow(new Object[]{ 1, "foo" }, new RowId(TEST_PARTITION)); IndexRow row2 = serializer.serializeRow(new Object[]{ 1, "foo" }, new RowId(TEST_PARTITION)); @@ -85,25 +91,17 @@ public abstract class AbstractHashIndexStorageTest extends AbstractIndexStorageT CompletableFuture<Void> destroyFuture = tableStorage.destroyIndex(index.indexDescriptor().id()); - waitForDurableCompletion(destroyFuture); + assertThat(destroyFuture, willCompleteSuccessfully()); + + assertThat(tableStorage.getIndex(TEST_PARTITION, indexId), is(nullValue())); + + index = createIndexStorage(INDEX_NAME, ColumnType.INT32, ColumnType.STRING); - //TODO IGNITE-17626 Index must be invalid, we should assert that getIndex returns null and that in won't surface upon restart. - // "destroy" is not "clear", you know. Maybe "getAndCreateIndex" will do it for the test, idk assertThat(getAll(index, row1), is(empty())); assertThat(getAll(index, row2), is(empty())); assertThat(getAll(index, row3), is(empty())); } - private void waitForDurableCompletion(CompletableFuture<?> future) { - while (true) { - if (future.isDone()) { - return; - } - - partitionStorage.flush().join(); - } - } - protected IndexRow createIndexRow(BinaryTupleRowSerializer serializer, RowId rowId, Object... values) { return serializer.serializeRow(values, rowId); } diff --git a/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/hash/PageMemoryHashIndexStorage.java b/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/hash/PageMemoryHashIndexStorage.java index ab6b0fc7f8..b367e8aff7 100644 --- a/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/hash/PageMemoryHashIndexStorage.java +++ b/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/hash/PageMemoryHashIndexStorage.java @@ -144,12 +144,6 @@ public class PageMemoryHashIndexStorage extends AbstractPageMemoryIndexStorage<H }); } - @Override - public void destroy() throws StorageException { - // TODO: IGNITE-17626 Remove it - throw new UnsupportedOperationException(); - } - /** * Starts destruction of the data stored by this index partition. * diff --git a/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/AbstractPageMemoryMvPartitionStorage.java b/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/AbstractPageMemoryMvPartitionStorage.java index 7ec51123ca..20209d009b 100644 --- a/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/AbstractPageMemoryMvPartitionStorage.java +++ b/modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/AbstractPageMemoryMvPartitionStorage.java @@ -182,7 +182,7 @@ public abstract class AbstractPageMemoryMvPartitionStorage implements MvPartitio } else { assert indexDescriptor == null; - //TODO: IGNITE-17626 Drop the index synchronously. + //TODO: IGNITE-21583 Drop the index synchronously. } } diff --git a/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/PersistentPageMemoryMvTableStorageTest.java b/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/PersistentPageMemoryMvTableStorageTest.java index 6e7d3a6e16..0803520158 100644 --- a/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/PersistentPageMemoryMvTableStorageTest.java +++ b/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/PersistentPageMemoryMvTableStorageTest.java @@ -38,6 +38,7 @@ import org.apache.ignite.internal.testframework.WorkDirectoryExtension; import org.apache.ignite.internal.util.IgniteUtils; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; @@ -91,4 +92,11 @@ public class PersistentPageMemoryMvTableStorageTest extends AbstractMvTableStora willCompleteSuccessfully() ); } + + @Disabled("https://issues.apache.org/jira/browse/IGNITE-21583") + @Test + @Override + public void testDestroyIndex() { + super.testDestroyIndex(); + } } diff --git a/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/VolatilePageMemoryMvTableStorageTest.java b/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/VolatilePageMemoryMvTableStorageTest.java index 370fccc77a..d17025edfe 100644 --- a/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/VolatilePageMemoryMvTableStorageTest.java +++ b/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/VolatilePageMemoryMvTableStorageTest.java @@ -53,6 +53,7 @@ import org.apache.ignite.internal.type.NativeTypes; import org.apache.ignite.internal.util.IgniteUtils; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; /** @@ -241,6 +242,13 @@ public class VolatilePageMemoryMvTableStorageTest extends AbstractMvTableStorage assertIndexDataDestructionCompletes(emptyIndexPagesBeforeDestroy); } + @Disabled("https://issues.apache.org/jira/browse/IGNITE-21583") + @Test + @Override + public void testDestroyIndex() { + super.testDestroyIndex(); + } + private VolatilePageMemoryDataRegion dataRegion() { return ((VolatilePageMemoryTableStorage) tableStorage).dataRegion(); } diff --git a/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/AbstractPageMemoryHashIndexStorageTest.java b/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/AbstractPageMemoryHashIndexStorageTest.java index 171b0d2fb8..1aedfd660e 100644 --- a/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/AbstractPageMemoryHashIndexStorageTest.java +++ b/modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/AbstractPageMemoryHashIndexStorageTest.java @@ -33,6 +33,7 @@ import org.apache.ignite.internal.storage.index.IndexRow; import org.apache.ignite.internal.storage.index.impl.BinaryTupleRowSerializer; import org.apache.ignite.internal.storage.pagememory.configuration.schema.BasePageMemoryStorageEngineConfiguration; import org.apache.ignite.sql.ColumnType; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; /** @@ -93,4 +94,11 @@ abstract class AbstractPageMemoryHashIndexStorageTest extends AbstractHashIndexS assertThat(getAll(index, createIndexRow(serializer, new RowId(TEST_PARTITION), 1, "foo")), empty()); } + + @Disabled("https://issues.apache.org/jira/browse/IGNITE-21583") + @Test + @Override + public void testDestroy() { + super.testDestroy(); + } } diff --git a/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/HashIndex.java b/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/HashIndex.java index 3fc9c0261d..d7bb4b7f2a 100644 --- a/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/HashIndex.java +++ b/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/HashIndex.java @@ -61,7 +61,8 @@ class HashIndex { * Removes all data associated with the index. */ void destroy() { - storages.values().forEach(RocksDbHashIndexStorage::destroy); + // TODO: implement, see https://issues.apache.org/jira/browse/IGNITE-21574. + throw new UnsupportedOperationException("Not implemented yet"); } /** diff --git a/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorage.java b/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorage.java index 15e2f6478c..07d2159dca 100644 --- a/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorage.java +++ b/modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorage.java @@ -40,7 +40,6 @@ import org.apache.ignite.internal.util.HashUtils; import org.rocksdb.RocksDBException; import org.rocksdb.WriteBatch; import org.rocksdb.WriteBatchWithIndex; -import org.rocksdb.WriteOptions; /** * {@link HashIndexStorage} implementation based on RocksDB. @@ -152,25 +151,6 @@ public class RocksDbHashIndexStorage extends AbstractRocksDbIndexStorage impleme }); } - @Override - public void destroy() { - busy(() -> { - throwExceptionIfStorageInProgressOfRebalance(state.get(), this::createStorageInfo); - - byte[] rangeEnd = incrementPrefix(constantPrefix); - - assert rangeEnd != null; - - try (WriteOptions writeOptions = new WriteOptions().setDisableWAL(true)) { - indexCf.db().deleteRange(indexCf.handle(), writeOptions, constantPrefix, rangeEnd); - - return null; - } catch (RocksDBException e) { - throw new StorageException("Unable to remove data from hash index. Index ID: " + descriptor.id(), e); - } - }); - } - private byte[] rocksPrefix(BinaryTuple prefix) { return rocksPrefix(prefix, 0).array(); } diff --git a/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbMvTableStorageTest.java b/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbMvTableStorageTest.java index f971749324..bb38e9f2df 100644 --- a/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbMvTableStorageTest.java +++ b/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbMvTableStorageTest.java @@ -42,6 +42,7 @@ import org.apache.ignite.internal.testframework.WorkDirectoryExtension; import org.apache.ignite.internal.util.IgniteUtils; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; @@ -161,4 +162,11 @@ public class RocksDbMvTableStorageTest extends AbstractMvTableStorageTest { void storageAdvertisesItIsPersistent() { assertThat(tableStorage.isVolatile(), is(false)); } + + @Disabled("https://issues.apache.org/jira/browse/IGNITE-21574") + @Test + @Override + public void testDestroyIndex() { + super.testDestroyIndex(); + } } diff --git a/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorageTest.java b/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorageTest.java index 745d5fc3cb..f9bdc2d5fa 100644 --- a/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorageTest.java +++ b/modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/index/RocksDbHashIndexStorageTest.java @@ -33,6 +33,8 @@ import org.apache.ignite.internal.testframework.WorkDirectoryExtension; import org.apache.ignite.internal.util.IgniteUtils; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; +import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; /** @@ -70,4 +72,11 @@ public class RocksDbHashIndexStorageTest extends AbstractHashIndexStorageTest { engine == null ? null : engine::stop ); } + + @Disabled("https://issues.apache.org/jira/browse/IGNITE-21574") + @Test + @Override + public void testDestroy() { + super.testDestroy(); + } }