sashapolo commented on code in PR #5588:
URL: https://github.com/apache/ignite-3/pull/5588#discussion_r2044753725
##########
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItZoneDataReplicationTest.java:
##########
@@ -314,56 +335,61 @@ void
testTableDropInTheMiddleOfRebalanceOnIncomingSide(@InjectExecutorService Ex
truncateLogOnEveryNode(partitionId);
+ dropTable(node.catalogManager, DEFAULT_SCHEMA_NAME, TEST_TABLE_NAME1);
+
// Block outgoing snapshot so that we have time to register mocks on
the receiving side.
startBlockOutgoingSnapshot(node, partitionId);
- Node newNode = addNodeToCluster();
+ Node receiverNode = addNodeToCluster();
+
+ // Wait for the table to start on the receiving side.
+ assertTrue(waitForCondition(() -> tableStorage(receiverNode, tableId)
!= null, 10_000));
- assertTrue(waitForCondition(() -> tableStorage(newNode, tableId) !=
null, 10_000));
+ MvTableStorage receivingTableStorage = tableStorage(receiverNode,
tableId);
- MvTableStorage tableStorage = tableStorage(newNode, tableId);
+ // Future that gets completed as soon as
"receivingTableStorage.startRebalancePartition" has been called.
+ var starRebalanceInvokedFuture = new CompletableFuture<Void>();
Review Comment:
well, this is embarrassing
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
