Format

apache · Dec 20, 2023 · 9c4e160 · 9c4e160
1 parent a8553e1
commit 9c4e160
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 6 deletions.
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -158,7 +158,8 @@ void PipelineFragmentContext::cancel(const PPlanFragmentCancelReason& reason,
             _exec_status = Status::Cancelled(msg);
         }
         _runtime_state->set_is_cancelled(true, msg);
-        LOG_WARNING("Instance {} cancelled, reason {}", print_id(_fragment_instance_id), msg.substr(0, 50));
+        LOG_WARNING("Instance {} cancelled, reason {}", print_id(_fragment_instance_id),
+                    msg.substr(0, 50));
 
         // Print detail informations below when you debugging here.
         //

diff --git a/be/src/runtime/runtime_state.h b/be/src/runtime/runtime_state.h
@@ -169,7 +169,8 @@ class RuntimeState {
         _is_cancelled.store(v);
         // Create a error status, so that we could print error stack, and
         // we could know which path call cancel.
-        LOG_WARNING("Task {} is cancelled, msg: {}", print_id(_fragment_instance_id), Status::Error<ErrorCode::CANCELLED>(msg));
+        LOG_WARNING("Task {} is cancelled, msg: {}", print_id(_fragment_instance_id),
+                    Status::Error<ErrorCode::CANCELLED>(msg));
     }
 
     void set_backend_id(int64_t backend_id) { _backend_id = backend_id; }

diff --git a/be/src/vec/runtime/vdata_stream_recvr.cpp b/be/src/vec/runtime/vdata_stream_recvr.cpp
@@ -254,7 +254,8 @@ void VDataStreamRecvr::SenderQueue::cancel(const std::string& msg) {
         }
         _is_cancelled = true;
         _cancel_msg = msg; // TODO: std::string copy, maybe we can do this better.
-        VLOG_QUERY << "cancelled stream: _fragment_instance_id=" << print_id(_recvr->fragment_instance_id())
+        VLOG_QUERY << "cancelled stream: _fragment_instance_id="
+                   << print_id(_recvr->fragment_instance_id())
                    << " node_id=" << _recvr->dest_node_id();
     }
     // Wake up all threads waiting to produce/consume batches.  They will all

diff --git a/be/src/vec/sink/vdata_stream_sender.cpp b/be/src/vec/sink/vdata_stream_sender.cpp
@@ -274,9 +274,9 @@ Status Channel::close_internal(const Status& exec_status) {
     }
 
     VLOG_RPC << "Channel::close() instance_id=" << print_id(_fragment_instance_id)
-              << " dest_node=" << _dest_node_id
-              << " #rows= " << ((_mutable_block == nullptr) ? 0 : _mutable_block->rows())
-              << " receiver status: " << _receiver_status << " close status: " << exec_status.msg();
+             << " dest_node=" << _dest_node_id
+             << " #rows= " << ((_mutable_block == nullptr) ? 0 : _mutable_block->rows())
+             << " receiver status: " << _receiver_status << " close status: " << exec_status.msg();
 
     if (is_receiver_eof()) {
         _mutable_block.reset();