Proto commits in Tencent/Firestorm

These 9 commits are when the Protocol Buffers files have changed:

Commit:ac18880
Author:macduan
Committer:GitHub

[Feature] Remote storage can apply its own extra config (#143) ## What changes were proposed in this pull request? Add remote storage conf Server can apply the specific remote storage conf to its storage manager (HdfsStorageManager for now) client can apply specific conf of the remote storage it fetched The storage related hadoop conf and the hadoop conf in the spark context / mr jobConf should be isolated ## Why are the changes needed? Firestorm supports multiple remote storage and we may want to apply some extra/sepecific conf to different remote storage. ## Does this PR introduce any user-facing change? No ## How was this patch tested? UT and system test

The documentation is generated from this commit.

Commit:dc56f6d
Author:Colin
Committer:GitHub

[Feature] Support multiple HDFS in Firestorm (Part2 for Shuffle Server & Driver) (#121) What changes were proposed in this pull request? The PR is target to support multiple HDFS with RSS cluster, and it's the 2nd part for Shuffle Server & Driver Why are the changes needed? To release I/O pressure when with multiple HDFS cluster Does this PR introduce any user-facing change? No How was this patch tested? new UT added

Commit:1a89399
Author:Colin
Committer:GitHub

[Feature] Support multiple HDFS in Firestorm (Part1 for Coordinator &… (#110) * [Feature] Support multiple HDFS in Firestorm (Part1 for Coordinator & Driver)

Commit:459acff
Author:macduan
Committer:GitHub

[Feature] add the dynamic client conf fetching and updating (#81) ### What changes were proposed in this pull request? Add api to fetch client conf from coordinator Dynamic apply the client conf ### Why are the changes needed? Support dynamic update client conf and avoid the requirement to add some client conf other than shuffle manager, client jar. For now, we only read the conf from local file or hdfs, and we could support db and kv store or leverage a config center in the future. ### Does this PR introduce any user-facing change? No ### How was this patch tested? UT & System test

Commit:2cd2175
Author:macduan
Committer:GitHub

[Feature] Add AccessManager (#61) # What changes were proposed in this pull request? Add access manager to handle cron task access requests and add checkers to check the candidate list and cluster load respectively. # Why are the changes needed? We need to add candidates checking and control of the access when the cluster load is high. # Does this PR introduce any user-facing change? Yes, need to update the client to enable this feature. # How was this patch tested? UT and system test.

Commit:c838158
Author:Colin
Committer:GitHub

Support store shuffle data in memory (#36) What changes were proposed in this pull request? This pr is target to store shuffle data in memory. New flush strategy and read strategy are involved. The benefits with this change are: Huge memory is useful now There has no wait for data flush after stage finish Reduce flush data to storage Why are the changes needed? new RPC interface is involved Does this PR introduce any user-facing change? Yes, user need to update configuration for the new feature How was this patch tested? UT add

Commit:cce8824
Author:roryqi
Committer:GitHub

[Feature] Firestorm supports node's health check (#14) ### What changes were proposed in this pull request? Firestorm supports node's health check. There are some full disk nodes in our cluster, they influence the shuffle service. We should exclude them.Currently we only check disk usage, and exclude the unhealthy nodes. ### Why are the changes needed? Because we should have the mechanism to find the servers that can't serve, and screen them ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? newly added UTs Co-authored-by: roryqi <roryqi@tencent.com>

Commit:cfc6c31
Author:macduan
Committer:GitHub

[Feature] Read index file first in local mode (#6) * add local part * add index read length * resolve comments * Adjust some error handling * Use BytesValue unsafe wrap instead of ByteString copyFrom * Remove some unused imports Co-authored-by: macduan <macduan@tencent.com>

Commit:44ff317
Author:colinma

Initial version