diff --git a/src/kvstore/kvstore_dist.h b/src/kvstore/kvstore_dist.h index 0a13b6ab2635..59d9158012ef 100644 --- a/src/kvstore/kvstore_dist.h +++ b/src/kvstore/kvstore_dist.h @@ -292,9 +292,8 @@ class KVStoreDist : public KVStoreLocal { << " size: " << size; } auto vals = new ps::SArray(data, size, false); - CHECK_NOTNULL(ps_worker_)->ZPull(pskv.keys, vals, &pskv.lens, kRowSparsePushPull, [vals, cb]() { - delete vals; cb(); - }); + CHECK_NOTNULL(ps_worker_)->ZPull(pskv.keys, vals, &pskv.lens, kRowSparsePushPull, + [vals, cb]() { delete vals; cb(); }); }; CHECK_NOTNULL(Engine::Get())->PushAsync( pull_from_servers, @@ -464,7 +463,6 @@ class KVStoreDist : public KVStoreLocal { /// \brief send & recver buffer std::unordered_map comm_buf_; bool row_sparse_verbose_; - }; } // namespace kvstore diff --git a/src/kvstore/kvstore_dist_server.h b/src/kvstore/kvstore_dist_server.h index 5b3e8bff848f..59d2cb705654 100644 --- a/src/kvstore/kvstore_dist_server.h +++ b/src/kvstore/kvstore_dist_server.h @@ -382,7 +382,7 @@ class KVStoreDistServer { struct RequestBuf { std::vector requests; std::unordered_set change_set; - }; + }; std::unordered_map merge_buf_; std::unordered_map request_buf_;