fix checkstyle

mymeiyi · Sep 26, 2024 · d1f1ad4 · d1f1ad4
1 parent 388dfa9
commit d1f1ad4
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 12 deletions.
diff --git a/be/src/cloud/cloud_tablet.cpp b/be/src/cloud/cloud_tablet.cpp
@@ -138,8 +138,7 @@ Status CloudTablet::capture_sub_txn_rs_readers(int64_t version,
  auto res = rowset->create_reader(&rs_reader);
  if (!res.ok()) {
  return Status::Error<ErrorCode::CAPTURE_ROWSET_READER_ERROR>(
- "failed to create reader for rowset:{}",
- rowset->rowset_id().to_string());
+ "failed to create reader for rowset:{}", rowset->rowset_id().to_string());
  }
  rs_splits->emplace_back(std::move(rs_reader));
  }

diff --git a/be/src/olap/base_tablet.h b/be/src/olap/base_tablet.h
@@ -104,7 +104,8 @@ class BaseTablet {
  std::vector<RowSetSplits>* rs_splits,
  bool skip_missing_version) = 0;
 
- virtual Status capture_sub_txn_rs_readers(int64_t version, const std::vector<int64_t>& sub_txn_ids,
+ virtual Status capture_sub_txn_rs_readers(int64_t version,
+ const std::vector<int64_t>& sub_txn_ids,
  std::vector<RowSetSplits>* rs_splits) = 0;
 
  virtual size_t tablet_footprint() = 0;

diff --git a/be/src/olap/parallel_scanner_builder.cpp b/be/src/olap/parallel_scanner_builder.cpp
@@ -172,7 +172,8 @@ Status ParallelScannerBuilder::_load() {
  const auto tablet_id = tablet->tablet_id();
  auto& read_source = _all_read_sources[tablet_id];
  if (sub_txn_ids.empty()) {
- RETURN_IF_ERROR(tablet->capture_rs_readers({0, version}, &read_source.rs_splits, false));
+ RETURN_IF_ERROR(
+ tablet->capture_rs_readers({0, version}, &read_source.rs_splits, false));
  } else {
  if (version > 0) {
  RETURN_IF_ERROR(

diff --git a/be/src/olap/tablet.cpp b/be/src/olap/tablet.cpp
@@ -941,8 +941,8 @@ Status Tablet::capture_sub_txn_rs_readers(int64_t version, const std::vector<int
  << ", sub_txn_ids.size=" << sub_txn_ids.size();
  for (int i = 0; i < sub_txn_ids.size(); ++i) {
  auto sub_txn_id = sub_txn_ids[i];
- auto rowset = _engine.txn_manager()->get_tablet_rowset(
- tablet_id(), tablet_uid(), partition_id(), sub_txn_id);
+ auto rowset = _engine.txn_manager()->get_tablet_rowset(tablet_id(), tablet_uid(),
+   partition_id(), sub_txn_id);
  DCHECK(rowset != nullptr) << " rowset is nullptr for sub_txn_id=" << sub_txn_ids[i]
  << ", partition_id=" << partition_id()
  << ", tablet=" << tablet_id();
@@ -958,8 +958,7 @@ Status Tablet::capture_sub_txn_rs_readers(int64_t version, const std::vector<int
  auto res = rowset->create_reader(&rs_reader);
  if (!res.ok()) {
  return Status::Error<ErrorCode::CAPTURE_ROWSET_READER_ERROR>(
- "failed to create reader for rowset:{}",
- rowset->rowset_id().to_string());
+ "failed to create reader for rowset:{}", rowset->rowset_id().to_string());
  }
  rs_splits->emplace_back(std::move(rs_reader));
  }

diff --git a/be/src/olap/txn_manager.cpp b/be/src/olap/txn_manager.cpp
@@ -792,8 +792,7 @@ void TxnManager::get_all_related_tablets(std::set<TabletInfo>* tablet_infos) {
 }
 
 RowsetSharedPtr TxnManager::get_tablet_rowset(TTabletId tablet_id, TabletUid tablet_uid,
- int64_t partition_id,
- TTransactionId transaction_id) {
+ int64_t partition_id, TTransactionId transaction_id) {
  pair<int64_t, int64_t> key(partition_id, transaction_id);
  std::shared_lock txn_rdlock(_get_txn_map_lock(transaction_id));
  txn_tablet_map_t& txn_tablet_map = _get_txn_tablet_map(transaction_id);

diff --git a/cloud/src/meta-service/meta_service.cpp b/cloud/src/meta-service/meta_service.cpp
@@ -1502,8 +1502,7 @@ void MetaServiceImpl::get_tmp_rowset(::google::protobuf::RpcController* controll
  it != version_to_schema.end()) {
  rowset_meta->mutable_tablet_schema()->CopyFrom(*it->second);
  } else {
- auto key = meta_schema_key(
- {instance_id, index_id, rowset_meta->schema_version()});
+ auto key = meta_schema_key({instance_id, index_id, rowset_meta->schema_version()});
  if (!try_fetch_and_parse_schema(txn.get(), *rowset_meta, key, code, msg)) {
  return;
  }