small fix

XiaoMi · Apr 30, 2020 · 860bfdd · 860bfdd
1 parent fb02c3c
commit 860bfdd
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/dist/replication/meta_server/meta_bulk_load_service.cpp b/src/dist/replication/meta_server/meta_bulk_load_service.cpp
@@ -44,7 +44,7 @@ void bulk_load_service::create_bulk_load_root_dir(error_code &err, task_tracker
                 dwarn_f("create bulk load root({}) failed, retry later", _bulk_load_root);
                 tasking::enqueue(
                     LPC_META_STATE_NORMAL,
-                    nullptr,
+                    _meta_svc->tracker(),
                     std::bind(&bulk_load_service::create_bulk_load_root_dir, this, err, tracker),
                     0,
                     std::chrono::seconds(1));

diff --git a/src/dist/replication/meta_server/meta_bulk_load_service.h b/src/dist/replication/meta_server/meta_bulk_load_service.h
@@ -109,7 +109,7 @@ class bulk_load_service
     zrwlock_nr &app_lock() const { return _state->_lock; }
     zrwlock_nr _lock; // bulk load states lock
 
-    std::string _bulk_load_root; // <cluster_root>/bulk_load
+    const std::string _bulk_load_root; // <cluster_root>/bulk_load
 
     /// bulk load states
     std::unordered_set<int32_t> _bulk_load_app_id;

diff --git a/src/dist/replication/meta_server/meta_service.cpp b/src/dist/replication/meta_server/meta_service.cpp
@@ -243,7 +243,7 @@ void meta_service::start_service()
 
     if (_bulk_load_svc) {
         ddebug("start bulk load service");
-        tasking::enqueue(LPC_META_STATE_NORMAL, nullptr, [this]() {
+        tasking::enqueue(LPC_META_STATE_NORMAL, tracker(), [this]() {
             _bulk_load_svc->initialize_bulk_load_service();
         });
     }