This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 7447ac71b5 [minor](format) fix BE code format (#25328)
7447ac71b5 is described below

commit 7447ac71b59bfbf38f5216d07867f557064332e1
Author: Mingyu Chen <morning...@163.com>
AuthorDate: Thu Oct 12 10:34:36 2023 +0800

    [minor](format) fix BE code format (#25328)
---
 be/src/vec/sink/writer/vtablet_writer.cpp | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/be/src/vec/sink/writer/vtablet_writer.cpp 
b/be/src/vec/sink/writer/vtablet_writer.cpp
index 0b39065721..c0676a5670 100644
--- a/be/src/vec/sink/writer/vtablet_writer.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer.cpp
@@ -55,6 +55,7 @@
 #endif
 
 // IWYU pragma: no_include <opentelemetry/common/threadlocal.h>
+#include "bvar/bvar.h"
 #include "common/compiler_util.h" // IWYU pragma: keep
 #include "common/logging.h"
 #include "common/object_pool.h"
@@ -92,7 +93,6 @@
 #include "vec/exprs/vexpr.h"
 #include "vec/sink/vtablet_block_convertor.h"
 #include "vec/sink/vtablet_finder.h"
-#include "bvar/bvar.h"
 
 namespace doris {
 class TExpr;
@@ -100,9 +100,11 @@ class TExpr;
 namespace vectorized {
 
 bvar::Adder<int64_t> g_sink_write_bytes;
-bvar::PerSecond<bvar::Adder<int64_t>> 
g_sink_write_bytes_per_second("sink_throughput_byte", &g_sink_write_bytes, 60);
+bvar::PerSecond<bvar::Adder<int64_t>> 
g_sink_write_bytes_per_second("sink_throughput_byte",
+                                                                    
&g_sink_write_bytes, 60);
 bvar::Adder<int64_t> g_sink_write_rows;
-bvar::PerSecond<bvar::Adder<int64_t>> 
g_sink_write_rows_per_second("sink_throughput_row", &g_sink_write_rows, 60);
+bvar::PerSecond<bvar::Adder<int64_t>> 
g_sink_write_rows_per_second("sink_throughput_row",
+                                                                   
&g_sink_write_rows, 60);
 
 Status IndexChannel::init(RuntimeState* state, const 
std::vector<TTabletWithPartition>& tablets) {
     SCOPED_CONSUME_MEM_TRACKER(_index_channel_tracker.get());


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to