Skip to content

Commit 307ec98

Browse files
committed
[MINOR][SS] Fix setTimeoutTimestamp doc
### What changes were proposed in this pull request? This patch updates the API doc of `setTimeoutTimestamp` of `GroupState`. ### Why are the changes needed? Update incorrect API doc. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Doc change only. Closes #39958 from viirya/fix_group_state. Authored-by: Liang-Chi Hsieh <[email protected]> Signed-off-by: Liang-Chi Hsieh <[email protected]> (cherry picked from commit a180e67) Signed-off-by: Liang-Chi Hsieh <[email protected]>
1 parent 7205567 commit 307ec98

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/streaming/GroupState.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,7 @@ trait GroupState[S] extends LogicalGroupState[S] {
259259
@throws[IllegalArgumentException](
260260
"if 'timestampMs' is not positive or less than the current watermark in a streaming query")
261261
@throws[UnsupportedOperationException](
262-
"if processing time timeout has not been enabled in [map|flatMap]GroupsWithState")
262+
"if event time timeout has not been enabled in [map|flatMap]GroupsWithState")
263263
def setTimeoutTimestamp(timestampMs: Long): Unit
264264

265265

0 commit comments

Comments
 (0)