This is an automated email from the ASF dual-hosted git repository.
roryqi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git
from 351275d [ISSUE-111] Sleep less time but try more times when stopping
(#112)
add 687cac9 [Improvement] Use ConfigBuilder to rewrite the class
RssSparkConfig (#104)
No new revisions were added by this update.
Summary of changes:
.../org/apache/spark/shuffle/RssSparkConfig.java | 339 ++++++++++++++-------
.../apache/spark/shuffle/RssSparkShuffleUtils.java | 22 +-
.../spark/shuffle/writer/BufferManagerOptions.java | 40 ++-
.../spark/shuffle/RssSparkShuffleUtilsTest.java | 44 +--
.../shuffle/writer/WriteBufferManagerTest.java | 10 +-
.../spark/shuffle/DelegationRssShuffleManager.java | 14 +-
.../apache/spark/shuffle/RssShuffleManager.java | 73 ++---
.../spark/shuffle/writer/RssShuffleWriter.java | 15 +-
.../shuffle/DelegationRssShuffleManagerTest.java | 24 +-
.../spark/shuffle/writer/RssShuffleWriterTest.java | 32 +-
.../spark/shuffle/DelegationRssShuffleManager.java | 14 +-
.../apache/spark/shuffle/RssShuffleManager.java | 103 +++----
.../spark/shuffle/writer/RssShuffleWriter.java | 15 +-
.../shuffle/DelegationRssShuffleManagerTest.java | 24 +-
.../spark/shuffle/writer/RssShuffleWriterTest.java | 32 +-
.../uniffle/client/util/RssClientConfig.java | 6 +-
.../org/apache/uniffle/test/AutoAccessTest.java | 18 +-
.../uniffle/test/DynamicFetchClientConfTest.java | 16 +-
.../RepartitionWithHdfsMultiStorageRssTest.java | 2 +-
.../test/RepartitionWithLocalFileRssTest.java | 2 +-
.../RepartitionWithMemoryMultiStorageRssTest.java | 2 +-
.../uniffle/test/RepartitionWithMemoryRssTest.java | 2 +-
.../org/apache/uniffle/test/SimpleTestBase.java | 2 +-
.../uniffle/test/SparkIntegrationTestBase.java | 24 +-
.../test/SparkSQLWithDelegationShuffleManager.java | 4 +-
...arkSQLWithDelegationShuffleManagerFallback.java | 4 +-
.../uniffle/test/SparkSQLWithMemoryLocalTest.java | 2 +-
.../org/apache/uniffle/test/GetReaderTest.java | 2 +-
.../apache/uniffle/test/AQERepartitionTest.java | 2 +-
.../org/apache/uniffle/test/AQESkewedJoinTest.java | 6 +-
.../org/apache/uniffle/test/GetReaderTest.java | 2 +-
31 files changed, 471 insertions(+), 426 deletions(-)
