Gabriel39 commented on code in PR #47462:
URL: https://github.com/apache/doris/pull/47462#discussion_r1967139394
##########
be/src/pipeline/pipeline_fragment_context.cpp:
##########
@@ -181,7 +183,17 @@ void PipelineFragmentContext::cancel(const Status reason) {
}
// Timeout is a special error code, we need print current stack to debug
timeout issue.
if (reason.is<ErrorCode::TIMEOUT>()) {
- LOG(WARNING) << "PipelineFragmentContext is cancelled due to timeout :
" << debug_string();
+ auto dbg_str = debug_string();
+ constexpr size_t max_log_size = 30000 - 100;
+ size_t pos = 0;
+ size_t total_size = dbg_str.size();
+ size_t tmp_size = std::min(max_log_size, total_size);
+ LOG(WARNING) << "PipelineFragmentContext is cancelled due to timeout:";
+ while (pos < total_size) {
+ tmp_size = std::min(max_log_size, total_size - pos);
+ LOG(WARNING) << "===" << std::string(dbg_str.data() + pos,
tmp_size);
Review Comment:
Debug log need to be deleted
##########
be/src/pipeline/exec/hashjoin_build_sink.cpp:
##########
@@ -108,16 +114,103 @@ Status HashJoinBuildSinkLocalState::open(RuntimeState*
state) {
RETURN_IF_ERROR(JoinBuildSinkLocalState::open(state));
#ifndef NDEBUG
- if (state->fuzzy_disable_runtime_filter_in_be()) {
- if ((_parent->operator_id() + random()) % 2 == 0) {
- RETURN_IF_ERROR(disable_runtime_filters(state));
- }
- }
+ // if (state->fuzzy_disable_runtime_filter_in_be()) {
Review Comment:
just delete this
--
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
