Skip to content

Commit 24a9369

Browse files
committed
Free memory after releasing lookupSourceSupplier
1 parent f8893ef commit 24a9369

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/trino-main/src/main/java/io/trino/operator/join/HashBuilderOperator.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -388,10 +388,10 @@ public ListenableFuture<Void> startMemoryRevoke()
388388
lookupSourceFactory.setPartitionSpilledLookupSourceHandle(partitionIndex, spilledLookupSourceHandle);
389389
lookupSourceNotNeeded = Optional.empty();
390390
index.clear();
391-
localUserMemoryContext.setBytes(index.getEstimatedSize().toBytes());
392-
localRevocableMemoryContext.setBytes(0);
393391
lookupSourceChecksum = OptionalLong.of(lookupSourceSupplier.checksum());
394392
lookupSourceSupplier = null;
393+
localUserMemoryContext.setBytes(index.getEstimatedSize().toBytes());
394+
localRevocableMemoryContext.setBytes(0);
395395
state = State.INPUT_SPILLED;
396396
});
397397
return spillIndex();

0 commit comments

Comments
 (0)