From 4ef7dededda306a29702236e503cb619816c4428 Mon Sep 17 00:00:00 2001 From: Mirza Aliev Date: Wed, 12 Feb 2025 17:03:28 +0100 Subject: [PATCH 1/4] IGNITE-24412 Extend test coverage of basic HA functionality --- ...ctHighAvailablePartitionsRecoveryTest.java | 22 ++ ...ablePartitionSequentialRecoveriesTest.java | 16 ++ ...ePartitionsRecoveryByFilterUpdateTest.java | 189 ++++++++++++++++++ ...ItHighAvailablePartitionsRecoveryTest.java | 75 +++++++ 4 files changed, 302 insertions(+) diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java index 753da2324e2..658ba4a2977 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java @@ -38,6 +38,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertNull; import static org.junit.jupiter.api.Assertions.assertTrue; import static org.junit.jupiter.api.Assertions.fail; @@ -480,6 +481,12 @@ void assertValuesPresentOnNodes(HybridTimestamp ts, Table table, Integer... inde } } + void assertValuesNotPresentOnNodes(HybridTimestamp ts, Table table, Integer... indexes) { + for (Integer index : indexes) { + assertValuesNotPresentOnNode(table, ts, index); + } + } + private void assertValuesPresentOnNode(Table table, HybridTimestamp ts, int targetNodeIndex) { IgniteImpl targetNode = unwrapIgniteImpl(node(targetNodeIndex)); @@ -495,6 +502,21 @@ private void assertValuesPresentOnNode(Table table, HybridTimestamp ts, int targ } } + private void assertValuesNotPresentOnNode(Table table, HybridTimestamp ts, int targetNodeIndex) { + IgniteImpl targetNode = unwrapIgniteImpl(node(targetNodeIndex)); + + TableImpl tableImpl = unwrapTableImpl(table); + InternalTable internalTable = tableImpl.internalTable(); + + for (int i = 0; i < ENTRIES; i++) { + CompletableFuture fut = + internalTable.get(marshalKey(tableImpl, Tuple.create(of("id", i))), ts, targetNode.node()); + assertThat(fut, willCompleteSuccessfully()); + + assertNull(fut.join()); + } + } + private static Row marshalKey(TableViewInternal table, Tuple key) { SchemaRegistry schemaReg = table.schemaView(); diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionSequentialRecoveriesTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionSequentialRecoveriesTest.java index afeede74197..8ad9db355c0 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionSequentialRecoveriesTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionSequentialRecoveriesTest.java @@ -17,7 +17,13 @@ package org.apache.ignite.internal.table.distributed.disaster; +import static org.hamcrest.MatcherAssert.assertThat; +import static org.hamcrest.Matchers.empty; +import static org.hamcrest.Matchers.is; + +import java.util.List; import org.apache.ignite.internal.app.IgniteImpl; +import org.apache.ignite.table.Table; import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; @@ -40,6 +46,14 @@ void testTwoSequentialResets() throws InterruptedException { IgniteImpl node = igniteImpl(0); + Table table = node.tables().table(HA_TABLE_NAME); + + List errors = insertValues(table, 0); + + assertThat(errors, is(empty())); + + assertValuesPresentOnNodes(node.clock().now(), table, 0, 1, 2, 3, 4); + assertRecoveryKeyIsEmpty(node); stopNodes(2, 3, 4); @@ -49,5 +63,7 @@ void testTwoSequentialResets() throws InterruptedException { stopNode(1); waitAndAssertStableAssignmentsOfPartitionEqualTo(node, HA_TABLE_NAME, PARTITION_IDS, nodeNames(0)); + + assertValuesPresentOnNodes(node.clock().now(), table, 0); } } diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java index 18d1a24ed7c..ffb758912cb 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java @@ -17,8 +17,14 @@ package org.apache.ignite.internal.table.distributed.disaster; +import static org.hamcrest.MatcherAssert.assertThat; +import static org.hamcrest.Matchers.empty; +import static org.hamcrest.Matchers.is; + +import java.util.List; import java.util.Set; import org.apache.ignite.internal.app.IgniteImpl; +import org.apache.ignite.table.Table; import org.intellij.lang.annotations.Language; import org.jetbrains.annotations.Nullable; import org.junit.jupiter.api.Test; @@ -32,6 +38,8 @@ public class ItHighAvailablePartitionsRecoveryByFilterUpdateTest extends Abstrac private static final String GLOBAL_NODES_CONFIG = nodeConfig("{zone = global}", null); + private static final String CUSTOM_NODES_CONFIG = nodeConfig("{zone = custom}", null); + private static final String ROCKS_NODES_CONFIG = nodeConfig(null, "{lru_rocks.engine = rocksdb}"); private static final String AIPERSIST_NODES_CONFIG = nodeConfig(null, "{segmented_aipersist.engine = aipersist}"); @@ -122,6 +130,187 @@ void testThatPartitionResetZoneStorageProfileFilterAware() throws InterruptedExc waitThatAllRebalancesHaveFinishedAndStableAssignmentsEqualsToExpected(node, HA_TABLE_NAME, PARTITION_IDS, nodeNames(0)); } + /** + * Test scenario. + *
    + *
  1. Create a zone in HA mode (7 nodes, A, B, C, D, E, F, G) - phase 1
    2. + *
  2. Insert data and wait for replication to all nodes.
    3. + *
  3. Stop a majority of nodes (4 nodes A, B, C, D)
    4. + *
  4. Wait for the partition to become available (E, F, G), no new writes - phase 2
    5. + *
  5. Stop a majority of nodes once again (E, F)
    6. + *
  6. Wait for the partition to become available (G), no new writes - phase 3
    7. + *
  7. Stop the last node G
    8. + *
  8. Start one node from phase 1, A
    9. + *
  9. Start one node from phase 3, G
    10. + *
  10. Start one node from phase 2, E
    11. + *
  11. No data should be lost (reads from partition on A and E must be consistent with G)
    12. + *
+ * + * @throws Exception If failed. + */ + @Test + void testSeveralHaResetsAndSomeNodeRestart() throws Exception { + for (int i = 1; i < 8; i++) { + startNode(i, CUSTOM_NODES_CONFIG); + } + + String globalFilter = "$[?(@.zone == \"custom\")]"; + createHaZoneWithTable(7, globalFilter, nodeNames(1, 2, 3, 4, 5, 6, 7)); + + IgniteImpl node0 = igniteImpl(0); + Table table = node0.tables().table(HA_TABLE_NAME); + + List errors = insertValues(table, 0); + assertThat(errors, is(empty())); + assertValuesPresentOnNodes(node0.clock().now(), table, 1, 2, 3, 4, 5, 6, 7); + + // Stop 4 nodes (A, B, C, D) + stopNodes(4, 5, 6, 7); + + // Wait for the partition to become available on the remaining nodes (E, F, G) + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(1, 2, 3)); + + // Stop 2 more nodes (E, F) + stopNodes(2, 3); + + // Wait for the partition to become available on the last node (G) + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(1)); + + // Stop the last node (G) + stopNode(1); + + // Start one node from phase 1 (A) + startNode(4); + + // Start one node from phase 3 (G) + startNode(1); + + // Start one node from phase 2 (E) + startNode(2); + + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(1, 2, 4)); + + // Verify that no data is lost and reads from partition on nodes A and E are consistent with node G + assertValuesPresentOnNodes(node0.clock().now(), table, 1, 2, 4); + } + + /** + * Test scenario, where we start nodes from the previous assignments chain, with new writes. + * The whole scenario will be possible when second phase of HA feature will be implemented. + * + *
    + *
  1. Create a zone in HA mode with 7 nodes (A, B, C, D, E, F, G).
    2. + *
  2. Stop a majority of nodes (4 nodes A, B, C, D).
    3. + *
  3. Wait for the partition to become available on the remaining nodes (E, F, G).
    4. + *
  4. Stop a majority of nodes (E, F).
    5. + *
  5. Write data to node G.
    6. + *
  6. Stop node G.
    7. + *
  7. Start nodes E and F.
    8. + *
  8. Nodes should wait for node G to come back online.
    9. + *
+ * + * @throws Exception If failed. + */ + @Test + void testNodesWaitForLastNodeFromChainToComeBackOnlineAfterMajorityStops() throws Exception { + for (int i = 1; i < 8; i++) { + startNode(i, CUSTOM_NODES_CONFIG); + } + + String globalFilter = "$[?(@.zone == \"custom\")]"; + createHaZoneWithTable(7, globalFilter, nodeNames(1, 2, 3, 4, 5, 6, 7)); + + IgniteImpl node0 = igniteImpl(0); + Table table = node0.tables().table(HA_TABLE_NAME); + + List errors = insertValues(table, 0); + assertThat(errors, is(empty())); + assertValuesPresentOnNodes(node0.clock().now(), table, 1, 2, 3, 4, 5, 6, 7); + + // Stop 4 nodes (A, B, C, D) + stopNodes(4, 5, 6, 7); + + // Wait for the partition to become available on the remaining nodes (E, F, G) + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(1, 2, 3)); + + // Stop 2 more nodes (E, F) + stopNodes(2, 3); + + // Wait for the partition to become available on the last node (G) + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(1)); + + errors = insertValues(table, 1000); + assertThat(errors, is(empty())); + + assertValuesPresentOnNodes(node0.clock().now(), table, 1); + + // Stop the last node (G) + stopNode(1); + + // Start one node from phase 3 (E) + startNode(2); + + // Start one node from phase 2 (F) + startNode(3); + + assertValuesNotPresentOnNodes(node0.clock().now(), table, 2, 3); + } + + /** + * Test scenario, where we start nodes from the previous assignments chain, without new writes. + * The whole scenario will be possible when second phase of HA feature will be implemented. + *
    + *
  1. Create a zone in HA mode with 7 nodes (A, B, C, D, E, F, G).
    2. + *
  2. Stop a majority of nodes (4 nodes A, B, C, D).
    3. + *
  3. Wait for the partition to become available on the remaining nodes (E, F, G).
    4. + *
  4. Stop a majority of nodes (E, F).
    5. + *
  5. Stop node G.
    6. + *
  6. Start nodes E and F.
    7. + *
  7. Nodes should wait for nodes A, B, C, D, E, F, G to come back online.
    8. + *
+ * + * @throws Exception If failed. + */ + @Test + void testNodesWaitForNodesFromGracefulChainToComeBackOnlineAfterMajorityStops() throws Exception { + for (int i = 1; i < 8; i++) { + startNode(i, CUSTOM_NODES_CONFIG); + } + + String globalFilter = "$[?(@.zone == \"custom\")]"; + createHaZoneWithTable(7, globalFilter, nodeNames(1, 2, 3, 4, 5, 6, 7)); + + IgniteImpl node0 = igniteImpl(0); + Table table = node0.tables().table(HA_TABLE_NAME); + + List errors = insertValues(table, 0); + assertThat(errors, is(empty())); + assertValuesPresentOnNodes(node0.clock().now(), table, 1, 2, 3, 4, 5, 6, 7); + + // Stop 4 nodes (A, B, C, D) + stopNodes(4, 5, 6, 7); + + // Wait for the partition to become available on the remaining nodes (E, F, G) + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(1, 2, 3)); + + // Stop 2 more nodes (E, F) + stopNodes(2, 3); + + // Wait for the partition to become available on the last node (G) + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(1)); + + // Stop the last node (G) + stopNode(1); + + // Start one node from phase 3 (E) + startNode(2); + + // Start one node from phase 2 (F) + startNode(3); + + assertValuesNotPresentOnNodes(node0.clock().now(), table, 2, 3); + } + private void alterZoneSql(String filter, String zoneName) { executeSql(String.format("ALTER ZONE \"%s\" SET \"DATA_NODES_FILTER\" = '%s'", zoneName, filter)); } diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java index 5b2424b24a5..29905304e67 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java @@ -21,6 +21,7 @@ import static org.apache.ignite.internal.TestWrappers.unwrapIgniteImpl; import static org.apache.ignite.internal.catalog.commands.CatalogUtils.IMMEDIATE_TIMER_VALUE; import static org.apache.ignite.internal.catalog.commands.CatalogUtils.INFINITE_TIMER_VALUE; +import static org.apache.ignite.internal.distributionzones.DistributionZonesTestUtil.alterZone; import static org.apache.ignite.internal.distributionzones.DistributionZonesUtil.PARTITION_DISTRIBUTION_RESET_TIMEOUT; import static org.apache.ignite.internal.distributionzones.DistributionZonesUtil.zoneScaleDownChangeTriggerKey; import static org.apache.ignite.internal.testframework.IgniteTestUtils.waitForCondition; @@ -257,6 +258,12 @@ void testScaleUpAfterHaRecoveryWhenMajorityLoss() throws Exception { stopNodes(1, 2, 3, 4); + Table table = node.tables().table(HA_TABLE_NAME); + + List errors = insertValues(table, 0); + + assertThat(errors, is(empty())); + waitAndAssertRecoveryKeyIsNotEmpty(node); assertRecoveryRequestForHaZoneTable(node); @@ -280,6 +287,8 @@ void testScaleUpAfterHaRecoveryWhenMajorityLoss() throws Exception { PARTITION_IDS, Set.of(node.name(), node1.name(), node2.name()) ); + + assertValuesPresentOnNodes(node.clock().now(), table, 0, 1, 2); } @Test @@ -397,4 +406,70 @@ void testScaleDownTimerIsWorkingForHaZone() throws InterruptedException { keyValueStorage ); } + + /** + * Test scenario. + *
    + *
  1. Create a zone in HA mode with 7 nodes (A, B, C, D, E, F, G).
    2. + *
  2. Insert data and wait for replication to all nodes.
    3. + *
  3. Stop a majority of nodes (A, B, C, D).
    4. + *
  4. Wait for the partition to become available on the remaining nodes (E, F, G).
    5. + *
  5. Start node A.
    6. + *
  6. Verify that node A cleans up its state.
    7. + *
+ * + * @throws Exception If failed. + */ + @Test + void testNodeStateCleanupAfterRestartInHaMode() throws Exception { + startNode(3); + startNode(4); + startNode(5); + startNode(6); + + createHaZoneWithTable(); + + IgniteImpl node0 = igniteImpl(0); + Table table = node0.tables().table(HA_TABLE_NAME); + + List errors = insertValues(table, 0); + assertThat(errors, is(empty())); + assertValuesPresentOnNodes(node0.clock().now(), table, 0, 1, 2, 3, 4, 5, 6); + + alterZone(node0.catalogManager(), HA_ZONE_NAME, INFINITE_TIMER_VALUE, null, null); + + stopNodes(3, 4, 5, 6); + + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(0, 1, 2)); + + startNode(6); + + assertValuesNotPresentOnNodes(node0.clock().now(), table, 6); + } + + @Test + void test() throws Exception { + startNode(3); + startNode(4); + startNode(5); + startNode(6); + + createHaZoneWithTable(); + + IgniteImpl node0 = igniteImpl(0); + Table table = node0.tables().table(HA_TABLE_NAME); + + stopNodes(3, 4, 5, 6); + + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(0, 1, 2)); + + stopNodes(1, 2); + + waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(0)); + + startNode(6); + + assertValuesNotPresentOnNodes(node0.clock().now(), table, 6); + } + } From 3091654ec7bf7a5c32ec0840074a016eeedbfee8 Mon Sep 17 00:00:00 2001 From: Mirza Aliev Date: Thu, 13 Feb 2025 12:36:56 +0100 Subject: [PATCH 2/4] IGNITE-24412 review fixes --- ...ctHighAvailablePartitionsRecoveryTest.java | 30 +++++++------------ ...ItHighAvailablePartitionsRecoveryTest.java | 26 ---------------- 2 files changed, 10 insertions(+), 46 deletions(-) diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java index 658ba4a2977..55ec350d3fb 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/AbstractHighAvailablePartitionsRecoveryTest.java @@ -38,7 +38,6 @@ import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.assertNotNull; -import static org.junit.jupiter.api.Assertions.assertNull; import static org.junit.jupiter.api.Assertions.assertTrue; import static org.junit.jupiter.api.Assertions.fail; @@ -55,6 +54,7 @@ import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicReference; +import java.util.function.Predicate; import java.util.stream.Collectors; import java.util.stream.IntStream; import org.apache.ignite.Ignite; @@ -477,17 +477,22 @@ static List insertValues(Table table, int offset) { void assertValuesPresentOnNodes(HybridTimestamp ts, Table table, Integer... indexes) { for (Integer index : indexes) { - assertValuesPresentOnNode(table, ts, index); + assertValuesOnNode(table, ts, index, fut -> fut.join() != null); } } void assertValuesNotPresentOnNodes(HybridTimestamp ts, Table table, Integer... indexes) { for (Integer index : indexes) { - assertValuesNotPresentOnNode(table, ts, index); + assertValuesOnNode(table, ts, index, rowFut -> rowFut.join() == null); } } - private void assertValuesPresentOnNode(Table table, HybridTimestamp ts, int targetNodeIndex) { + private void assertValuesOnNode( + Table table, + HybridTimestamp ts, + int targetNodeIndex, + Predicate> dataCondition + ) { IgniteImpl targetNode = unwrapIgniteImpl(node(targetNodeIndex)); TableImpl tableImpl = unwrapTableImpl(table); @@ -498,22 +503,7 @@ private void assertValuesPresentOnNode(Table table, HybridTimestamp ts, int targ internalTable.get(marshalKey(tableImpl, Tuple.create(of("id", i))), ts, targetNode.node()); assertThat(fut, willCompleteSuccessfully()); - assertNotNull(fut.join()); - } - } - - private void assertValuesNotPresentOnNode(Table table, HybridTimestamp ts, int targetNodeIndex) { - IgniteImpl targetNode = unwrapIgniteImpl(node(targetNodeIndex)); - - TableImpl tableImpl = unwrapTableImpl(table); - InternalTable internalTable = tableImpl.internalTable(); - - for (int i = 0; i < ENTRIES; i++) { - CompletableFuture fut = - internalTable.get(marshalKey(tableImpl, Tuple.create(of("id", i))), ts, targetNode.node()); - assertThat(fut, willCompleteSuccessfully()); - - assertNull(fut.join()); + assertTrue(dataCondition.test(fut)); } } diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java index 29905304e67..58046ad800d 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java @@ -446,30 +446,4 @@ void testNodeStateCleanupAfterRestartInHaMode() throws Exception { assertValuesNotPresentOnNodes(node0.clock().now(), table, 6); } - - @Test - void test() throws Exception { - startNode(3); - startNode(4); - startNode(5); - startNode(6); - - createHaZoneWithTable(); - - IgniteImpl node0 = igniteImpl(0); - Table table = node0.tables().table(HA_TABLE_NAME); - - stopNodes(3, 4, 5, 6); - - waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(0, 1, 2)); - - stopNodes(1, 2); - - waitAndAssertStableAssignmentsOfPartitionEqualTo(node0, HA_TABLE_NAME, PARTITION_IDS, nodeNames(0)); - - startNode(6); - - assertValuesNotPresentOnNodes(node0.clock().now(), table, 6); - } - } From 5e955641f14f6a79c7f6f253b41fc4f147627883 Mon Sep 17 00:00:00 2001 From: Mirza Aliev Date: Thu, 13 Feb 2025 15:51:39 +0100 Subject: [PATCH 3/4] IGNITE-24412 mute tests --- .../ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java | 3 +++ .../disaster/ItHighAvailablePartitionsRecoveryTest.java | 2 ++ 2 files changed, 5 insertions(+) diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java index ffb758912cb..5131c08e9a6 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java @@ -27,6 +27,7 @@ import org.apache.ignite.table.Table; import org.intellij.lang.annotations.Language; import org.jetbrains.annotations.Nullable; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; /** Test suite for the cases with a recovery of the group replication factor after reset by zone filter update. */ @@ -212,6 +213,7 @@ void testSeveralHaResetsAndSomeNodeRestart() throws Exception { * @throws Exception If failed. */ @Test + @Disabled("https://issues.apache.org/jira/browse/IGNITE-24509") void testNodesWaitForLastNodeFromChainToComeBackOnlineAfterMajorityStops() throws Exception { for (int i = 1; i < 8; i++) { startNode(i, CUSTOM_NODES_CONFIG); @@ -272,6 +274,7 @@ void testNodesWaitForLastNodeFromChainToComeBackOnlineAfterMajorityStops() throw * @throws Exception If failed. */ @Test + @Disabled("https://issues.apache.org/jira/browse/IGNITE-24509") void testNodesWaitForNodesFromGracefulChainToComeBackOnlineAfterMajorityStops() throws Exception { for (int i = 1; i < 8; i++) { startNode(i, CUSTOM_NODES_CONFIG); diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java index 58046ad800d..3e8f78565e8 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryTest.java @@ -48,6 +48,7 @@ import org.apache.ignite.internal.metastorage.impl.MetaStorageManagerImpl; import org.apache.ignite.internal.metastorage.server.KeyValueStorage; import org.apache.ignite.table.Table; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; /** Test for the HA zones recovery. */ @@ -421,6 +422,7 @@ void testScaleDownTimerIsWorkingForHaZone() throws InterruptedException { * @throws Exception If failed. */ @Test + @Disabled("https://issues.apache.org/jira/browse/IGNITE-24509") void testNodeStateCleanupAfterRestartInHaMode() throws Exception { startNode(3); startNode(4); From 3f1cfbb62c9ea6bf82568c0506e2d61bd0321611 Mon Sep 17 00:00:00 2001 From: Mirza Aliev Date: Thu, 13 Feb 2025 16:04:37 +0100 Subject: [PATCH 4/4] IGNITE-24412 mute test --- .../ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java index 5131c08e9a6..24a7712c44f 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java @@ -150,6 +150,7 @@ void testThatPartitionResetZoneStorageProfileFilterAware() throws InterruptedExc * @throws Exception If failed. */ @Test + @Disabled("https://issues.apache.org/jira/browse/IGNITE-24513") void testSeveralHaResetsAndSomeNodeRestart() throws Exception { for (int i = 1; i < 8; i++) { startNode(i, CUSTOM_NODES_CONFIG);