Fixed crash on leader change (vesoft-inc#549)

boshengchen · Jun 27, 2019 · 86eb34d · 86eb34d
1 parent 44a6de2
commit 86eb34d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/storage/BaseProcessor.inl b/src/storage/BaseProcessor.inl
@@ -41,9 +41,11 @@ void BaseProcessor<RESP>::doPut(GraphSpaceID spaceId,
         thriftResult.set_code(to(code));
         thriftResult.set_part_id(partId);
         if (code == kvstore::ResultCode::ERR_LEADER_CHANGED) {
+            nebula::cpp2::HostAddr leader;
             auto addr = kvstore_->partLeader(spaceId, partId);
-            thriftResult.get_leader()->set_ip(addr.first);
-            thriftResult.get_leader()->set_port(addr.second);
+            leader.set_ip(addr.first);
+            leader.set_port(addr.second);
+            thriftResult.set_leader(leader);
         }
         bool finished = false;
         {