Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r172416019
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,16 @@ private[spark] class
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r172414393
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,16 @@ private[spark] class
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/20449
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r171519778
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -40,6 +41,10 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r171489737
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -40,6 +41,10 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r171486224
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -40,6 +41,10 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r171485997
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -40,6 +41,10 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r171153715
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,63 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r171152501
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,63 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r171148057
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,63 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170847978
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170847138
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170845905
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170844335
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170844519
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170844540
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170844554
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170844986
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170843830
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170843555
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170843441
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170842725
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170842569
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,58 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170822587
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,63 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170821804
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,63 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170821083
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,63 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170820691
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,63 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170501977
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +319,55 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170501590
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +319,55 @@ class JobCancellationSuite extends SparkFunSuite with
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170501479
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -18,15 +18,14 @@
package org.apache.spark
import
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170501431
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,16 @@ private[spark] class
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r170457215
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,16 @@ private[spark] class
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r167158719
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,16 @@ private[spark] class
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r166877282
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,41 @@ class JobCancellationSuite extends SparkFunSuite with
Github user jerryshao commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r166875113
--- Diff: core/src/test/scala/org/apache/spark/JobCancellationSuite.scala
---
@@ -320,6 +321,41 @@ class JobCancellationSuite extends SparkFunSuite with
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r166864792
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,18 @@ private[spark] class
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r166857525
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,18 @@ private[spark] class
Github user advancedxy commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r165066153
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,18 @@ private[spark] class
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20449#discussion_r165051362
--- Diff:
core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala ---
@@ -104,9 +104,18 @@ private[spark] class
GitHub user advancedxy opened a pull request:
https://github.com/apache/spark/pull/20449
[SPARK-23040][CORE]: Returns interruptible iterator for shuffle reader
## What changes were proposed in this pull request?
Before this commit, a non-interruptible iterator is returned
40 matches
Mail list logo
