Skip to content

Commit 7293243

Browse files
committed
Fix typo in StateImpl function name
1 parent 606f99b commit 7293243

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

streaming/src/main/scala/org/apache/spark/streaming/State.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ private[streaming] class StateImpl[S] extends State[S] {
206206
* Update the internal data and flags in `this` to the given state that is going to be timed out.
207207
* This method allows `this` object to be reused across many state records.
208208
*/
209-
def wrapTiminoutState(newState: S): Unit = {
209+
def wrapTimingOutState(newState: S): Unit = {
210210
this.state = newState
211211
defined = true
212212
timingOut = true

streaming/src/main/scala/org/apache/spark/streaming/rdd/MapWithStateRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ private[streaming] object MapWithStateRDDRecord {
6767
// data returned
6868
if (removeTimedoutData && timeoutThresholdTime.isDefined) {
6969
newStateMap.getByTime(timeoutThresholdTime.get).foreach { case (key, state, _) =>
70-
wrappedState.wrapTiminoutState(state)
70+
wrappedState.wrapTimingOutState(state)
7171
val returned = mappingFunction(batchTime, key, None, wrappedState)
7272
mappedData ++= returned
7373
newStateMap.remove(key)

streaming/src/test/scala/org/apache/spark/streaming/MapWithStateSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ class MapWithStateSuite extends SparkFunSuite
125125
state.remove()
126126
testState(None, shouldBeRemoved = true)
127127

128-
state.wrapTiminoutState(3)
128+
state.wrapTimingOutState(3)
129129
testState(Some(3), shouldBeTimingOut = true)
130130
}
131131

0 commit comments

Comments
 (0)