Skip to content

Commit b48b956

Browse files
IGNITE-26580 Fix checkstyle issues
1 parent 3a4335c commit b48b956

File tree

2 files changed

+11
-5
lines changed

2 files changed

+11
-5
lines changed

modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/MdcAffinityBackupFilter.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,8 +102,6 @@ public MdcAffinityBackupFilter(int dcsNum, int backups) {
102102
"copies cannot be distributed evenly across DCs. " +
103103
"Please adjust the number of backups, " + suggestion);
104104
}
105-
106-
107105
}
108106

109107
/** {@inheritDoc} */

modules/core/src/test/java/org/apache/ignite/cache/affinity/rendezvous/MdcAffinityBackupFilterSelfTest.java

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,8 @@ public void testAffinityFilterConfigurationValidation() throws Exception {
171171
startGrid(1);
172172

173173
fail("Expected exception was not thrown.");
174-
} catch (IgniteCheckedException e) {
174+
}
175+
catch (IgniteCheckedException e) {
175176
String errMsg = e.getMessage();
176177

177178
assertNotNull(errMsg);
@@ -184,7 +185,8 @@ public void testAffinityFilterConfigurationValidation() throws Exception {
184185
startGrid(1);
185186

186187
fail("Expected exception was not thrown.");
187-
} catch (IgniteCheckedException e) {
188+
}
189+
catch (IgniteCheckedException e) {
188190
String errMsg = e.getMessage();
189191

190192
assertNotNull(errMsg);
@@ -232,7 +234,12 @@ private IgniteEx startClusterAcrossDataCenters(String[] dcIds, int nodesPerDc) t
232234
}
233235

234236
/** */
235-
private Map<Integer, Set<UUID>> verifyNoRebalancing(int srvIdx, IgniteEx srv, Map<Integer, Set<UUID>> oldDistribution, Predicate<ClusterNode> dc1NodesFilter) throws InterruptedException {
237+
private Map<Integer, Set<UUID>> verifyNoRebalancing(
238+
int srvIdx,
239+
IgniteEx srv,
240+
Map<Integer, Set<UUID>> oldDistribution,
241+
Predicate<ClusterNode> dc1NodesFilter
242+
) throws InterruptedException {
236243
stopGrid(srvIdx);
237244
awaitPartitionMapExchange();
238245
IgniteCache<Integer, Integer> cache = srv.getOrCreateCache(DEFAULT_CACHE_NAME);
@@ -255,6 +262,7 @@ private Map<Integer, Set<UUID>> affinityForPartitions(IgniteCache<Integer, Integ
255262
for (int i = 0; i < PARTS_CNT; i++) {
256263
int j = i;
257264

265+
// For each partition, collect UUID of all its affinity nodes passing the provided filter.
258266
aff.mapKeyToPrimaryAndBackups(i)
259267
.stream()
260268
.filter(dcFilter)

0 commit comments

Comments
 (0)