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 da189c76df IGNITE-21180 Enable tests in ItTableRaftSnapshotsTest (#3000) da189c76df is described below commit da189c76df750e50a2f2233ac8db3ca8ff96747e Author: Roman Puchkovskiy <roman.puchkovs...@gmail.com> AuthorDate: Fri Dec 29 17:03:52 2023 +0400 IGNITE-21180 Enable tests in ItTableRaftSnapshotsTest (#3000) --- .../internal/raftsnapshot/ItTableRaftSnapshotsTest.java | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/modules/table/src/integrationTest/java/org/apache/ignite/internal/raftsnapshot/ItTableRaftSnapshotsTest.java b/modules/table/src/integrationTest/java/org/apache/ignite/internal/raftsnapshot/ItTableRaftSnapshotsTest.java index 91b9b799f3..c36221e4dc 100644 --- a/modules/table/src/integrationTest/java/org/apache/ignite/internal/raftsnapshot/ItTableRaftSnapshotsTest.java +++ b/modules/table/src/integrationTest/java/org/apache/ignite/internal/raftsnapshot/ItTableRaftSnapshotsTest.java @@ -228,7 +228,7 @@ class ItTableRaftSnapshotsTest extends IgniteIntegrationTest { String storageEngine, Consumer<Cluster> doOnClusterAfterInit ) throws InterruptedException { - cluster.startAndInit(3); + startAndInitCluster(); doOnClusterAfterInit.accept(cluster); @@ -246,6 +246,10 @@ class ItTableRaftSnapshotsTest extends IgniteIntegrationTest { causeLogTruncationOnSolePartitionLeader(0); } + private void startAndInitCluster() { + cluster.startAndInit(3, IntStream.range(0, 3).toArray()); + } + private void putToNode(int nodeIndex, int key, String value) { putToNode(nodeIndex, key, value, null); } @@ -377,7 +381,7 @@ class ItTableRaftSnapshotsTest extends IgniteIntegrationTest { * partition state arrives in a RAFT snapshot, then the transaction is seen as committed (i.e. its effects are seen). */ private void txSemanticsIsMaintainedAfterInstallingSnapshot() throws Exception { - cluster.startAndInit(3); + startAndInitCluster(); createTestTableWith3Replicas(DEFAULT_STORAGE_ENGINE); @@ -422,8 +426,6 @@ class ItTableRaftSnapshotsTest extends IgniteIntegrationTest { * reach the follower and get applied after the snapshot is installed. */ @Test - // TODO: IGNITE-18423 - enable when ReplicationTimeoutException is fixed - @Disabled("IGNITE-18423") void entriesKeepAppendedDuringSnapshotInstallation() throws Exception { prepareClusterForInstallingSnapshotToNode2(); @@ -460,8 +462,7 @@ class ItTableRaftSnapshotsTest extends IgniteIntegrationTest { * (and can install a RAFT snapshot on the ex-leader). */ @Test - // TODO: IGNITE-18423 - enable when ReplicationTimeoutException is fixed - @Disabled("IGNITE-18423") + @Disabled("IGNITE-21181") void nodeCanInstallSnapshotsAfterSnapshotInstalledToIt() throws Exception { feedNode2WithSnapshotOfOneRow(); @@ -698,7 +699,7 @@ class ItTableRaftSnapshotsTest extends IgniteIntegrationTest { */ @Test void laggingSchemasOnFollowerPreventSnapshotInstallation() throws Exception { - cluster.startAndInit(3); + startAndInitCluster(); createTestTableWith3Replicas(DEFAULT_STORAGE_ENGINE);