This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new e83ddd08b35 branch-3.0: [fix](schema scan) Fix invalid pointer access
#48313 (#48340)
e83ddd08b35 is described below
commit e83ddd08b35f3f8eb95c189fcf91c92ee827dca9
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Feb 27 17:49:30 2025 +0800
branch-3.0: [fix](schema scan) Fix invalid pointer access #48313 (#48340)
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 c96fb2db354..e258f7563d1 100644
--- a/be/src/exec/schema_scanner.cpp
+++ b/be/src/exec/schema_scanner.cpp
@@ -119,11 +119,11 @@ 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) {
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
