Re: [PR] [SPARK-46906][SS] Add a check for stateful operator change for streaming [spark]

["chaoqin-li1123 (via GitHub)" <gi...@apache.org>]

chaoqin-li1123 commented on code in PR #44927:
URL: https://github.com/apache/spark/pull/44927#discussion_r1470419428


##########
common/utils/src/main/resources/error/error-classes.json:
##########
@@ -3317,6 +3317,12 @@
     ],
     "sqlState" : "XXKST"
   },
+  "STREAMING_STATEFUL_OPERATOR_NOT_MATCH_IN_STATE_METADATA" : {
+    "message" : [
+      "Streaming stateful operator name does not match with the operator in state metadata with the same operator id (id: <operatorId>). Stateful Operator name for current batch: <currentOperatorName>; Operator name in the state metadata: <stateMetadataOperatorName>."

Review Comment:
   Can we explain why this occur to the customer? Like "changing stateful operator of existing streaming query is not allowed."



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


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