diff options
| author | jianran.tfh <jianran.tfh@taobao.com> | 2017-03-21 15:15:19 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2017-03-21 15:15:19 +0000 |
| commit | 650d03cfc9a609a2c603f9ced452d03ec8429b0d (patch) | |
| tree | e5474926b69d0d83dde8100345ea84afe6d3eec1 /core/src | |
| parent | 7620aed828d8baefc425b54684a83c81f1507b02 (diff) | |
| download | spark-650d03cfc9a609a2c603f9ced452d03ec8429b0d.tar.gz spark-650d03cfc9a609a2c603f9ced452d03ec8429b0d.tar.bz2 spark-650d03cfc9a609a2c603f9ced452d03ec8429b0d.zip | |
[SPARK-19998][BLOCK MANAGER] Change the exception log to add RDD id of the related the block
## What changes were proposed in this pull request?
"java.lang.Exception: Could not compute split, block $blockId not found" doesn't have the rdd id info, the "BlockManager: Removing RDD $id" has only the RDD id, so it couldn't find that the Exception's reason is the Removing; so it's better block not found Exception add RDD id info
## How was this patch tested?
Existing tests
Author: jianran.tfh <jianran.tfh@taobao.com>
Author: jianran <tanfanhua1984@163.com>
Closes #17334 from jianran/SPARK-19998.
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/BlockRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/BlockRDD.scala b/core/src/main/scala/org/apache/spark/rdd/BlockRDD.scala index d47b75544f..4e036c2ed4 100644 --- a/core/src/main/scala/org/apache/spark/rdd/BlockRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/BlockRDD.scala @@ -47,7 +47,7 @@ class BlockRDD[T: ClassTag](sc: SparkContext, @transient val blockIds: Array[Blo blockManager.get[T](blockId) match { case Some(block) => block.data.asInstanceOf[Iterator[T]] case None => - throw new Exception("Could not compute split, block " + blockId + " not found") + throw new Exception(s"Could not compute split, block $blockId of RDD $id not found") } } |