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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
