Skip to content

Commit b1b9831

Browse files
committed
format
1 parent b26c3c2 commit b1b9831

File tree

2 files changed

+10
-5
lines changed

2 files changed

+10
-5
lines changed

be/src/agent/task_worker_pool.cpp

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1182,8 +1182,10 @@ void report_tablet_callback(StorageEngine& engine, const ClusterInfo* cluster_in
11821182
}
11831183
}
11841184

1185-
if (report_version < s_report_version || UNLIKELY(config::enable_debug_points &&
1186-
DebugPoints::instance()->is_enable("WorkPoolReportTablet.report_tablet_callback.skip"))) {
1185+
if (report_version < s_report_version ||
1186+
UNLIKELY(config::enable_debug_points &&
1187+
DebugPoints::instance()->is_enable(
1188+
"WorkPoolReportTablet.report_tablet_callback.skip"))) {
11871189
// TODO llj This can only reduce the possibility for report error, but can't avoid it.
11881190
// If FE create a tablet in FE meta and send CREATE task to this BE, the tablet may not be included in this
11891191
// report, and the report version has a small probability that it has not been updated in time. When FE
@@ -1271,8 +1273,10 @@ void report_tablet_callback(CloudStorageEngine& engine, const ClusterInfo* clust
12711273
}
12721274
}
12731275

1274-
if (report_version < s_report_version || UNLIKELY(config::enable_debug_points &&
1275-
DebugPoints::instance()->is_enable("WorkPoolCloudReportTablet.report_tablet_callback.skip"))) {
1276+
if (report_version < s_report_version ||
1277+
UNLIKELY(config::enable_debug_points &&
1278+
DebugPoints::instance()->is_enable(
1279+
"WorkPoolCloudReportTablet.report_tablet_callback.skip"))) {
12761280
LOG(WARNING) << "report version " << report_version << " change to " << s_report_version;
12771281
DorisMetrics::instance()->report_all_tablets_requests_skip->increment(1);
12781282
int64_t current_time = time(nullptr);

be/src/util/doris_metrics.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,8 @@ DEFINE_GAUGE_CORE_METRIC_PROTOTYPE_2ARG(runtime_filter_consumer_timeout_num, Met
250250
DEFINE_COUNTER_METRIC_PROTOTYPE_2ARG(get_remote_tablet_slow_time_ms, MetricUnit::MILLISECONDS);
251251
DEFINE_COUNTER_METRIC_PROTOTYPE_2ARG(get_remote_tablet_slow_cnt, MetricUnit::NOUNIT);
252252

253-
DEFINE_GAUGE_METRIC_PROTOTYPE_2ARG(tablet_report_continuous_failure_duration_s, MetricUnit::SECONDS);
253+
DEFINE_GAUGE_METRIC_PROTOTYPE_2ARG(tablet_report_continuous_failure_duration_s,
254+
MetricUnit::SECONDS);
254255

255256
DEFINE_COUNTER_METRIC_PROTOTYPE_2ARG(ann_index_load_costs_ms, MetricUnit::MILLISECONDS);
256257
DEFINE_COUNTER_METRIC_PROTOTYPE_2ARG(ann_index_load_cnt, MetricUnit::NOUNIT);

0 commit comments

Comments
 (0)