Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/19788#discussion_r152976754
--- Diff:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolverSuite.java
---
@@ -110,6 +110,13 @@ public void testSortShuffleBlocks() throws IOException
{
new InputStreamReader(block1Stream, StandardCharsets.UTF_8));
block1Stream.close();
assertEquals(sortBlock1, block1);
+
+ InputStream block01Stream =
+ resolver.getBlockData("app0", "exec0", 0, 0, 0,
2).createInputStream();
--- End diff --
nit: please follow the above indents format.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
