diff --git a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md index 1af700580125f..66b4d7838b0b9 100644 --- a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md +++ b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md @@ -563,7 +563,7 @@ val counts: DataStream[(String, Int)] = stream ## Operator State -*Operator State* (or *non-keyed state*) is state that is is bound to one +*Operator State* (or *non-keyed state*) is state that is bound to one parallel operator instance. The [Kafka Connector]({{< ref "docs/connectors/datastream/kafka" >}}) is a good motivating example for the use of Operator State in Flink. Each parallel instance of the Kafka consumer maintains a map of topic partitions and offsets as its Operator State. diff --git a/docs/content/docs/dev/datastream/fault-tolerance/state.md b/docs/content/docs/dev/datastream/fault-tolerance/state.md index acb91f717ce98..391b9b30fe51a 100644 --- a/docs/content/docs/dev/datastream/fault-tolerance/state.md +++ b/docs/content/docs/dev/datastream/fault-tolerance/state.md @@ -624,7 +624,7 @@ val counts: DataStream[(String, Int)] = stream ## Operator State -*Operator State* (or *non-keyed state*) is state that is is bound to one +*Operator State* (or *non-keyed state*) is state that is bound to one parallel operator instance. The [Kafka Connector]({{< ref "docs/connectors/datastream/kafka" >}}) is a good motivating example for the use of Operator State in Flink. Each parallel instance of the Kafka consumer maintains a map of topic partitions and offsets as its Operator State.