This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 4f3ccca9a24 branch-2.1: [fix](schema scan) Fix invalid pointer access
#48313 (#48341)
4f3ccca9a24 is described below
commit 4f3ccca9a24b268b65e3daf3350edc03aa9b6086
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Feb 26 20:29:39 2025 +0800
branch-2.1: [fix](schema scan) Fix invalid pointer access #48313 (#48341)
Cherry-picked from #48313
Co-authored-by: Gabriel <liwenqi...@selectdb.com>
---
be/src/exec/schema_scanner.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/exec/schema_scanner.cpp b/be/src/exec/schema_scanner.cpp
index 6336abd7f0b..70e007cf7fa 100644
--- a/be/src/exec/schema_scanner.cpp
+++ b/be/src/exec/schema_scanner.cpp
@@ -119,12 +119,12 @@ Status SchemaScanner::get_next_block_async(RuntimeState*
state) {
auto task_ctx = state->get_task_execution_context();
RETURN_IF_ERROR(ExecEnv::GetInstance()->fragment_mgr()->get_thread_pool()->submit_func(
[this, task_ctx, state]() {
- DCHECK(_async_thread_running == false);
auto task_lock = task_ctx.lock();
if (task_lock == nullptr) {
_scanner_status.update(Status::InternalError("Task context
not exists!"));
return;
}
+ DCHECK(_async_thread_running == false);
SCOPED_ATTACH_TASK(state);
_dependency->block();
_async_thread_running = true;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
