You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2023/01/31 15:39:17 UTC
[doris] 19/20: [branch-1.2] format code after cherry-pick
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 60f22608a442d203888ea1b3f84205b37b16eab5
Author: morningman <mo...@163.com>
AuthorDate: Tue Jan 31 20:42:34 2023 +0800
[branch-1.2] format code after cherry-pick
---
be/src/runtime/result_buffer_mgr.h | 3 +--
be/src/runtime/result_sink.cpp | 4 ++--
be/src/vec/sink/vresult_file_sink.cpp | 3 +--
be/src/vec/sink/vresult_sink.cpp | 3 +--
4 files changed, 5 insertions(+), 8 deletions(-)
diff --git a/be/src/runtime/result_buffer_mgr.h b/be/src/runtime/result_buffer_mgr.h
index cc16e771a0..c74a078466 100644
--- a/be/src/runtime/result_buffer_mgr.h
+++ b/be/src/runtime/result_buffer_mgr.h
@@ -47,8 +47,7 @@ public:
// the returned sender do not need release
// sender is not used when call cancel or unregister
Status create_sender(const TUniqueId& query_id, int buffer_size,
- std::shared_ptr<BufferControlBlock>* sender,
- int query_timeout);
+ std::shared_ptr<BufferControlBlock>* sender, int query_timeout);
// fetch data, used by RPC
Status fetch_data(const TUniqueId& fragment_id, TFetchDataResult* result);
diff --git a/be/src/runtime/result_sink.cpp b/be/src/runtime/result_sink.cpp
index a19c44ea7c..dfe25a4980 100644
--- a/be/src/runtime/result_sink.cpp
+++ b/be/src/runtime/result_sink.cpp
@@ -66,8 +66,8 @@ Status ResultSink::prepare(RuntimeState* state) {
RETURN_IF_ERROR(prepare_exprs(state));
// create sender
- RETURN_IF_ERROR(state->exec_env()->result_mgr()->create_sender(state->fragment_instance_id(),
- _buf_size, &_sender, state->query_timeout()));
+ RETURN_IF_ERROR(state->exec_env()->result_mgr()->create_sender(
+ state->fragment_instance_id(), _buf_size, &_sender, state->query_timeout()));
// create writer based on sink type
switch (_sink_type) {
diff --git a/be/src/vec/sink/vresult_file_sink.cpp b/be/src/vec/sink/vresult_file_sink.cpp
index 948dfce4d0..d1d2cfaa72 100644
--- a/be/src/vec/sink/vresult_file_sink.cpp
+++ b/be/src/vec/sink/vresult_file_sink.cpp
@@ -103,8 +103,7 @@ Status VResultFileSink::prepare(RuntimeState* state) {
if (_is_top_sink) {
// create sender
RETURN_IF_ERROR(state->exec_env()->result_mgr()->create_sender(
- state->fragment_instance_id(), _buf_size, &_sender,
- state->query_timeout()));
+ state->fragment_instance_id(), _buf_size, &_sender, state->query_timeout()));
// create writer
_writer.reset(new (std::nothrow) VFileResultWriter(
_file_opts.get(), _storage_type, state->fragment_instance_id(), _output_vexpr_ctxs,
diff --git a/be/src/vec/sink/vresult_sink.cpp b/be/src/vec/sink/vresult_sink.cpp
index 5d3fe0ec9a..a5868ce2b0 100644
--- a/be/src/vec/sink/vresult_sink.cpp
+++ b/be/src/vec/sink/vresult_sink.cpp
@@ -62,8 +62,7 @@ Status VResultSink::prepare(RuntimeState* state) {
// create sender
RETURN_IF_ERROR(state->exec_env()->result_mgr()->create_sender(
- state->fragment_instance_id(), _buf_size, &_sender,
- state->query_timeout()));
+ state->fragment_instance_id(), _buf_size, &_sender, state->query_timeout()));
// create writer based on sink type
switch (_sink_type) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org