diff --git a/be/src/exec/exec_node.cpp b/be/src/exec/exec_node.cpp index 53e5cc7327..d0dde43c93 100644 --- a/be/src/exec/exec_node.cpp +++ b/be/src/exec/exec_node.cpp @@ -172,8 +172,11 @@ void ExecNode::release_resource(doris::RuntimeState* state) { Status ExecNode::close(RuntimeState* state) { if (_is_closed) { + LOG(INFO) << "fragment_instance_id=" << print_id(state->fragment_instance_id()) + << " already closed"; return Status::OK(); } + LOG(INFO) << "fragment_instance_id=" << print_id(state->fragment_instance_id()) << " closed"; _is_closed = true; Status result;