fix test case

src/graph/executor/admin/AddHostsExecutor.cpp

@@ -1,7 +1,6 @@
 /* Copyright (c) 2021 vesoft inc. All rights reserved.
  *
- * This source code is licensed under Apache 2.0 License,
- * attached with Common Clause Condition 1.0, found in the LICENSES directory.
+ * This source code is licensed under Apache 2.0 License.
  */
 
 #include "graph/executor/admin/AddHostsExecutor.h"

src/graph/executor/admin/AddHostsExecutor.h

@@ -1,7 +1,6 @@
 /* Copyright (c) 2021 vesoft inc. All rights reserved.
  *
- * This source code is licensed under Apache 2.0 License,
- * attached with Common Clause Condition 1.0, found in the LICENSES directory.
+ * This source code is licensed under Apache 2.0 License.
  */
 
 #ifndef GRAPH_EXECUTOR_ADMIN_ADD_HOST_EXECUTOR_H_

src/graph/executor/admin/DropHostsExecutor.cpp

@@ -1,7 +1,6 @@
 /* Copyright (c) 2021 vesoft inc. All rights reserved.
  *
- * This source code is licensed under Apache 2.0 License,
- * attached with Common Clause Condition 1.0, found in the LICENSES directory.
+ * This source code is licensed under Apache 2.0 License.
  */
 
 #include "graph/executor/admin/DropHostsExecutor.h"

src/graph/executor/admin/DropHostsExecutor.h

@@ -1,7 +1,6 @@
 /* Copyright (c) 2021 vesoft inc. All rights reserved.
  *
- * This source code is licensed under Apache 2.0 License,
- * attached with Common Clause Condition 1.0, found in the LICENSES directory.
+ * This source code is licensed under Apache 2.0 License.
  */
 
 #ifndef GRAPH_EXECUTOR_ADMIN_DROP_HOST_EXECUTOR_H_

src/graph/executor/admin/ZoneExecutor.cpp

@@ -18,7 +18,18 @@ folly::Future<Status> MergeZoneExecutor::execute() {
 
 folly::Future<Status> RenameZoneExecutor::execute() {
   SCOPED_TIMER(&execTime_);
-  return Status::OK();
+  auto *rzNode = asNode<RenameZone>(node());
+  return qctx()
+      ->getMetaClient()
+      ->renameZone(rzNode->originalZoneName(), rzNode->zoneName())
+      .via(runner())
+      .thenValue([](StatusOr<bool> resp) {
+        if (!resp.ok()) {
+          LOG(ERROR) << "Rename Zone Failed :" << resp.status();
+          return resp.status();
+        }
+        return Status::OK();
+      });
 }
 
 folly::Future<Status> DropZoneExecutor::execute() {

src/graph/validator/AdminValidator.cpp

@@ -20,9 +20,7 @@ Status CreateSpaceValidator::validateImpl() {
   ifNotExist_ = sentence->isIfNotExist();
   auto status = Status::OK();
   spaceDesc_.set_space_name(std::move(*(sentence->spaceName())));
-  if (sentence->zoneNames()) {
-    spaceDesc_.set_zone_names(sentence->zoneNames()->zoneNames());
-  }
+  spaceDesc_.set_zone_names(sentence->zoneNames()->zoneNames());
   StatusOr<std::string> retStatusOr;
   std::string result;
   auto *charsetInfo = qctx_->getCharsetInfo();

src/meta/CMakeLists.txt

@@ -86,6 +86,8 @@ nebula_add_library(
     processors/zone/DropZoneProcessor.cpp
     processors/zone/RenameZoneProcessor.cpp
     processors/zone/GetZoneProcessor.cpp
+    processors/zone/MergeZoneProcessor.cpp
+    processors/zone/SplitZoneProcessor.cpp
     processors/zone/ListZonesProcessor.cpp
     processors/listener/ListenerProcessor.cpp
     processors/session/SessionManagerProcessor.cpp

src/meta/MetaServiceHandler.cpp

@@ -67,7 +67,9 @@
 #include "meta/processors/zone/DropZoneProcessor.h"
 #include "meta/processors/zone/GetZoneProcessor.h"
 #include "meta/processors/zone/ListZonesProcessor.h"
+#include "meta/processors/zone/MergeZoneProcessor.h"
 #include "meta/processors/zone/RenameZoneProcessor.h"
+#include "meta/processors/zone/SplitZoneProcessor.h"
 
 #define RETURN_FUTURE(processor)   \
   auto f = processor->getFuture(); \
@@ -445,6 +447,16 @@ folly::Future<cpp2::GetZoneResp> MetaServiceHandler::future_getZone(const cpp2::
   RETURN_FUTURE(processor);
 }
 
+folly::Future<cpp2::ExecResp> MetaServiceHandler::future_mergeZone(const cpp2::MergeZoneReq& req) {
+  auto* processor = MergeZoneProcessor::instance(kvstore_);
+  RETURN_FUTURE(processor);
+}
+
+folly::Future<cpp2::ExecResp> MetaServiceHandler::future_splitZone(const cpp2::SplitZoneReq& req) {
+  auto* processor = SplitZoneProcessor::instance(kvstore_);
+  RETURN_FUTURE(processor);
+}
+
 folly::Future<cpp2::ListZonesResp> MetaServiceHandler::future_listZones(
     const cpp2::ListZonesReq& req) {
   auto* processor = ListZonesProcessor::instance(kvstore_);

src/meta/MetaServiceHandler.h

@@ -186,6 +186,10 @@ class MetaServiceHandler final : public cpp2::MetaServiceSvIf {
 
   folly::Future<cpp2::GetZoneResp> future_getZone(const cpp2::GetZoneReq& req) override;
 
+  folly::Future<cpp2::ExecResp> future_mergeZone(const cpp2::MergeZoneReq& req) override;
+
+  folly::Future<cpp2::ExecResp> future_splitZone(const cpp2::SplitZoneReq& req) override;
+
   folly::Future<cpp2::ListZonesResp> future_listZones(const cpp2::ListZonesReq& req) override;
 
   folly::Future<cpp2::ExecResp> future_addHostsIntoZone(
@@ -210,6 +214,7 @@ class MetaServiceHandler final : public cpp2::MetaServiceSvIf {
 
   folly::Future<cpp2::GetMetaDirInfoResp> future_getMetaDirInfo(
       const cpp2::GetMetaDirInfoReq& req) override;
+
   folly::Future<cpp2::CreateSessionResp> future_createSession(
       const cpp2::CreateSessionReq& req) override;
 

src/meta/processors/parts/CreateSpaceAsProcessor.cpp

@@ -47,7 +47,6 @@ void CreateSpaceAsProcessor::process(const cpp2::CreateSpaceAsReq &req) {
   }
 
   std::vector<kvstore::KV> data;
-
   auto newSpaceData =
       makeNewSpaceData(nebula::value(oldSpaceId), nebula::value(newSpaceId), newSpaceName);
   if (nebula::ok(newSpaceData)) {
@@ -123,9 +122,10 @@ ErrorOr<nebula::cpp2::ErrorCode, std::vector<kvstore::KV>> CreateSpaceAsProcesso
     return nebula::error(partPrefix);
   }
   auto iter = nebula::value(partPrefix).get();
-  for (; iter->valid(); iter->next()) {
+  while (iter->valid()) {
     auto partId = MetaKeyUtils::parsePartKeyPartId(iter->key());
     data.emplace_back(MetaKeyUtils::partKey(newSpaceId, partId), iter->val());
+    iter->next();
   }
   return data;
 }
@@ -145,7 +145,7 @@ ErrorOr<nebula::cpp2::ErrorCode, std::vector<kvstore::KV>> CreateSpaceAsProcesso
 
   std::vector<kvstore::KV> data;
   auto iter = nebula::value(tagPrefix).get();
-  for (; iter->valid(); iter->next()) {
+  while (iter->valid()) {
     auto val = iter->val();
 
     auto tagId = MetaKeyUtils::parseTagId(iter->key());
@@ -157,6 +157,7 @@ ErrorOr<nebula::cpp2::ErrorCode, std::vector<kvstore::KV>> CreateSpaceAsProcesso
     auto tagVer = MetaKeyUtils::parseTagVersion(iter->key());
     auto key = MetaKeyUtils::schemaTagKey(newSpaceId, tagId, tagVer);
     data.emplace_back(std::move(key), val.str());
+    iter->next();
   }
   return data;
 }
@@ -176,7 +177,7 @@ ErrorOr<nebula::cpp2::ErrorCode, std::vector<kvstore::KV>> CreateSpaceAsProcesso
 
   std::vector<kvstore::KV> data;
   auto iter = nebula::value(edgePrefix).get();
-  for (; iter->valid(); iter->next()) {
+  while (iter->valid()) {
     auto val = iter->val();
 
     auto edgeType = MetaKeyUtils::parseEdgeType(iter->key());
@@ -188,6 +189,7 @@ ErrorOr<nebula::cpp2::ErrorCode, std::vector<kvstore::KV>> CreateSpaceAsProcesso
     auto ver = MetaKeyUtils::parseEdgeVersion(iter->key());
     auto key = MetaKeyUtils::schemaEdgeKey(newSpaceId, edgeType, ver);
     data.emplace_back(std::move(key), val.str());
+    iter->next();
   }
   return data;
 }
@@ -207,7 +209,7 @@ ErrorOr<nebula::cpp2::ErrorCode, std::vector<kvstore::KV>> CreateSpaceAsProcesso
 
   std::vector<kvstore::KV> data;
   auto iter = nebula::value(indexPrefix).get();
-  for (; iter->valid(); iter->next()) {
+  while (iter->valid()) {
     auto val = iter->val();
 
     auto indexId = MetaKeyUtils::parseIndexesKeyIndexID(iter->key());
@@ -219,6 +221,7 @@ ErrorOr<nebula::cpp2::ErrorCode, std::vector<kvstore::KV>> CreateSpaceAsProcesso
                       std::string(reinterpret_cast<const char *>(&indexId), sizeof(indexId)));
 
     data.emplace_back(MetaKeyUtils::indexKey(newSpaceId, indexId), MetaKeyUtils::indexVal(idxItem));
+    iter->next();
   }
   return data;
 }