This is an automated email from the ASF dual-hosted git repository.
feiwang pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git
from a77a64b89 [CELEBORN-1835][CIP-8] Add tier writer base and memory tier
writer
add 75b697d81 [CELEBORN-1838] Interrupt spark task should not report fetch
failure
No new revisions were added by this update.
Summary of changes:
.../flink/client/FlinkShuffleClientImpl.java | 14 +--
client-spark/spark-3-4/pom.xml | 5 +
.../shuffle/celeborn/CelebornShuffleReader.scala | 33 ++++-
.../celeborn/CelebornShuffleReaderSuite.scala | 95 ++++++++++++++
.../apache/celeborn/client/DummyShuffleClient.java | 4 +
.../apache/celeborn/client/ShuffleClientImpl.java | 28 +++--
.../celeborn/client/ShuffleClientSuiteJ.java | 136 ++++++++++++++++++++-
project/CelebornBuild.scala | 2 +-
...stSuite.scala => CelebornStageRerunSuite.scala} | 4 +-
9 files changed, 293 insertions(+), 28 deletions(-)
create mode 100644
client-spark/spark-3-4/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReaderSuite.scala
rename client/src/{test =>
main}/java/org/apache/celeborn/client/DummyShuffleClient.java (97%)
rename
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/{CelebornShuffleLostSuite.scala
=> CelebornStageRerunSuite.scala} (96%)
