Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/22325
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r219236374
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -386,6 +386,7 @@ final class ShuffleBlockFetcherIterator(
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r219021367
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +445,36 @@ final class
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r219021183
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +445,36 @@ final class
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r218991156
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +445,36 @@ final class ShuffleBlockFetcherIterator(
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r218990774
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +445,36 @@ final class ShuffleBlockFetcherIterator(
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r218989956
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,49 +444,34 @@ final class ShuffleBlockFetcherIterator(
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r218944816
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +444,34 @@ final class
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r218873184
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +444,34 @@ final class
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r218872037
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +444,34 @@ final class
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r218857081
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,36 +444,34 @@ final class
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r215396772
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,10 +444,23 @@ final class
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r215391696
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,10 +444,23 @@ final class
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r215390096
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,10 +444,23 @@ final class ShuffleBlockFetcherIterator(
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r215388601
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,10 +444,23 @@ final class
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22325#discussion_r215368719
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -444,10 +444,23 @@ final class ShuffleBlockFetcherIterator(
GitHub user rezasafi opened a pull request:
https://github.com/apache/spark/pull/22325
[SPARK-25318]. Add exception handling when wrapping the input stream during
the the fetch or stage retry in response to a corrupted block
SPARK-4105 provided a solution to block corruption issue
17 matches
Mail list logo
