File tree Expand file tree Collapse file tree 2 files changed +2
-5
lines changed
cpp/celeborn/client/writer Expand file tree Collapse file tree 2 files changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -29,8 +29,7 @@ PushState::PushState(const conf::CelebornConf& conf)
2929 conf.clientPushMaxBytesSizeInFlightEnabled()),
3030 maxInFlightBytesSizeTotal_(conf.clientPushMaxBytesSizeInFlightTotal()),
3131 maxInFlightBytesSizePerWorker_(
32- conf.clientPushMaxBytesSizeInFlightPerWorker()) {
33- }
32+ conf.clientPushMaxBytesSizeInFlightPerWorker()) {}
3433
3534int PushState::nextBatchId () {
3635 return currBatchId_.fetch_add (1 );
Original file line number Diff line number Diff line change @@ -86,9 +86,7 @@ class PushState {
8686 std::string,
8787 std::shared_ptr<utils::ConcurrentHashSet<int >>>
8888 inflightBatchesPerAddress_;
89- utils::ConcurrentHashMap<
90- std::string,
91- std::shared_ptr<std::atomic<long >>>
89+ utils::ConcurrentHashMap<std::string, std::shared_ptr<std::atomic<long >>>
9290 inflightBytesSizePerAddress_;
9391 utils::ConcurrentHashMap<int , int > inflightBatchBytesSizes_;
9492 folly::Synchronized<std::unique_ptr<std::exception>> exception_;
You can’t perform that action at this time.
0 commit comments