Minor enhancement about error message

src/clients/meta/MetaClient.cpp

@@ -821,7 +821,7 @@ Status MetaClient::handleResponse(const RESP& resp) {
     case nebula::cpp2::ErrorCode::E_FAIL_TO_CONNECT:
       return Status::Error("Fail to connect!");
     case nebula::cpp2::ErrorCode::E_RPC_FAILURE:
-      return Status::Error("Rpc failure!");
+      return Status::Error("Rpc failure, probably timeout!");
     case nebula::cpp2::ErrorCode::E_LEADER_CHANGED:
       return Status::LeaderChanged("Leader changed!");
     case nebula::cpp2::ErrorCode::E_NO_HOSTS:
@@ -868,8 +868,6 @@ Status MetaClient::handleResponse(const RESP& resp) {
       return Status::Error("The balancer is running!");
     case nebula::cpp2::ErrorCode::E_CONFIG_IMMUTABLE:
       return Status::Error("Config immutable!");
-    case nebula::cpp2::ErrorCode::E_CONFLICT:
-      return Status::Error("Conflict!");
     case nebula::cpp2::ErrorCode::E_INVALID_PARM:
       return Status::Error("Invalid param!");
     case nebula::cpp2::ErrorCode::E_WRONGCLUSTER:
@@ -965,6 +963,8 @@ Status MetaClient::handleResponse(const RESP& resp) {
       return Status::Error("Related index exists, please drop index first");
     case nebula::cpp2::ErrorCode::E_RELATED_SPACE_EXISTS:
       return Status::Error("There are still space on the host");
+    case nebula::cpp2::ErrorCode::E_RELATED_FULLTEXT_INDEX_EXISTS:
+      return Status::Error("Related fulltext index exists, please drop it first");
     default:
       return Status::Error("Unknown error!");
   }

src/clients/storage/StorageClientBase-inl.h

@@ -205,7 +205,7 @@ folly::Future<StatusOr<Response>> StorageClientBase<ClientType, ClientManagerTyp
           invalidLeader(spaceId, partsId);
           LOG(ERROR) << "Request to " << host << " failed: " << ex->what();
         }
-        return Status::Error("RPC failure in StorageClient: %s", ex->what());
+        return Status::Error("RPC failure in StorageClient, probably timeout: %s", ex->what());
       });
 }
 

src/graph/executor/StorageAccessExecutor.h

@@ -56,6 +56,8 @@ class StorageAccessExecutor : public Executor {
 
   Status handleErrorCode(nebula::cpp2::ErrorCode code, PartitionID partId) const {
     switch (code) {
+      case nebula::cpp2::ErrorCode::E_RPC_FAILURE:
+        return Status::Error("Storage Error: RPC failure, probably timeout.");
       case nebula::cpp2::ErrorCode::E_KEY_NOT_FOUND:
         return Status::Error("Storage Error: Vertex or edge not found.");
       case nebula::cpp2::ErrorCode::E_DATA_TYPE_MISMATCH: {

src/interface/common.thrift

@@ -364,6 +364,7 @@ enum ErrorCode {
     E_SCHEMA_NAME_EXISTS              = -2013,  // Schema name already exists
     E_RELATED_INDEX_EXISTS            = -2014,  // There are still indexes related to tag or edge, cannot drop it
     E_RELATED_SPACE_EXISTS            = -2015,  // There are still some space on the host, cannot drop it
+    E_RELATED_FULLTEXT_INDEX_EXISTS   = -2016,  // There are still fulltext index on tag/edge
 
     E_STORE_FAILURE                   = -2021,  // Failed to store data
     E_STORE_SEGMENT_ILLEGAL           = -2022,  // Illegal storage segment

src/meta/processors/BaseProcessor-inl.h

@@ -453,7 +453,7 @@ nebula::cpp2::ErrorCode BaseProcessor<RESP>::indexCheck(
           if (it != indexCols.end()) {
             LOG(INFO) << "Index conflict, index :" << index.get_index_name()
                       << ", column : " << tCol.name;
-            return nebula::cpp2::ErrorCode::E_CONFLICT;
+            return nebula::cpp2::ErrorCode::E_RELATED_INDEX_EXISTS;
           }
         }
       }
@@ -474,7 +474,7 @@ nebula::cpp2::ErrorCode BaseProcessor<RESP>::ftIndexCheck(
             std::find_if(cols.begin(), cols.end(), [&](const auto& c) { return c == iCol.name; });
         if (it != cols.end()) {
           LOG(INFO) << "fulltext index conflict";
-          return nebula::cpp2::ErrorCode::E_CONFLICT;
+          return nebula::cpp2::ErrorCode::E_RELATED_FULLTEXT_INDEX_EXISTS;
         }
       }
     }

src/meta/processors/BaseProcessor.h

@@ -339,7 +339,7 @@ class BaseProcessor {
    * @tparam RESP
    * @param items
    * @param alterItems
-   * @return ErrorCode::E_CONFLICT if contains
+   * @return ErrorCode::E_RELATED_INDEX_EXISTS if contains
    */
   nebula::cpp2::ErrorCode indexCheck(const std::vector<cpp2::IndexItem>& items,
                                      const std::vector<cpp2::AlterSchemaItem>& alterItems);
@@ -350,7 +350,7 @@ class BaseProcessor {
    * @tparam RESP
    * @param cols
    * @param alterItems
-   * @return nebula::cpp2::ErrorCode
+   * @return ErrorCode::E_RELATED_FULLTEXT_INDEX_EXISTS if contains
    */
   nebula::cpp2::ErrorCode ftIndexCheck(const std::vector<std::string>& cols,
                                        const std::vector<cpp2::AlterSchemaItem>& alterItems);

src/meta/processors/index/CreateEdgeIndexProcessor.cpp

@@ -24,15 +24,15 @@ void CreateEdgeIndexProcessor::process(const cpp2::CreateEdgeIndexReq& req) {
   }
   if (fields.size() != columnSet.size()) {
     LOG(INFO) << "Conflict field in the edge index.";
-    handleErrorCode(nebula::cpp2::ErrorCode::E_CONFLICT);
+    handleErrorCode(nebula::cpp2::ErrorCode::E_INVALID_PARM);
     onFinished();
     return;
   }
 
   // A maximum of 16 columns are allowed in the index
   if (columnSet.size() > maxIndexLimit) {
     LOG(INFO) << "The number of index columns exceeds maximum limit " << maxIndexLimit;
-    handleErrorCode(nebula::cpp2::ErrorCode::E_CONFLICT);
+    handleErrorCode(nebula::cpp2::ErrorCode::E_INVALID_PARM);
     onFinished();
     return;
   }

src/meta/processors/index/CreateTagIndexProcessor.cpp

@@ -24,15 +24,15 @@ void CreateTagIndexProcessor::process(const cpp2::CreateTagIndexReq& req) {
   }
   if (fields.size() != columnSet.size()) {
     LOG(INFO) << "Conflict field in the tag index.";
-    handleErrorCode(nebula::cpp2::ErrorCode::E_CONFLICT);
+    handleErrorCode(nebula::cpp2::ErrorCode::E_INVALID_PARM);
     onFinished();
     return;
   }
 
   // A maximum of 16 columns are allowed in the index.
   if (columnSet.size() > maxIndexLimit) {
     LOG(INFO) << "The number of index columns exceeds maximum limit " << maxIndexLimit;
-    handleErrorCode(nebula::cpp2::ErrorCode::E_CONFLICT);
+    handleErrorCode(nebula::cpp2::ErrorCode::E_INVALID_PARM);
     onFinished();
     return;
   }

src/meta/processors/schema/CreateTagProcessor.cpp

@@ -22,7 +22,7 @@ void CreateTagProcessor::process(const cpp2::CreateTagReq& req) {
     LOG(INFO) << "Failed to create tag `" << tagName
               << "': some edge with the same name already exists.";
     resp_.id_ref() = to(nebula::value(conflictRet), EntryType::TAG);
-    handleErrorCode(nebula::cpp2::ErrorCode::E_CONFLICT);
+    handleErrorCode(nebula::cpp2::ErrorCode::E_SCHEMA_NAME_EXISTS);
     onFinished();
     return;
   } else {

src/meta/test/IndexProcessorTest.cpp

@@ -301,7 +301,7 @@ TEST(IndexProcessorTest, TagIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_INVALID_PARM, resp.get_code());
   }
   {
     cpp2::CreateTagIndexReq req;
@@ -665,7 +665,7 @@ TEST(IndexProcessorTest, EdgeIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_INVALID_PARM, resp.get_code());
   }
   {
     cpp2::CreateEdgeIndexReq req;
@@ -834,7 +834,7 @@ TEST(IndexProcessorTest, EdgeIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_INVALID_PARM, resp.get_code());
   }
   {
     cpp2::CreateEdgeIndexReq req;
@@ -846,7 +846,7 @@ TEST(IndexProcessorTest, EdgeIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_INVALID_PARM, resp.get_code());
   }
 }
 
@@ -1001,7 +1001,7 @@ TEST(IndexProcessorTest, IndexCheckAlterEdgeTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_INDEX_EXISTS, resp.get_code());
   }
   // Verify ErrorCode of drop
   {
@@ -1024,7 +1024,7 @@ TEST(IndexProcessorTest, IndexCheckAlterEdgeTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_INDEX_EXISTS, resp.get_code());
   }
 }
 
@@ -1128,7 +1128,7 @@ TEST(IndexProcessorTest, IndexCheckAlterTagTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_INDEX_EXISTS, resp.get_code());
   }
   {
     cpp2::AlterTagReq req;
@@ -1149,7 +1149,7 @@ TEST(IndexProcessorTest, IndexCheckAlterTagTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_INDEX_EXISTS, resp.get_code());
   }
 }
 
@@ -1997,7 +1997,7 @@ TEST(IndexProcessorTest, AlterWithFTIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_FULLTEXT_INDEX_EXISTS, resp.get_code());
   }
   {
     cpp2::AlterTagReq req;
@@ -2018,7 +2018,7 @@ TEST(IndexProcessorTest, AlterWithFTIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_FULLTEXT_INDEX_EXISTS, resp.get_code());
   }
   {
     cpp2::AlterTagReq req;
@@ -2060,7 +2060,7 @@ TEST(IndexProcessorTest, AlterWithFTIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_FULLTEXT_INDEX_EXISTS, resp.get_code());
   }
   {
     cpp2::AlterEdgeReq req;
@@ -2081,7 +2081,7 @@ TEST(IndexProcessorTest, AlterWithFTIndexTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_RELATED_FULLTEXT_INDEX_EXISTS, resp.get_code());
   }
   {
     cpp2::AlterEdgeReq req;

src/meta/test/ProcessorTest.cpp

@@ -848,7 +848,7 @@ TEST(ProcessorTest, CreateEdgeTest) {
     auto f = processor->getFuture();
     processor->process(req);
     auto resp = std::move(f).get();
-    ASSERT_EQ(nebula::cpp2::ErrorCode::E_CONFLICT, resp.get_code());
+    ASSERT_EQ(nebula::cpp2::ErrorCode::E_SCHEMA_NAME_EXISTS, resp.get_code());
   }
 
   // Set schema ttl property

src/tools/db-dump/CMakeLists.txt

@@ -18,15 +18,15 @@ nebula_add_executable(
         curl
 )
 
-install(
-    TARGETS
-        db_dump
-    PERMISSIONS
-        OWNER_EXECUTE OWNER_WRITE OWNER_READ
-        GROUP_EXECUTE GROUP_READ
-        WORLD_EXECUTE WORLD_READ
-    DESTINATION
-        bin
-    COMPONENT
-        tool
-)
+#install(
+#    TARGETS
+#        db_dump
+#    PERMISSIONS
+#        OWNER_EXECUTE OWNER_WRITE OWNER_READ
+#        GROUP_EXECUTE GROUP_READ
+#        WORLD_EXECUTE WORLD_READ
+#    DESTINATION
+#        bin
+#    COMPONENT
+#        tool
+#)