From eb650a81f14fa7bc665856397e19ddf1a92ca3c5 Mon Sep 17 00:00:00 2001 From: Liwei Lin Date: Fri, 11 Mar 2016 11:07:27 -0800 Subject: [STREAMING][MINOR] Fix a duplicate "be" in comments Author: Liwei Lin Closes #11650 from lw-lin/typo. --- streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala b/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala index e6724feaee..7c1ea2f89d 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala @@ -83,8 +83,7 @@ sealed abstract class StateSpec[KeyType, ValueType, StateType, MappedType] exten def numPartitions(numPartitions: Int): this.type /** - * Set the partitioner by which the state RDDs generated by `mapWithState` will be - * be partitioned. + * Set the partitioner by which the state RDDs generated by `mapWithState` will be partitioned. */ def partitioner(partitioner: Partitioner): this.type -- cgit v1.2.3