You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ka...@apache.org on 2020/07/15 04:41:58 UTC
[spark] branch master updated (af8e65f -> 542aefb)
This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from af8e65f [SPARK-32276][SQL] Remove redundant sorts before repartition nodes
add 542aefb [SPARK-31985][SS] Remove incomplete/undocumented stateful aggregation in continuous mode
No new revisions were added by this update.
Summary of changes:
.../analysis/UnsupportedOperationChecker.scala | 11 -
.../datasources/v2/DataSourceV2Strategy.scala | 14 +-
.../continuous/ContinuousCoalesceExec.scala | 45 ---
.../continuous/ContinuousCoalesceRDD.scala | 137 -------
.../streaming/continuous/ContinuousExecution.scala | 4 -
.../shuffle/ContinuousShuffleReadRDD.scala | 80 ----
.../shuffle/ContinuousShuffleReader.scala | 32 --
.../shuffle/ContinuousShuffleWriter.scala | 27 --
.../shuffle/RPCContinuousShuffleReader.scala | 138 -------
.../shuffle/RPCContinuousShuffleWriter.scala | 60 ---
.../execution/streaming/state/StateStoreRDD.scala | 14 +-
.../shuffle/ContinuousShuffleSuite.scala | 423 ---------------------
.../continuous/ContinuousAggregationSuite.scala | 134 -------
13 files changed, 2 insertions(+), 1117 deletions(-)
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousCoalesceExec.scala
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousCoalesceRDD.scala
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/ContinuousShuffleReadRDD.scala
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/ContinuousShuffleReader.scala
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/ContinuousShuffleWriter.scala
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/RPCContinuousShuffleReader.scala
delete mode 100644 sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/RPCContinuousShuffleWriter.scala
delete mode 100644 sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/ContinuousShuffleSuite.scala
delete mode 100644 sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousAggregationSuite.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org