diff --git a/paddle/fluid/distributed/auto_parallel/spmd_rules/replicated_spmd_rule.cc b/paddle/fluid/distributed/auto_parallel/spmd_rules/replicated_spmd_rule.cc index b0ffb47c99234..5227a82a4b8b5 100644 --- a/paddle/fluid/distributed/auto_parallel/spmd_rules/replicated_spmd_rule.cc +++ b/paddle/fluid/distributed/auto_parallel/spmd_rules/replicated_spmd_rule.cc @@ -30,7 +30,7 @@ ReplicatedSPMDRule::InferForward(const std::vector& input_specs, } // TODO(ljz): we need to know num of output and size of each output before - // generate the excat replicated dist tensor attr for the current op. + // generate the exact replicated dist tensor attr for the current op. // here we just assume that only one output tensor and has the same size as // the first input tensor. return {intput_dist_attrs, {ReplicatedOnMesh(input_specs[0].dist_attr())}}; diff --git a/paddle/fluid/distributed/ps/service/server.h b/paddle/fluid/distributed/ps/service/server.h index 5a0764b11e8a1..bae9ab652ff74 100644 --- a/paddle/fluid/distributed/ps/service/server.h +++ b/paddle/fluid/distributed/ps/service/server.h @@ -194,7 +194,7 @@ class PsBaseService : public PsService { const char *err_msg) { response.set_err_msg(err_msg); response.set_err_code(err_code); - LOG(WARNING) << "Resonse err_code:" << err_code << " msg:" << err_msg; + LOG(WARNING) << "Response err_code:" << err_code << " msg:" << err_msg; } virtual int32_t Initialize() = 0; diff --git a/paddle/fluid/distributed/ps/table/depends/rocksdb_warpper.h b/paddle/fluid/distributed/ps/table/depends/rocksdb_warpper.h index 873644f8ca416..b090ef778d2ac 100644 --- a/paddle/fluid/distributed/ps/table/depends/rocksdb_warpper.h +++ b/paddle/fluid/distributed/ps/table/depends/rocksdb_warpper.h @@ -237,7 +237,7 @@ class RocksDBHandler { Uint64Comparator* get_comparator() { return &_comparator; } - int ingest_externel_file(int id, + int ingest_external_file(int id, const std::vector& sst_filelist) { rocksdb::IngestExternalFileOptions ifo; ifo.move_files = true; diff --git a/paddle/fluid/distributed/ps/table/ssd_sparse_table.cc b/paddle/fluid/distributed/ps/table/ssd_sparse_table.cc index 13577bde3e145..d72b4ee1c3d3f 100644 --- a/paddle/fluid/distributed/ps/table/ssd_sparse_table.cc +++ b/paddle/fluid/distributed/ps/table/ssd_sparse_table.cc @@ -2896,7 +2896,7 @@ int32_t SSDSparseTable::LoadWithBinary(const std::string& path, int param) { auto sst_filelist = _afs_client.list(::paddle::string::format_string( "%s_%d/part-*", FLAGS_rocksdb_path.c_str(), shard_idx)); if (!sst_filelist.empty()) { - int ret = _db->ingest_externel_file(shard_idx, sst_filelist); + int ret = _db->ingest_external_file(shard_idx, sst_filelist); if (ret) { VLOG(0) << "ingest file failed"; abort(); @@ -3038,7 +3038,7 @@ int32_t SSDSparseTable::CacheTable(uint16_t pass_id) { } VLOG(0) << "write sst_file shard " << shard_id << ": " << butil::gettimeofday_ms() - show_begin << " ms"; - int ret = _db->ingest_externel_file(shard_id, {filename}); + int ret = _db->ingest_external_file(shard_id, {filename}); if (ret) { VLOG(0) << "ingest file failed" << ", " << status.getState(); diff --git a/paddle/fluid/distributed/ps/wrapper/fleet.cc b/paddle/fluid/distributed/ps/wrapper/fleet.cc index ac404f5d9e70c..44043bc65501c 100644 --- a/paddle/fluid/distributed/ps/wrapper/fleet.cc +++ b/paddle/fluid/distributed/ps/wrapper/fleet.cc @@ -918,8 +918,8 @@ std::default_random_engine& FleetWrapper::LocalRandomEngine() { clock_gettime(CLOCK_REALTIME, &tp); double cur_time = tp.tv_sec + tp.tv_nsec * 1e-9; static std::atomic x(0); - std::seed_seq sseq = {x++, x++, x++, (uint64_t)(cur_time * 1000)}; - engine.seed(sseq); + std::seed_seq s_seq = {x++, x++, x++, (uint64_t)(cur_time * 1000)}; + engine.seed(s_seq); } }; thread_local engine_wrapper_t r; diff --git a/paddle/fluid/distributed/ps/wrapper/fleet.h b/paddle/fluid/distributed/ps/wrapper/fleet.h index 208e94ec12102..95504ede00fad 100644 --- a/paddle/fluid/distributed/ps/wrapper/fleet.h +++ b/paddle/fluid/distributed/ps/wrapper/fleet.h @@ -288,7 +288,7 @@ class FleetWrapper { std::string GetDistDesc() const { CHECK(is_initialized_ == true) - << "fleetwrapper should be initialized first!!!"; + << "FleetWrapper should be initialized first!!!"; return dist_desc_; } diff --git a/paddle/fluid/distributed/test/graph_node_test.cc b/paddle/fluid/distributed/test/graph_node_test.cc index 26207a9ad8c9e..8c29c2bf1df3f 100644 --- a/paddle/fluid/distributed/test/graph_node_test.cc +++ b/paddle/fluid/distributed/test/graph_node_test.cc @@ -416,7 +416,7 @@ void RunBrpcPushSparse() { // auto ph_host2 = paddle::distributed::PSHost(ip2, port2, 1); // host_sign_list_.push_back(ph_host2.SerializeToString()); // // test-end - // // Srart Server + // // Start Server // std::thread* server_thread = new std::thread(RunServer); // std::thread* server_thread2 = new std::thread(RunServer2); // sleep(1);