Details
-
Bug
-
Status: Reopened
-
Not a Priority
-
Resolution: Unresolved
-
None
-
None
-
None
Description
I don't think the description of the ValueState in the https://github.com/apache/flink/blob/master/docs/getting-started/walkthroughs/datastream_api.zh.md is right.
I think It shoud be
Modifications to the object returned by ValueState#valueare not guaranteed to be recognized by the system, and so all changes must be performed with ValueState#update. In this way, fault tolerance is managed automatically by Flink under the hood, and so you can interact with it like with any standard variable.
Instead of
Modifications to the object returned by ValueState#valueare not guaranteed to be recognized by the system, and so all changes must be performed with ValueState#update. Otherwise, fault tolerance is managed automatically by Flink under the hood, and so you can interact with it like with any standard variable.