Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public class IgniteCacheObjectKeyIndexingSelfTest extends GridCommonAbstractTest
private static final int CACHE_SIZE = 20_000;

/** {@inheritDoc} */
@Override protected void afterTestsStopped() throws Exception {
@Override protected void afterTest() throws Exception {
Ignition.stopAll(true);

cleanPersistenceDir();
Expand Down Expand Up @@ -116,9 +116,9 @@ public void testObjectKeyHandling() throws Exception {
/** */
@Test
public void testObjectKeyHandlingDuringRebalance() throws Exception {
startGrid(getTestIgniteInstanceName(0), createIgniteCfg(0));
startGrid(createIgniteCfg(0));

Ignite ign1 = startGrid(getTestIgniteInstanceName(1), createIgniteCfg(1));
Ignite ign1 = startGrid(createIgniteCfg(1));

ign1.cluster().state(ClusterState.ACTIVE);

Expand All @@ -132,7 +132,7 @@ public void testObjectKeyHandlingDuringRebalance() throws Exception {

cleanPersistenceDir("node_1");

startGrid(getTestIgniteInstanceName(1), createIgniteCfg(1));
startGrid(createIgniteCfg(1));

grid(0).cluster().setBaselineTopology(grid(0).cluster().topologyVersion());

Expand Down Expand Up @@ -199,17 +199,13 @@ private Map<TestObject, TestObject> fillCache(int mul, boolean rnd, Supplier<Boo
}

/** */
private IgniteConfiguration createIgniteCfg(int id) {
return new IgniteConfiguration()
.setGridLogger(log)
private IgniteConfiguration createIgniteCfg(int id) throws Exception {
return getConfiguration(getTestIgniteInstanceName(id))
.setConsistentId("node_" + id)
.setRebalanceBatchSize(64)
.setDataStorageConfiguration(
new DataStorageConfiguration()
.setDefaultDataRegionConfiguration(
new DataRegionConfiguration().setPersistenceEnabled(true)
)
);
.setDataStorageConfiguration(new DataStorageConfiguration()
.setDefaultDataRegionConfiguration(new DataRegionConfiguration()
.setPersistenceEnabled(true)));
}

/** */
Expand Down
Loading