You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by et...@apache.org on 2022/11/16 11:56:30 UTC
[incubator-celeborn] branch branch-950 updated (40bee97d -> a6df5879)
This is an automated email from the ASF dual-hosted git repository.
ethanfeng pushed a change to branch branch-950
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
from 40bee97d Record app disk usage in HA mode.
add b8eb4c23 [ISSUE-929][BUG] Flusher thread interrupted and won't recover (#930)
add c86faf98 1.[BUG] Fix fetch incorrect data chunk (#926) 2.[ISSUE-939][REFACTOR] Bump up ratis to 2.4.0 (#940) 3.[ISSUE-925][FOLLOWUP] Refactor class name of RetryingChunkReceiveCallback (#954) 4.Add instructions for the latest release policy.
add a6df5879 Merge branch 'branch-0.1' into branch-950
No new revisions were added by this update.
Summary of changes:
README.md | 4 +-
.../{RetryingChunkClient.java => ChunkClient.java} | 192 ++++------
.../{MetricsCallback.java => PartitionReader.java} | 13 +-
.../com/aliyun/emr/rss/client/read/Replica.java | 94 +++++
.../aliyun/emr/rss/client/read/RssInputStream.java | 102 +-----
.../emr/rss/client/read/WorkerPartitionReader.java | 188 ++++++++++
.../rss/client/read/RetryingChunkClientSuiteJ.java | 394 ---------------------
.../network/client/ChunkReceivedCallback.java | 5 +-
.../rss/common/network/client/TransportClient.java | 2 +-
.../network/client/TransportResponseHandler.java | 9 +-
.../scala/com/aliyun/emr/rss/common/RssConf.scala | 4 +
.../network/ChunkFetchIntegrationSuiteJ.java | 5 +-
.../network/RequestTimeoutIntegrationSuiteJ.java | 5 +-
.../network/TransportResponseHandlerSuiteJ.java | 10 +-
pom.xml | 2 +-
.../clustermeta/ha/MasterStateMachineSuiteJ.java | 5 +-
.../rss/service/deploy/worker/DeviceMonitor.scala | 4 +-
.../service/deploy/worker/FileWriterSuiteJ.java | 5 +-
18 files changed, 399 insertions(+), 644 deletions(-)
rename client/src/main/java/com/aliyun/emr/rss/client/read/{RetryingChunkClient.java => ChunkClient.java} (58%)
copy client/src/main/java/com/aliyun/emr/rss/client/read/{MetricsCallback.java => PartitionReader.java} (83%)
create mode 100644 client/src/main/java/com/aliyun/emr/rss/client/read/Replica.java
create mode 100644 client/src/main/java/com/aliyun/emr/rss/client/read/WorkerPartitionReader.java
delete mode 100644 client/src/test/java/com/aliyun/emr/rss/client/read/RetryingChunkClientSuiteJ.java