yiguolei commented on code in PR #37990:
URL: https://github.com/apache/doris/pull/37990#discussion_r1683949300
##########
be/src/vec/sink/vmysql_result_writer.cpp:
##########
@@ -249,6 +237,47 @@ Status
VMysqlResultWriter<is_binary_format>::write(RuntimeState* state, Block& i
return status;
}
+template <bool is_binary_format>
+Status VMysqlResultWriter<is_binary_format>::write(RuntimeState* state, Block&
input_block) {
+ SCOPED_TIMER(_append_row_batch_timer);
+ Status status = Status::OK();
+ if (UNLIKELY(input_block.rows() == 0)) {
+ return status;
+ }
+
+ DCHECK(_output_vexpr_ctxs.empty() != true);
+
+ // Exec vectorized expr here to speed up, block.rows() == 0 means expr exec
+ // failed, just return the error status
+ Block block;
+
RETURN_IF_ERROR(VExprContext::get_output_block_after_execute_exprs(_output_vexpr_ctxs,
+
input_block, &block));
+ constexpr static size_t MAX_BLOCK_SIZE = 1024L * 1024 * 1024;
Review Comment:
change this to be.conf
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
