sashapolo commented on code in PR #5588:
URL: https://github.com/apache/ignite-3/pull/5588#discussion_r2041613595
##########
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItZoneDataReplicationTest.java:
##########
@@ -199,6 +223,141 @@ void testLocalRaftLogReapplication() throws Exception {
assertThat(kvView.get(null, 42), is(42));
}
+ /**
+ * Tests the following scenario.
+ *
+ * <ol>
+ * <li>Create a table and fill it with data;</li>
+ * <li>Truncate Raft log to force snapshot installation on joining
nodes;</li>
+ * <li>Drop the table, but do not update the low watermark;</li>
+ * <li>Add a new node to the cluster;</li>
+ * <li>Existing node will start streaming the snapshot to the joining
node. At the same time, update the Low Watermark value
+ * to force deletion of table storages on the existing node;</li>
+ * <li>Validate that concurrent snapshot streaming and storages
removals do not interfere with each other.</li>
+ * </ol>
+ */
+ @Test
+ void
testTableDropInTheMiddleOfRebalanceOnOutgoingSide(@InjectExecutorService
ExecutorService executorService) throws Exception {
Review Comment:
Sure, why not
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
