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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
