Fix some typos(ingest_externel_file, etc) (PaddlePaddle#62040)

Difers · Feb 26, 2024 · 67bd48f · 67bd48f
1 parent 5508f55
commit 67bd48f
Show file tree

Hide file tree

Showing 7 changed files with 9 additions and 9 deletions.
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
@@ -30,7 +30,7 @@ ReplicatedSPMDRule::InferForward(const std::vector<DistTensorSpec>& 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
@@ -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
@@ -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<std::string>& 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
@@ -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
@@ -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<uint64_t> 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
@@ -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
@@ -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);