Merge branch 'master' into profile-get-dst

vesoft-inc · Nov 16, 2022 · 144b687 · 144b687
2 parents 26c8a87 + 050f9f3
commit 144b687
Showing 1 changed file with 21 additions and 0 deletions.
diff --git a/src/tools/meta-dump/MetaDumpTool.cpp b/src/tools/meta-dump/MetaDumpTool.cpp
@@ -10,6 +10,7 @@
 #include "common/time/TimeUtils.h"
 #include "common/utils/MetaKeyUtils.h"
 #include "meta/ActiveHostsMan.h"
+#include "meta/processors/job/JobDescription.h"
 
 DEFINE_string(path, "", "rocksdb instance path");
 
@@ -273,6 +274,26 @@ class MetaDumper {
         iter->Next();
       }
     }
+    {
+      LOG(INFO) << "------------------------------------------\n\n";
+      LOG(INFO) << "Job info:";
+      prefix = MetaKeyUtils::jobPrefix();
+      iter->Seek(rocksdb::Slice(prefix));
+      while (iter->Valid() && iter->key().starts_with(prefix)) {
+        auto key = folly::StringPiece(iter->key().data(), iter->key().size());
+        auto val = folly::StringPiece(iter->value().data(), iter->value().size());
+        if (MetaKeyUtils::isJobKey(key)) {
+          auto jobRet = JobDescription::makeJobDescription(key, val);
+          auto job = nebula::value(jobRet);
+          LOG(INFO) << folly::sformat("space id: {}, job id: {}, status: {}",
+                                      job.getSpace(),
+                                      job.getJobId(),
+                                      JobStatus::toString(job.getStatus()));
+        }
+
+        iter->Next();
+      }
+    }
     if (iter) {
       delete iter;
     }