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
The following commit(s) were added to refs/heads/spill_and_reserve by this push:
new acb837d0de4 [fix] avoid crash when no data to revoke
acb837d0de4 is described below
commit acb837d0de42d00dd2399c20d34badd47bdd3119
Author: Jerry Hu <[email protected]>
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 ce75010e0ff..43f774cc8db 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: [email protected]
For additional commands, e-mail: [email protected]
