spark-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ankur Gupta (JIRA)" <>
Subject [jira] [Created] (SPARK-25008) Add memory mode info to showMemoryUsage in TaskMemoryManager
Date Thu, 02 Aug 2018 21:53:00 GMT
Ankur Gupta created SPARK-25008:

             Summary: Add memory mode info to showMemoryUsage in TaskMemoryManager
                 Key: SPARK-25008
             Project: Spark
          Issue Type: Task
          Components: Spark Core
    Affects Versions: 2.3.0
            Reporter: Ankur Gupta

TaskMemoryManager prints the current memory usage information before throwing an OOM exception
which is helpful in debugging issues. This log does not have the memory mode information which
can be also useful to quickly determine which memory users need to increase.

This JIRA is to add that information to showMemoryUsage method of TaskMemoryManager.

Current logs:
18/07/03 17:57:16 INFO memory.TaskMemoryManager: Memory used in task 318
18/07/03 17:57:16 INFO memory.TaskMemoryManager: Acquired by org.apache.spark.util.collection.unsafe.sort.UnsafeExternalSorter@7f084d1b:
1024.0 KB
18/07/03 17:57:16 INFO memory.TaskMemoryManager: Acquired by org.apache.spark.shuffle.sort.ShuffleExternalSorter@713d50f2:
32.0 KB
18/07/03 17:57:16 INFO memory.TaskMemoryManager: 0 bytes of memory were used by task 318 but
are not associated with specific consumers
18/07/03 17:57:16 INFO memory.TaskMemoryManager: 1081344 bytes of memory are used for execution
and 306201016 bytes of memory are used for storage
18/07/03 17:57:16 ERROR executor.Executor: Exception in task 86.0 in stage 49.0 (TID 318)
java.lang.OutOfMemoryError: Unable to acquire 326284160 bytes of memory, got 3112960
 at org.apache.spark.memory.MemoryConsumer.allocatePage(
 at org.apache.spark.shuffle.sort.ShuffleExternalSorter.acquireNewPageIfNecessary(
 at org.apache.spark.shuffle.sort.ShuffleExternalSorter.insertRecord(
 at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.insertRecordIntoSorter(
 at org.apache.spark.shuffle.sort.UnsafeShuffleWriter.write(
 at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:96)
 at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:53)
 at org.apache.spark.executor.Executor$
 at java.util.concurrent.ThreadPoolExecutor.runWorker(
 at java.util.concurrent.ThreadPoolExecutor$

This message was sent by Atlassian JIRA

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message