This is an automated email from the ASF dual-hosted git repository.
mrhhsg pushed a commit to branch spill_and_reserve
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 92e23d94728370988540e204f265d82294d90b5f
Author: Jerry Hu <mrh...@gmail.com>
AuthorDate: Tue Sep 10 10:38:08 2024 +0800
[fix] avoid crash when no data to revoke
---
be/src/pipeline/pipeline_task.cpp | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_task.cpp
b/be/src/pipeline/pipeline_task.cpp
index 1bd74bcab45..10309000ced 100644
--- a/be/src/pipeline/pipeline_task.cpp
+++ b/be/src/pipeline/pipeline_task.cpp
@@ -41,6 +41,7 @@
#include "util/mem_info.h"
#include "util/runtime_profile.h"
#include "util/uid_util.h"
+#include "vec/spill/spill_stream.h"
namespace doris {
class RuntimeState;
@@ -550,7 +551,9 @@ size_t PipelineTask::get_revocable_size() const {
}
Status PipelineTask::revoke_memory() {
- RETURN_IF_ERROR(_sink->revoke_memory(_state));
+ if (_sink->revocable_mem_size(_state) >=
vectorized::SpillStream::MIN_SPILL_WRITE_BATCH_MEM) {
+ RETURN_IF_ERROR(_sink->revoke_memory(_state));
+ }
return _root->revoke_memory(_state);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
