Skip to content

Commit

Permalink
save work
Browse files Browse the repository at this point in the history
Signed-off-by: xufei <xufeixw@mail.ustc.edu.cn>
  • Loading branch information
windtalker committed Aug 18, 2023
1 parent 7c7c638 commit 87c0614
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
5 changes: 2 additions & 3 deletions dbms/src/Core/OperatorSpillContext.h
Original file line number Diff line number Diff line change
Expand Up @@ -48,11 +48,10 @@ class OperatorSpillContext
const static Int64 MIN_SPILL_THRESHOLD = 10ULL * 1024 * 1024;
OperatorSpillContext(UInt64 operator_spill_threshold_, const String op_name_, const LoggerPtr & log_)
: operator_spill_threshold(operator_spill_threshold_)
, auto_spill_mode(operator_spill_threshold == 0)
, op_name(op_name_)
, log(log_)
{
auto_spill_mode = supportAutoTriggerSpill() && operator_spill_threshold == 0;
}
{}
virtual ~OperatorSpillContext() = default;
bool isSpillEnabled() const { return enable_spill && (supportAutoTriggerSpill() || operator_spill_threshold > 0); }
void disableSpill() { enable_spill = false; }
Expand Down
5 changes: 4 additions & 1 deletion dbms/src/Interpreters/HashJoinSpillContext.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,10 @@ HashJoinSpillContext::HashJoinSpillContext(
, max_cached_bytes(std::max(
build_spill_config.max_cached_data_bytes_in_spiller,
probe_spill_config.max_cached_data_bytes_in_spiller))
{}
{
/// join does not support auto spill mode
auto_spill_mode = false;
}

void HashJoinSpillContext::init(size_t partition_num)
{
Expand Down

0 comments on commit 87c0614

Please sign in to comment.