[GitHub] [spark] viirya commented on a change in pull request #31468: [SPARK-34353][SQL] CollectLimitExec avoid shuffle if input rdd has 0/1 partition

viirya commented on a change in pull request #31468: URL: https://github.com/apache/spark/pull/31468#discussion_r578951440 ## File path: sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala ## @@ -52,16 +53,25 @@ case class CollectLimitExec(limit: Int, child: Spar

[GitHub] [spark] viirya commented on a change in pull request #31468: [SPARK-34353][SQL] CollectLimitExec avoid shuffle if input rdd has 0/1 partition

viirya commented on a change in pull request #31468: URL: https://github.com/apache/spark/pull/31468#discussion_r578951088 ## File path: sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala ## @@ -52,16 +53,25 @@ case class CollectLimitExec(limit: Int, child: Spar

[GitHub] [spark] viirya commented on a change in pull request #31468: [SPARK-34353][SQL] CollectLimitExec avoid shuffle if input rdd has 0/1 partition

viirya commented on a change in pull request #31468: URL: https://github.com/apache/spark/pull/31468#discussion_r578914581 ## File path: sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala ## @@ -52,16 +53,25 @@ case class CollectLimitExec(limit: Int, child: Spar

[GitHub] [spark] viirya commented on a change in pull request #31468: [SPARK-34353][SQL] CollectLimitExec avoid shuffle if input rdd has 0/1 partition

viirya commented on a change in pull request #31468: URL: https://github.com/apache/spark/pull/31468#discussion_r578910294 ## File path: sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala ## @@ -52,16 +53,25 @@ case class CollectLimitExec(limit: Int, child: Spar