format

Author: morningman

be/src/cloud/cloud_engine_calc_delete_bitmap_task.cpp

@@ -236,8 +236,8 @@ Status CloudTabletCalcDeleteBitmapTask::handle() const {
         for (const auto& sub_txn_id : _sub_txn_ids) {
             ss << sub_txn_id << ", ";
         }
-        LOG(INFO) << "Start calculating delete bitmap for txn_id=" << _transaction_id << ", sub_txn_ids=["
-                  << ss.str() << "], table_id=" << tablet->table_id()
+        LOG(INFO) << "Start calculating delete bitmap for txn_id=" << _transaction_id
+                  << ", sub_txn_ids=[" << ss.str() << "], table_id=" << tablet->table_id()
                   << ", partition_id=" << tablet->partition_id() << ", tablet_id=" << _tablet_id
                   << ", start_version=" << _version;
         std::vector<RowsetSharedPtr> invisible_rowsets;

be/src/exprs/vbitmap_predicate.cpp

@@ -76,8 +76,7 @@ Status VBitmapPredicate::_do_execute(VExprContext* context, const Block* block,
                                      const uint8_t* __restrict filter, Selector* selector,
                                      size_t count, ColumnPtr& result_column) const {
     DCHECK(_open_finished || block == nullptr);
-    DCHECK(!(filter != nullptr && selector != nullptr))
-            << "filter and selector cannot be both set";
+    DCHECK(!(filter != nullptr && selector != nullptr)) << "filter and selector cannot be both set";
     DCHECK_EQ(_children.size(), 1);
 
     ColumnPtr argument_column;

be/src/exprs/vbloom_predicate.cpp

@@ -74,8 +74,7 @@ Status VBloomPredicate::_do_execute(VExprContext* context, const Block* block,
                                     const uint8_t* __restrict filter, Selector* selector,
                                     size_t count, ColumnPtr& result_column) const {
     DCHECK(_open_finished || block == nullptr);
-    DCHECK(!(filter != nullptr && selector != nullptr))
-            << "filter and selector cannot be both set";
+    DCHECK(!(filter != nullptr && selector != nullptr)) << "filter and selector cannot be both set";
     DCHECK_EQ(_children.size(), 1);
 
     ColumnPtr argument_column;

be/src/format/csv/csv_reader.cpp

@@ -770,8 +770,7 @@ Status CsvReader::_parse_col_nums(size_t* col_nums) {
     size_t size = 0;
     RETURN_IF_ERROR(_line_reader->read_line(&ptr, &size, &_line_reader_eof, _io_ctx));
     if (size == 0) {
-        return Status::InternalError<false>(
-                "The first line is empty, cannot parse column numbers");
+        return Status::InternalError<false>("The first line is empty, cannot parse column numbers");
     }
     if (!validate_utf8(_params, reinterpret_cast<const char*>(ptr), size)) {
         return Status::InternalError<false>("Only support csv data in utf8 codec");

be/src/io/cache/cache_lru_dumper.cpp

@@ -328,7 +328,8 @@ void CacheLRUDumper::do_dump_queue(LRUQueue& queue, const std::string& queue_nam
                 fmt::format("{}/lru_dump_{}.tail", _mgr->_cache_base_path, queue_name);
         std::ofstream out(tmp_filename, std::ios::binary);
         if (out) {
-            LOG(INFO) << "Begin to dump " << queue_name << " with " << elements.size() << " elements";
+            LOG(INFO) << "Begin to dump " << queue_name << " with " << elements.size()
+                      << " elements";
             for (const auto& [hash, offset, size] : elements) {
                 RETURN_IF_STATUS_ERROR(st,
                                        dump_one_lru_entry(out, tmp_filename, hash, offset, size));

be/src/io/cache/fs_file_cache_storage.cpp

@@ -465,7 +465,7 @@ Status FSFileCacheStorage::upgrade_cache_dir_if_necessary() const {
         exit(-1);
     } else if (version == "2.0") {
         VLOG_DEBUG << "Cache will upgrade from 2.0 to 3.0 progressively during running. 2.0 data "
-                     "format will evict eventually.";
+                      "format will evict eventually.";
         return Status::OK();
     } else if (version == "3.0") {
         LOG(INFO) << "Readly 3.0 format, no need to upgrade.";

be/src/storage/storage_engine.cpp

@@ -1292,8 +1292,7 @@ void StorageEngine::start_delete_unused_rowset() {
               << due_to_delayed_expired_ts << " rowsets due to delayed expired timestamp. left "
               << _unused_delete_bitmap.size() << " unused delete bitmap.";
     for (auto&& rs : unused_rowsets_copy) {
-        VLOG_NOTICE << "Start removing rowset:" << rs->rowset_id()
-                    << ", version:" << rs->version();
+        VLOG_NOTICE << "Start removing rowset:" << rs->rowset_id() << ", version:" << rs->version();
         // delete delete_bitmap of unused rowsets
         if (auto tablet = _tablet_manager->get_tablet(rs->rowset_meta()->tablet_id());
             tablet && tablet->enable_unique_key_merge_on_write()) {