diff options
| author | Liwei Lin <proflin.me@gmail.com> | 2016-03-11 11:07:27 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-03-11 11:07:27 -0800 |
| commit | eb650a81f14fa7bc665856397e19ddf1a92ca3c5 (patch) | |
| tree | 857add8fd1cbf6e7bcd81a692ee01bfc9ecf0989 /streaming | |
| parent | 99b7187c2dce4c73829b9b32de80b02a053763cc (diff) | |
| download | spark-eb650a81f14fa7bc665856397e19ddf1a92ca3c5.tar.gz spark-eb650a81f14fa7bc665856397e19ddf1a92ca3c5.tar.bz2 spark-eb650a81f14fa7bc665856397e19ddf1a92ca3c5.zip | |
[STREAMING][MINOR] Fix a duplicate "be" in comments
Author: Liwei Lin <proflin.me@gmail.com>
Closes #11650 from lw-lin/typo.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala | 3 |
1 files changed, 1 insertions, 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 |