fix

Signed-off-by: srlch <[email protected]>
StarRocks · Jan 2, 2025 · 244d215 · 244d215
1 parent 7ab83ad
commit 244d215
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 6 deletions.
diff --git a/be/src/exec/schema_scanner.cpp b/be/src/exec/schema_scanner.cpp
@@ -31,6 +31,8 @@
 #include "exec/schema_scanner/schema_be_threads_scanner.h"
 #include "exec/schema_scanner/schema_be_txns_scanner.h"
 #include "exec/schema_scanner/schema_charsets_scanner.h"
+#include "exec/schema_scanner/schema_cluster_snapshot_jobs_scanner.h"
+#include "exec/schema_scanner/schema_cluster_snapshots_scanner.h"
 #include "exec/schema_scanner/schema_collations_scanner.h"
 #include "exec/schema_scanner/schema_column_stats_usage_scanner.h"
 #include "exec/schema_scanner/schema_columns_scanner.h"
@@ -219,6 +221,10 @@ std::unique_ptr<SchemaScanner> SchemaScanner::create(TSchemaTableType::type type
         return std::make_unique<SchemaColumnStatsUsageScanner>();
     case TSchemaTableType::SCH_ANALYZE_STATUS:
         return std::make_unique<SchemaAnalyzeStatus>();
+    case TSchemaTableType::SCH_CLUSTER_SNAPSHOTS:
+        return std::make_unique<SchemaClusterSnapshotsScanner>();
+    case TSchemaTableType::SCH_CLUSTER_SNAPSHOT_JOBS:
+        return std::make_unique<SchemaClusterSnapshotJobsScanner>();
     default:
         return std::make_unique<SchemaDummyScanner>();
     }

diff --git a/be/src/exec/schema_scanner/schema_cluster_snapshot_jobs_scanner.cpp b/be/src/exec/schema_scanner/schema_cluster_snapshot_jobs_scanner.cpp
@@ -53,9 +53,8 @@ Status SchemaClusterSnapshotJobsScanner::_fill_chunk(ChunkPtr* chunk) {
     auto& slot_id_map = (*chunk)->get_slot_id_to_index_map();
     const TClusterSnapshotJobsItem& info = _result.items[_index];
     DatumArray datum_array{
-            Slice(info.snapshot_name), info.job_id,
-            info.created_time,         info.finished_time,
-            Slice(info.state),         Slice(info.detail_info),
+            Slice(info.snapshot_name), info.job_id,       info.created_time,
+            info.finished_time,        Slice(info.state), Slice(info.detail_info),
             Slice(info.error_message),
     };
     for (const auto& [slot_id, index] : slot_id_map) {

diff --git a/be/src/exec/schema_scanner/schema_helper.cpp b/be/src/exec/schema_scanner/schema_helper.cpp
@@ -230,13 +230,14 @@ Status SchemaHelper::get_analyze_status(const SchemaScannerState& state, const T
 Status SchemaHelper::get_cluster_snapshots_info(const SchemaScannerState& state, const TClusterSnapshotsRequest& req,
                                                 TClusterSnapshotsResponse* res) {
     return _call_rpc(state,
-                     [&req, &res](FrontendServiceConnection& client)  { client->getClusterSnapshotsInfo(*res, req); });
+                     [&req, &res](FrontendServiceConnection& client) { client->getClusterSnapshotsInfo(*res, req); });
 }
 
-Status SchemaHelper::get_cluster_snapshot_jobs_info(const SchemaScannerState& state, const TClusterSnapshotJobsRequest& req,
+Status SchemaHelper::get_cluster_snapshot_jobs_info(const SchemaScannerState& state,
+                                                    const TClusterSnapshotJobsRequest& req,
                                                     TClusterSnapshotJobsResponse* res) {
     return _call_rpc(
-            state, [&req, &res](FrontendServiceConnection& client)  { client->getClusterSnapshotJobsInfo(*res, req); });
+            state, [&req, &res](FrontendServiceConnection& client) { client->getClusterSnapshotJobsInfo(*res, req); });
 }
 
 void fill_data_column_with_null(Column* data_column) {

diff --git a/fe/fe-core/src/main/java/com/starrocks/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/com/starrocks/service/FrontendServiceImpl.java
@@ -3181,4 +3181,5 @@ public TClusterSnapshotsResponse getClusterSnapshotsInfo(TClusterSnapshotsReques
     @Override
     public TClusterSnapshotJobsResponse getClusterSnapshotJobsInfo(TClusterSnapshotJobsRequest params) {
         return new TClusterSnapshotJobsResponse();
+    }
 }