Github user yucai commented on a diff in the pull request:
https://github.com/apache/spark/pull/19788#discussion_r153049711
--- 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();
+ String block01 = CharStreams.toString(
+ new InputStreamReader(block01Stream, StandardCharsets.UTF_8));
--- End diff --
Thanks, updated!
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
