sk0x50 commented on code in PR #5198:
URL: https://github.com/apache/ignite-3/pull/5198#discussion_r1950361920
##########
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItReplicaLifecycleTest.java:
##########
@@ -768,7 +777,76 @@ public void testTableEstimatedSize(TestInfo testInfo)
throws Exception {
}
}
- private void prepareTableIdToZoneIdConverter(Node node, int zoneId) {
+ @Test
+ public void testScanCloseReplicaRequest(TestInfo testInfo) throws
Exception {
+ // Prepare a single node cluster.
+ startNodes(testInfo, 1);
+ Node node = getNode(0);
+
placementDriver.setPrimary(node.clusterService.topologyService().localMember());
+
+ // Prepare a zone.
+ String zoneName = "test_zone";
+ createZone(node, zoneName, 1, 1);
+ int zoneId = DistributionZonesTestUtil.getZoneId(node.catalogManager,
zoneName, node.hybridClock.nowLong());
+ prepareTableIdToZoneIdConverter(node, zoneId);
+
+ // Create a table to work with.
+ String tableName = "test_table";
+ createTable(node, zoneName, tableName);
+ int tableId = TableTestUtils.getTableId(node.catalogManager,
tableName, node.hybridClock.nowLong());
+ TableViewInternal tableViewInternal = node.tableManager.table(tableId);
+ KeyValueView<Long, Integer> tableView =
tableViewInternal.keyValueView(Long.class, Integer.class);
+
+ // Write 2 rows to the table.
+ Map<Long, Integer> valuesToPut = Map.of(0L, 0, 1L, 1);
+ assertDoesNotThrow(() -> tableView.putAll(null, valuesToPut));
Review Comment:
Should we use an explicit transaction here, at least for now?
--
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
