diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala index 225cff8afc..80f21433b4 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala @@ -479,6 +479,7 @@ private[joins] object UnsafeHashedRelation { throw QueryExecutionErrors.cannotAcquireMemoryToBuildUnsafeHashedRelationError() } } else if (isNullAware) { + binaryMap.free() return HashedRelationWithAllNullKeys } } @@ -1060,6 +1061,7 @@ private[joins] object LongHashedRelation { val key = rowKey.getLong(0) map.append(key, unsafeRow) } else if (isNullAware) { + map.free() return HashedRelationWithAllNullKeys } }