diff options
| author | Davies Liu <davies@databricks.com> | 2015-08-14 20:56:55 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-08-14 20:56:55 -0700 |
| commit | 37586e5449ff8f892d41f0b6b8fa1de83dd3849e (patch) | |
| tree | 40ae7de2cc5c3f64891aed0c2e96d994398d34e2 /streaming | |
| parent | e5fd60415fbfea2c5c02602f7ddbc999dd058064 (diff) | |
| download | spark-37586e5449ff8f892d41f0b6b8fa1de83dd3849e.tar.gz spark-37586e5449ff8f892d41f0b6b8fa1de83dd3849e.tar.bz2 spark-37586e5449ff8f892d41f0b6b8fa1de83dd3849e.zip | |
[HOTFIX] fix duplicated braces
Author: Davies Liu <davies@databricks.com>
Closes #8219 from davies/fix_typo.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDD.scala | 2 | ||||
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/scheduler/InputInfoTracker.scala | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDD.scala b/streaming/src/main/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDD.scala index 31ce8e1ec1..620b8a36a2 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDD.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDD.scala @@ -84,7 +84,7 @@ class WriteAheadLogBackedBlockRDD[T: ClassTag]( require( blockIds.length == walRecordHandles.length, s"Number of block Ids (${blockIds.length}) must be " + - s" same as number of WAL record handles (${walRecordHandles.length}})") + s" same as number of WAL record handles (${walRecordHandles.length})") require( isBlockIdValid.isEmpty || isBlockIdValid.length == blockIds.length, diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/InputInfoTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/InputInfoTracker.scala index 363c03d431..deb15d0759 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/InputInfoTracker.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/InputInfoTracker.scala @@ -66,7 +66,7 @@ private[streaming] class InputInfoTracker(ssc: StreamingContext) extends Logging new mutable.HashMap[Int, StreamInputInfo]()) if (inputInfos.contains(inputInfo.inputStreamId)) { - throw new IllegalStateException(s"Input stream ${inputInfo.inputStreamId}} for batch" + + throw new IllegalStateException(s"Input stream ${inputInfo.inputStreamId} for batch" + s"$batchTime is already added into InputInfoTracker, this is a illegal state") } inputInfos += ((inputInfo.inputStreamId, inputInfo)) |