Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/19168#discussion_r137780881
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -157,7 +157,14 @@ final class ShuffleBlockFetcherIterator(
private[storage] def releaseCurrentResultBuffer(): Unit = {
// Release the current buffer if necessary
if (currentResult != null) {
--- End diff --
I can't evaluate the change, but, the 'null' case is now already handled by
your `case _`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]