Skip to content

Commit 92c0ab6

Browse files
author
yucai
committed
minor
1 parent 039ae85 commit 92c0ab6

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,8 +85,8 @@ public void testOpenShuffleBlocks() {
8585

8686
ManagedBuffer block0Marker = new NioManagedBuffer(ByteBuffer.wrap(new byte[3]));
8787
ManagedBuffer block1Marker = new NioManagedBuffer(ByteBuffer.wrap(new byte[7]));
88-
when(blockResolver.getBlockData("app0", "exec1", 0, 0, 0)).thenReturn(block0Marker);
89-
when(blockResolver.getBlockData("app0", "exec1", 0, 0, 1)).thenReturn(block1Marker);
88+
when(blockResolver.getBlockData("app0", "exec1", 0, 0, 0, 1)).thenReturn(block0Marker);
89+
when(blockResolver.getBlockData("app0", "exec1", 0, 0, 1, 1)).thenReturn(block1Marker);
9090
ByteBuffer openBlocks = new OpenBlocks("app0", "exec1",
9191
new String[] { "shuffle_0_0_0", "shuffle_0_0_1" })
9292
.toByteBuffer();
@@ -109,8 +109,8 @@ public void testOpenShuffleBlocks() {
109109
assertEquals(block0Marker, buffers.next());
110110
assertEquals(block1Marker, buffers.next());
111111
assertFalse(buffers.hasNext());
112-
verify(blockResolver, times(1)).getBlockData("app0", "exec1", 0, 0, 0);
113-
verify(blockResolver, times(1)).getBlockData("app0", "exec1", 0, 0, 1);
112+
verify(blockResolver, times(1)).getBlockData("app0", "exec1", 0, 0, 0, 1);
113+
verify(blockResolver, times(1)).getBlockData("app0", "exec1", 0, 0, 1, 1);
114114

115115
// Verify open block request latency metrics
116116
Timer openBlockRequestLatencyMillis = (Timer) ((ExternalShuffleBlockHandler) handler)

0 commit comments

Comments
 (0)