Skip to content

Commit

Permalink
fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
zhztheplayer committed Dec 15, 2023
1 parent 667d24d commit bd26242
Showing 1 changed file with 8 additions and 10 deletions.
18 changes: 8 additions & 10 deletions velox/exec/fuzzer/AggregationFuzzerBase.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -372,20 +372,18 @@ velox::test::ResultOrError AggregationFuzzerBase::execute(

builder.configs(queryConfigs_);

if (injectSpill) {
if (injectSpill || injectPartialSpill) {
spillDirectory = exec::test::TempDirectoryPath::create();
builder.spillDirectory(spillDirectory->path)
.config(core::QueryConfig::kSpillEnabled, "true")
.config(core::QueryConfig::kAggregationSpillEnabled, "true")
.config(core::QueryConfig::kTestingSpillPct, "100");
}

if (injectPartialSpill) {
spillDirectory = exec::test::TempDirectoryPath::create();
builder.spillDirectory(spillDirectory->path)
.config(core::QueryConfig::kSpillEnabled, "true")
.config(core::QueryConfig::kPartialAggregationSpillEnabled, "true")
.config(core::QueryConfig::kTestingSpillPct, "100");
if (injectSpill) {
builder.config(core::QueryConfig::kAggregationSpillEnabled, "true");
}
if (injectPartialSpill) {
builder.config(
core::QueryConfig::kPartialAggregationSpillEnabled, "true");
}
}

if (abandonPartial) {
Expand Down

0 comments on commit bd26242

Please sign in to comment.