Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
maobaolong committed Nov 18, 2024
1 parent 8f8173d commit 62712f5
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -511,7 +511,6 @@ public void testClientRemoteReadFromMultipleDisk(boolean isNettyMode) {
// Send shuffle data
Map<Long, byte[]> expectedData = Maps.newHashMap();
Roaring64NavigableMap blockIdBitmap = Roaring64NavigableMap.bitmapOf();
Roaring64NavigableMap taskIdBitmap = Roaring64NavigableMap.bitmapOf(0);

List<ShuffleBlockInfo> blocks =
createShuffleBlockList(0, 0, 0, 5, 30, blockIdBitmap, expectedData, mockSSI);
Expand All @@ -533,6 +532,7 @@ public void testClientRemoteReadFromMultipleDisk(boolean isNettyMode) {
(LocalStorage) shuffleServer.getStorageManager().selectStorage(readEvent);
assertNotEquals(storage1, storage2);

Roaring64NavigableMap taskIdBitmap = Roaring64NavigableMap.bitmapOf(0);
// unexpected taskAttemptId should be filtered
ShuffleReadClientImpl readClient =
baseReadBuilder(isNettyMode)
Expand Down

0 comments on commit 62712f5

Please sign in to comment.