From 71030877555962f509101024a9638b9852d8de05 Mon Sep 17 00:00:00 2001 From: mans2singh Date: Sun, 25 Apr 2021 16:48:59 -0400 Subject: [PATCH] [hotfix][docs] Removed duplicate 'is' --- docs/content.zh/docs/dev/datastream/fault-tolerance/state.md | 2 +- docs/content/docs/dev/datastream/fault-tolerance/state.md | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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.