Skip to content

Commit dceae72

Browse files
committed
Fixed style issues
1 parent f34935f commit dceae72

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -487,8 +487,8 @@ private String[] prepareBlockManagerLocalDirs(String TEST_APP, String user, Stri
487487
}
488488

489489
private void removeApplication(String TEST_APP) {
490-
// PushResolver cleans up the local dirs in a different thread which can conflict with the test data of other
491-
// tests, since all the tests are using the same Application Id.
490+
// PushResolver cleans up the local dirs in a different thread which can conflict with the test
491+
// data of other tests, since they are using the same Application Id.
492492
pushResolver.applicationRemoved(TEST_APP, false);
493493
}
494494

@@ -504,7 +504,8 @@ private void validateChunks(
504504
}
505505
for (int i = 0; i < meta.getNumChunks(); i++) {
506506
FileSegmentManagedBuffer mb =
507-
(FileSegmentManagedBuffer) pushResolver.getMergedBlockData(TEST_APP, shuffleId, reduceId, i);
507+
(FileSegmentManagedBuffer) pushResolver.getMergedBlockData(TEST_APP, shuffleId, reduceId,
508+
i);
508509
assertEquals(expectedSizes[i], mb.getLength());
509510
}
510511
}

0 commit comments

Comments
 (0)