This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new c0df8fca20 [pipelineX](fix) Fix potential concurrent problem (#24651)
c0df8fca20 is described below
commit c0df8fca20304b27bb5b9cc8c37e32d2cfe9546c
Author: Gabriel <[email protected]>
AuthorDate: Wed Sep 20 13:00:58 2023 +0800
[pipelineX](fix) Fix potential concurrent problem (#24651)
---
be/src/vec/exec/scan/pip_scanner_context.h | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/be/src/vec/exec/scan/pip_scanner_context.h
b/be/src/vec/exec/scan/pip_scanner_context.h
index 2022ecb29e..6360f104c6 100644
--- a/be/src/vec/exec/scan/pip_scanner_context.h
+++ b/be/src/vec/exec/scan/pip_scanner_context.h
@@ -142,13 +142,13 @@ public:
for (int j = i; j < block_size; j += queue_size) {
_blocks_queues[queue].emplace_back(std::move(blocks[j]));
}
+ if (_data_dependency) {
+ _data_dependency->set_ready_for_read();
+ }
}
_next_queue_to_feed = queue + 1 < queue_size ? queue + 1 : 0;
}
}
- if (_data_dependency) {
- _data_dependency->set_ready_for_read();
- }
_current_used_bytes += local_bytes;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
