[spark] branch branch-3.4 updated: [MINOR][SS] Fix setTimeoutTimestamp doc

[vi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

viirya pushed a commit to branch branch-3.4
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/branch-3.4 by this push:
     new f11338aafc5 [MINOR][SS] Fix setTimeoutTimestamp doc
f11338aafc5 is described below

commit f11338aafc5c36b385514914ea82bcee216c1be1
Author: Liang-Chi Hsieh <vi...@gmail.com>
AuthorDate: Thu Feb 9 18:17:27 2023 -0800

    [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 <vi...@gmail.com>
    Signed-off-by: Liang-Chi Hsieh <vi...@gmail.com>
    (cherry picked from commit a180e67d3859a4e145beaf671c1221fb4d6cbda7)
    Signed-off-by: Liang-Chi Hsieh <vi...@gmail.com>
---
 sql/core/src/main/scala/org/apache/spark/sql/streaming/GroupState.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sql/core/src/main/scala/org/apache/spark/sql/streaming/GroupState.scala b/sql/core/src/main/scala/org/apache/spark/sql/streaming/GroupState.scala
index 71c6aaea8cf..2c8f1db74f8 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/streaming/GroupState.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/streaming/GroupState.scala
@@ -259,7 +259,7 @@ trait GroupState[S] extends LogicalGroupState[S] {
   @throws[IllegalArgumentException](
     "if 'timestampMs' is not positive or less than the current watermark in a streaming query")
   @throws[UnsupportedOperationException](
-    "if processing time timeout has not been enabled in [map|flatMap]GroupsWithState")
+    "if event time timeout has not been enabled in [map|flatMap]GroupsWithState")
   def setTimeoutTimestamp(timestampMs: Long): Unit
 
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org