This is an automated email from the ASF dual-hosted git repository.
nicholasjiang pushed a change to branch branch-0.6
in repository https://gitbox.apache.org/repos/asf/celeborn.git
omit af16d19ca [CELEBORN-2112] Introduce PausePushDataStatus and
PausePushDataAndReplicateStatus metric to record status of pause push data
omit a1bb38c88 [CELEBORN-2106] CommitFile/Reserved location shows detail
primary location UniqueId
omit 834fb1a50 [CELEBORN-2102] Introduce SorterCacheHitRate metric to
monitor the hit reate of index cache for sorter
omit 484fd6aae [CELEBORN-2108] Remove redundant PartitionType
omit 91a3a1a98 [CELEBORN-2119] DfsTierWriter should close
s3MultipartUploadHandler and ossMultipartUploadHandler for close resource
omit 9c7d466f6 [CELEBORN-2117] Use git submodules for Chart Actions
omit 730524c23 [CELEBORN-2100] Fix performance issue on readToReadOnlyBuffer
omit 16b12053c [CELEBORN-2090] Support Lz4 Decompression in CppClient
omit f9ed782ec [CELEBORN-2085] Use a fixed buffer for flush copying to
reduce GC
omit ad2d7f3dd [CELEBORN-1844][FOLLOWUP] Fix the condition of StoragePolicy
that worker uses memory storage
omit 0360c80da [CELEBORN-1792][FOLLOWUP] Add missing break in
resumeByPinnedMemory
omit f06125899 [CELEBORN-2093] Support Flink 2.1
new 25f9e5282 [CELEBORN-1792][FOLLOWUP] Add missing break in
resumeByPinnedMemory
new d881e0b47 [CELEBORN-1844][FOLLOWUP] Fix the condition of StoragePolicy
that worker uses memory storage
new 047edf035 [CELEBORN-2085] Use a fixed buffer for flush copying to
reduce GC
new ccb09d80c [CELEBORN-2090] Support Lz4 Decompression in CppClient
new bafd4b3c1 [CELEBORN-2100] Fix performance issue on readToReadOnlyBuffer
new 448d54211 [CELEBORN-2117] Use git submodules for Chart Actions
new 13530f859 [CELEBORN-2119] DfsTierWriter should close
s3MultipartUploadHandler and ossMultipartUploadHandler for close resource
new d82f37fd4 [CELEBORN-2108] Remove redundant PartitionType
new e743cae1c [CELEBORN-2102] Introduce SorterCacheHitRate metric to
monitor the hit reate of index cache for sorter
new f176c525c [CELEBORN-2106] CommitFile/Reserved location shows detail
primary location UniqueId
new fc8b8dd67 [CELEBORN-2112] Introduce PausePushDataStatus and
PausePushDataAndReplicateStatus metric to record status of pause push data
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (af16d19ca)
\
N -- N -- N refs/heads/branch-0.6 (fc8b8dd67)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/deps.yml | 1 -
.github/workflows/license.yml | 1 -
.github/workflows/maven.yml | 1 -
.github/workflows/sbt.yml | 1 -
.github/workflows/style.yml | 1 -
README.md | 3 +-
build/make-distribution.sh | 2 -
build/release/release.sh | 4 -
client-flink/flink-2.1-shaded/pom.xml | 137 -----
.../src/main/resources/META-INF/LICENSE | 248 --------
.../src/main/resources/META-INF/NOTICE | 45 --
.../META-INF/licenses/LICENSE-protobuf.txt | 42 --
client-flink/flink-2.1/pom.xml | 75 ---
.../plugin/flink/RemoteShuffleInputGate.java | 195 -------
.../flink/RemoteShuffleInputGateFactory.java | 64 --
.../plugin/flink/RemoteShuffleResultPartition.java | 77 ---
.../flink/RemoteShuffleResultPartitionFactory.java | 93 ---
.../plugin/flink/RemoteShuffleServiceFactory.java | 61 --
.../flink/tiered/CelebornChannelBufferManager.java | 165 ------
.../flink/tiered/CelebornChannelBufferReader.java | 337 -----------
.../flink/tiered/CelebornTierConsumerAgent.java | 556 ------------------
.../plugin/flink/tiered/CelebornTierFactory.java | 137 -----
.../flink/tiered/CelebornTierMasterAgent.java | 219 -------
.../flink/tiered/CelebornTierProducerAgent.java | 503 ----------------
.../flink/tiered/TierShuffleDescriptorImpl.java | 72 ---
.../plugin/flink/RemoteShuffleMasterSuiteJ.java | 395 -------------
.../RemoteShuffleResultPartitionFactorySuiteJ.java | 51 --
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 643 ---------------------
.../flink/RemoteShuffleServiceFactorySuiteJ.java | 58 --
.../plugin/flink/ShuffleResourceTrackerSuiteJ.java | 152 -----
.../tiered/CelebornTierMasterAgentSuiteJ.java | 201 -------
dev/dependencies.sh | 4 -
dev/deps/dependencies-client-flink-2.1 | 80 ---
dev/reformat | 1 -
docs/README.md | 4 +-
docs/deploy.md | 2 +-
docs/developers/sbt.md | 1 -
pom.xml | 19 -
project/CelebornBuild.scala | 11 -
.../apache/celeborn/tests/flink/FlinkVersion.java | 5 +-
40 files changed, 5 insertions(+), 4662 deletions(-)
delete mode 100644 client-flink/flink-2.1-shaded/pom.xml
delete mode 100644
client-flink/flink-2.1-shaded/src/main/resources/META-INF/LICENSE
delete mode 100644
client-flink/flink-2.1-shaded/src/main/resources/META-INF/NOTICE
delete mode 100644
client-flink/flink-2.1-shaded/src/main/resources/META-INF/licenses/LICENSE-protobuf.txt
delete mode 100644 client-flink/flink-2.1/pom.xml
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java
delete mode 100644
client-flink/flink-2.1/src/main/java/org/apache/celeborn/plugin/flink/tiered/TierShuffleDescriptorImpl.java
delete mode 100644
client-flink/flink-2.1/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java
delete mode 100644
client-flink/flink-2.1/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactorySuiteJ.java
delete mode 100644
client-flink/flink-2.1/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
delete mode 100644
client-flink/flink-2.1/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuiteJ.java
delete mode 100644
client-flink/flink-2.1/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerSuiteJ.java
delete mode 100644
client-flink/flink-2.1/src/test/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgentSuiteJ.java
delete mode 100644 dev/deps/dependencies-client-flink-2.1
