update

Signed-off-by: sevev <qiangzh95@gmail.com>
StarRocks · Oct 23, 2024 · f3caf1c · f3caf1c
1 parent c52a24e
commit f3caf1c
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/be/src/exec/pipeline/pipeline_driver_executor.cpp b/be/src/exec/pipeline/pipeline_driver_executor.cpp
@@ -346,8 +346,8 @@ void GlobalDriverExecutor::report_exec_state(QueryContext* query_ctx, FragmentCo
             auto status = ExecStateReporter::report_exec_status(*params, exec_env, fe_addr);
             if (!status.ok()) {
                 if (status.is_not_found()) {
-                    LOG(INFO) << "[Driver] Fail to report exec state due to query not found: fragment_instance_id="
-                              << print_id(fragment_id);
+                    VLOG(1) << "[Driver] Fail to report exec state due to query not found: fragment_instance_id="
+                            << print_id(fragment_id);
                 } else {
                     LOG(WARNING) << "[Driver] Fail to report exec state: fragment_instance_id=" << print_id(fragment_id)
                                  << ", status: " << status.to_string() << ", retry_times=" << retry_times;

diff --git a/be/src/storage/compaction_task.cpp b/be/src/storage/compaction_task.cpp
@@ -114,7 +114,7 @@ void CompactionTask::run() {
     DataDir* data_dir = _tablet->data_dir();
     if (data_dir->capacity_limit_reached(input_rowsets_size())) {
         std::ostringstream sstream;
-        sstream << "compaction task:" << _task_info.task_id << "failed, skip tablet:" << _tablet->tablet_id()
+        sstream << "compaction task:" << _task_info.task_id << " failed, skip tablet:" << _tablet->tablet_id()
                 << " because data dir reaches capacity limit. input rowsets size:" << input_rowsets_size();
         Status st = Status::InternalError(sstream.str());
         _failure_callback(st);

diff --git a/be/src/storage/tablet_updates.cpp b/be/src/storage/tablet_updates.cpp
@@ -1761,10 +1761,10 @@ Status TabletUpdates::_apply_normal_rowset_commit(const EditVersionInfo& version
             "apply_rowset_commit finish. tablet:$0 version:$1 txn_id: $2 total del/row:$3/$4 $5% rowset:$6 #seg:$7 ",
             tablet_id, version_info.version.to_string(), rowset->txn_id(), _cur_total_dels, _cur_total_rows,
             del_percent, rowset_id, rowset->num_segments());
-    std::string msg_part2 =
-            strings::Substitute("#op(upsert:$0 del:$1) #del:$2+$3=$4 #dv:$5 duration:$6ms($7/$8/$9/$10)",
-                                rowset->num_rows(), delete_op, old_total_del, new_del, total_del, ndelvec,
-                                t_write - t_start, t_apply - t_start, t_index - t_apply, t_delvec - t_index);
+    std::string msg_part2 = strings::Substitute(
+            "#op(upsert:$0 del:$1) #del:$2+$3=$4 #dv:$5 duration:$6ms($7/$8/$9/$10)", rowset->num_rows(), delete_op,
+            old_total_del, new_del, total_del, ndelvec, t_write - t_start, t_apply - t_start, t_index - t_apply,
+            t_delvec - t_index, t_write - t_delvec);
 
     bool is_slow = t_apply - t_start > config::apply_version_slow_log_sec * 1000;
     if (is_slow) {