format

Author: bobhan1

be/src/cloud/cloud_delete_task.cpp

@@ -102,8 +102,7 @@ Status CloudDeleteTask::execute(CloudStorageEngine& engine, const TPushReq& requ
         return st;
     }
 
-    st = engine.meta_mgr().commit_rowset(*rowset->rowset_meta(), "", nullptr,
-                                         tablet->table_id());
+    st = engine.meta_mgr().commit_rowset(*rowset->rowset_meta(), "", nullptr, tablet->table_id());
     if (!st.ok()) {
         LOG(WARNING) << "failed to commit rowset, status=" << st.to_string();
         return st;

be/src/cloud/cloud_schema_change_job.cpp

@@ -418,9 +418,8 @@ Status CloudSchemaChangeJob::_convert_historical_rowsets(const SchemaChangeParam
                                          st.to_string());
         }
 
-                st = _cloud_storage_engine.meta_mgr().commit_rowset(*rowset_writer->rowset_meta(), _job_id,
-                                                             &existed_rs_meta,
-                                                             _new_tablet->table_id());
+        st = _cloud_storage_engine.meta_mgr().commit_rowset(
+                *rowset_writer->rowset_meta(), _job_id, &existed_rs_meta, _new_tablet->table_id());
         if (!st.ok()) {
             if (st.is<ALREADY_EXIST>()) {
                 LOG(INFO) << "Rowset " << rs_reader->version() << " has already existed in tablet "

be/src/cloud/cloud_warm_up_manager.cpp

@@ -501,8 +501,7 @@ Status CloudWarmUpManager::set_event(int64_t job_id, TWarmUpEventType::type even
 }
 
 std::vector<TReplicaInfo> CloudWarmUpManager::get_replica_info(int64_t tablet_id, int64_t table_id,
-                                                               bool bypass_cache,
-                                                               bool& cache_hit) {
+                                                               bool bypass_cache, bool& cache_hit) {
     std::vector<TReplicaInfo> replicas;
     std::vector<int64_t> cancelled_jobs;
     std::lock_guard<std::mutex> lock(_mtx);

be/src/cloud/cloud_warm_up_manager.h

@@ -114,8 +114,7 @@ class CloudWarmUpManager {
                               int64_t sync_wait_timeout_ms, bool skip_existence_check);
 
     std::vector<TReplicaInfo> get_replica_info(int64_t tablet_id, int64_t table_id,
-                                               bool bypass_cache,
-                                               bool& cache_hit);
+                                               bool bypass_cache, bool& cache_hit);
 
     void _warm_up_rowset(RowsetMeta& rs_meta, int64_t table_id, int64_t sync_wait_timeout_ms);
     void _recycle_cache(int64_t tablet_id, const std::vector<RecycledRowsets>& rowsets);

be/src/storage/compaction/compaction.cpp

@@ -1636,7 +1636,7 @@ Status CloudCompactionMixin::execute_compact_impl(int64_t permits) {
     update_compaction_level();
 
     RETURN_IF_ERROR(_engine.meta_mgr().commit_rowset(*_output_rowset->rowset_meta().get(), _uuid,
-                                                    nullptr, _tablet->table_id()));
+                                                     nullptr, _tablet->table_id()));
 
     // 4. modify rowsets in memory
     RETURN_IF_ERROR(modify_rowsets());

be/test/cloud/cloud_warm_up_manager_filter_test.cpp

@@ -15,15 +15,14 @@
 // specific language governing permissions and limitations
 // under the License.
 
-#include "cloud/cloud_warm_up_manager.h"
-
 #include <gtest/gtest.h>
 
 #include <optional>
 #include <unordered_set>
 #include <vector>
 
 #include "cloud/cloud_storage_engine.h"
+#include "cloud/cloud_warm_up_manager.h"
 #include "gen_cpp/AgentService_types.h"
 
 namespace doris {