This is an automated email from the ASF dual-hosted git repository.
wenchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from fda4070 [SPARK-29283][SQL] Error message is hidden when query from
JDBC, especially enabled adaptive execution
add 239ee3f [SPARK-9853][CORE] Optimize shuffle fetch of continuous
partition IDs
No new revisions were added by this update.
Summary of changes:
.../network/shuffle/ExternalBlockHandler.java | 28 ++++--
.../shuffle/ExternalShuffleBlockResolver.java | 24 ++++-
.../network/shuffle/OneForOneBlockFetcher.java | 35 ++++---
.../network/shuffle/ShuffleIndexInformation.java | 11 ++-
.../shuffle/protocol/FetchShuffleBlocks.java | 24 ++++-
.../shuffle/BlockTransferMessagesSuite.java | 5 +-
.../network/shuffle/ExternalBlockHandlerSuite.java | 25 ++++-
.../shuffle/ExternalShuffleBlockResolverSuite.java | 7 ++
.../shuffle/OneForOneBlockFetcherSuite.java | 22 ++++-
.../spark/network/netty/NettyBlockRpcServer.scala | 27 +++++-
.../spark/serializer/SerializerManager.scala | 1 +
.../spark/shuffle/BlockStoreShuffleReader.scala | 31 ++++++-
.../spark/shuffle/IndexShuffleBlockResolver.scala | 27 ++++--
.../spark/shuffle/ShuffleBlockResolver.scala | 4 +-
.../spark/shuffle/sort/SortShuffleManager.scala | 24 ++++-
.../scala/org/apache/spark/storage/BlockId.scala | 17 +++-
.../org/apache/spark/storage/BlockManager.scala | 2 +-
.../storage/ShuffleBlockFetcherIterator.scala | 71 ++++++++++++--
.../shuffle/BlockStoreShuffleReaderSuite.scala | 3 +-
.../org/apache/spark/storage/BlockIdSuite.scala | 14 +++
.../storage/ShuffleBlockFetcherIteratorSuite.scala | 103 +++++++++++++++++++--
.../org/apache/spark/sql/internal/SQLConf.scala | 13 +++
.../spark/sql/execution/ShuffledRowRDD.scala | 7 ++
23 files changed, 443 insertions(+), 82 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
