From f7524da89488e66ed61de336409dfee69cf06fa1 Mon Sep 17 00:00:00 2001 From: gatorsmile Date: Tue, 1 Aug 2017 10:05:05 -0700 Subject: [PATCH] improve message. --- .../scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala b/core/src/main/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala index 37c67cee55f90..979152b55f957 100644 --- a/core/src/main/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala @@ -152,8 +152,10 @@ private[spark] object ReliableCheckpointRDD extends Logging { sc, checkpointDirPath.toString, originalRDD.partitioner) if (newRDD.partitions.length != originalRDD.partitions.length) { throw new SparkException( - s"Checkpoint RDD $newRDD(${newRDD.partitions.length}) has different " + - s"number of partitions from original RDD $originalRDD(${originalRDD.partitions.length})") + "Checkpoint RDD has a different number of partitions from original RDD. Original " + + s"RDD [ID: ${originalRDD.id}, num of partitions: ${originalRDD.partitions.length}]; " + + s"Checkpoint RDD [ID: ${newRDD.id}, num of partitions: " + + s"${newRDD.partitions.length}].") } newRDD }