This is an automated email from the ASF dual-hosted git repository.
lixiao pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from 590b9a0 [SPARK-31010][SQL][FOLLOW-UP] Add Java UDF suggestion in
error message of untyped Scala UDF
add 34c7ec8 [SPARK-31253][SQL] Add metrics to AQE shuffle reader
No new revisions were added by this update.
Summary of changes:
.../spark/sql/execution/ShuffledRowRDD.scala | 16 ++-
.../adaptive/CoalesceShufflePartitions.scala | 6 +-
.../adaptive/CustomShuffleReaderExec.scala | 114 ++++++++++++++++++---
.../adaptive/OptimizeLocalShuffleReader.scala | 15 ++-
.../execution/adaptive/OptimizeSkewedJoin.scala | 82 ++++-----------
.../sql/execution/adaptive/QueryStageExec.scala | 5 +
.../execution/CoalesceShufflePartitionsSuite.scala | 23 +++--
.../adaptive/AdaptiveQueryExecSuite.scala | 74 ++++++++++++-
8 files changed, 229 insertions(+), 106 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
