Skip to content

Commit 3351fb1

Browse files
committed
Mode
1 parent 3eeac08 commit 3351fb1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -536,7 +536,7 @@ private[execution] final class LongToUnsafeRowMap(
536536
val mm: TaskMemoryManager,
537537
capacity: Int,
538538
ignoresDuplicatedKey: Boolean = false)
539-
extends MemoryConsumer(mm, MemoryMode.ON_HEAP) with Externalizable with KryoSerializable {
539+
extends MemoryConsumer(mm, mm.getTungstenMemoryMode) with Externalizable with KryoSerializable {
540540

541541
// Whether the keys are stored in dense mode or not.
542542
private var isDense = false

0 commit comments

Comments
 (0)