Fix aggregation memory revoke when operator is finishing#164
Fix aggregation memory revoke when operator is finishing#164sopel39 merged 5 commits intotrinodb:masterfrom
Conversation
27089f4 to
4afc33d
Compare
findepi
left a comment
There was a problem hiding this comment.
Generally looks good. Please update code as fixups for easier re-review.
...src/main/java/io/prestosql/operator/aggregation/builder/SpillableHashAggregationBuilder.java
Outdated
Show resolved
Hide resolved
presto-main/src/test/java/io/prestosql/operator/TestHashAggregationOperator.java
Outdated
Show resolved
Hide resolved
presto-main/src/test/java/io/prestosql/operator/TestHashAggregationOperator.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
I don't get it. Previously the code was calling assertOperatorEqualsIgnoreOrder
Now it's more verbose, including manually calling toPages, dropping hash channels, converting to MaterializedResult.
i assume this is assertOperatorEqualsIgnoreOrder inlined, but what's the actual difference?
Is this really related to increasing the data set, as Produce more than single page in testHashAggregation commit message says?
There was a problem hiding this comment.
This can take time.
Can we spill asynchronously?
spillToDisk();
return WorkProcessor.empty();
(then we need to updateMemory(); on next call..)
There was a problem hiding this comment.
Added todo since this requires bigger operator refactor
...src/main/java/io/prestosql/operator/aggregation/builder/SpillableHashAggregationBuilder.java
Outdated
Show resolved
Hide resolved
...src/main/java/io/prestosql/operator/aggregation/builder/SpillableHashAggregationBuilder.java
Outdated
Show resolved
Hide resolved
...src/main/java/io/prestosql/operator/aggregation/builder/SpillableHashAggregationBuilder.java
Outdated
Show resolved
Hide resolved
...src/main/java/io/prestosql/operator/aggregation/builder/SpillableHashAggregationBuilder.java
Outdated
Show resolved
Hide resolved
4afc33d to
fdc38d6
Compare
|
ac |
fdc38d6 to
f2f743f
Compare
presto-main/src/test/java/io/prestosql/operator/TestHashAggregationOperator.java
Outdated
Show resolved
Hide resolved
f2f743f to
f7f1701
Compare
…titions to table scan
No description provided.