Skip to content

[SPARK-9411] [SQL] Make Tungsten page sizes configurable #7741

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
JoshRosen wants to merge 7 commits into from
Closed

[SPARK-9411] [SQL] Make Tungsten page sizes configurable #7741

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
e614858
Makes BytesToBytesMap page size configurable
JoshRosen Jul 29, 2015
bc734f0
Rename configuration
JoshRosen Jul 29, 2015
0045aa2
Make UnsafeShuffle's page size configurable
JoshRosen Jul 29, 2015
ba54d4b
Make UnsafeExternalSorter's page size configurable
JoshRosen Jul 29, 2015
bccfb51
Lower page size to 4MB in TestHive
JoshRosen Jul 29, 2015
2c0eefc
Fix MAXIMUM_PAGE_SIZE_BYTES comment + value
JoshRosen Jul 29, 2015
a43c4db
Fix pow
JoshRosen Jul 29, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Rename configuration
  • Loading branch information
@JoshRosen
JoshRosen committed Jul 29, 2015
commit bc734f05619d162ae007eec2d11b4a6830e8e03d
2 changes: 1 addition & 1 deletion sql/core/src/main/scala/org/apache/spark/sql/execution/GeneratedAggregate.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -260,7 +260,7 @@ case class GeneratedAggregate(
} else if (unsafeEnabled && schemaSupportsUnsafe) {
assert(iter.hasNext, "There should be at least one row for this path")
log.info("Using Unsafe-based aggregator")
val pageSizeBytes = SparkEnv.get.conf.getLong("spark.unsafe.pageSizeBytes", 67108864L)
val pageSizeBytes = SparkEnv.get.conf.getSizeAsBytes("spark.buffer.pageSize", "64m")
val aggregationMap = new UnsafeFixedWidthAggregationMap(
newAggregationBuffer(EmptyRow),
aggregationBufferSchema,
Expand Down
2 changes: 1 addition & 1 deletion sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -260,7 +260,7 @@ private[joins] final class UnsafeHashedRelation(
val nKeys = in.readInt()
// This is used in Broadcast, shared by multiple tasks, so we use on-heap memory
val memoryManager = new TaskMemoryManager(new ExecutorMemoryManager(MemoryAllocator.HEAP))
val pageSizeBytes = SparkEnv.get.conf.getLong("spark.unsafe.pageSizeBytes", 67108864L)
val pageSizeBytes = SparkEnv.get.conf.getSizeAsBytes("spark.buffer.pageSize", "64m")
binaryMap = new BytesToBytesMap(
memoryManager,
nKeys * 2, // reduce hash collision
Expand Down