Github user 10110346 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22723#discussion_r230579427
--- Diff:
core/src/main/scala/org/apache/spark/input/WholeTextFileInputFormat.scala ---
@@ -48,11 +50,11 @@ private[spark] class WholeTextFileInputFormat
Github user 10110346 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22723#discussion_r230579423
--- Diff:
core/src/main/scala/org/apache/spark/input/WholeTextFileInputFormat.scala ---
@@ -48,11 +50,11 @@ private[spark] class WholeTextFileInputFormat
Github user 10110346 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22723#discussion_r230579084
--- Diff: core/src/main/scala/org/apache/spark/rdd/WholeTextFileRDD.scala
---
@@ -51,7 +51,7 @@ private[spark] class WholeTextFileRDD(
case _ =>
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/22723#discussion_r229720799
--- Diff: core/src/main/scala/org/apache/spark/rdd/WholeTextFileRDD.scala
---
@@ -51,7 +51,7 @@ private[spark] class WholeTextFileRDD(
case _ =>
Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/22723#discussion_r229721018
--- Diff:
core/src/main/scala/org/apache/spark/input/WholeTextFileInputFormat.scala ---
@@ -48,11 +50,11 @@ private[spark] class WholeTextFileInputFormat
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22723#discussion_r229717747
--- Diff:
core/src/main/scala/org/apache/spark/input/WholeTextFileInputFormat.scala ---
@@ -48,11 +50,11 @@ private[spark] class WholeTextFileInputForma
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/22723#discussion_r229717581
--- Diff:
core/src/main/scala/org/apache/spark/input/WholeTextFileInputFormat.scala ---
@@ -48,11 +50,11 @@ private[spark] class WholeTextFileInputForma
GitHub user 10110346 opened a pull request:
https://github.com/apache/spark/pull/22723
[SPARK-25729][CORE]It is better to replace `minPartitions` with
`defaultParallelism` , when `minPartitions` is less than `defaultParallelism`
## What changes were proposed in this pull request?