Github user MaxGekk commented on a diff in the pull request:
https://github.com/apache/spark/pull/21913#discussion_r207525278
--- Diff:
streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala
---
@@ -313,9 +313,7 @@ private[streaming] object FileBased
Github user MaxGekk commented on a diff in the pull request:
https://github.com/apache/spark/pull/21913#discussion_r207524725
--- Diff: core/src/main/scala/org/apache/spark/util/ThreadUtils.scala ---
@@ -254,4 +254,49 @@ private[spark] object ThreadUtils {
executor.shutdo
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/21913#discussion_r206704908
--- Diff: core/src/main/scala/org/apache/spark/util/ThreadUtils.scala ---
@@ -254,4 +254,49 @@ private[spark] object ThreadUtils {
executor.shutdo
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/21913#discussion_r206704241
--- Diff: core/src/main/scala/org/apache/spark/util/ThreadUtils.scala ---
@@ -254,4 +254,49 @@ private[spark] object ThreadUtils {
executor.shutdo
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/21913#discussion_r206704548
--- Diff: core/src/main/scala/org/apache/spark/util/ThreadUtils.scala ---
@@ -254,4 +254,49 @@ private[spark] object ThreadUtils {
executor.shutdo
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/21913#discussion_r206704050
--- Diff:
streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala
---
@@ -313,9 +313,7 @@ private[streaming] object FileBased
GitHub user MaxGekk opened a pull request:
https://github.com/apache/spark/pull/21913
[WIP][SPARK-24005][CORE] Remove usage of Scalaâs parallel collection
## What changes were proposed in this pull request?
In the PR, I propose to replace usage of Scala parallel collection
