This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push: new da39169 [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario da39169 is described below commit da39169cd8337b1a667ab07c31a592d727f56df7 Author: Jun Qin <11677043+qinjunje...@users.noreply.github.com> AuthorDate: Thu Sep 16 11:39:45 2021 +0200 [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario --- docs/content.zh/docs/dev/datastream/fault-tolerance/state.md | 4 ++-- docs/content/docs/dev/datastream/fault-tolerance/state.md | 4 ++-- 2 files changed, 4 insertions(+), 4 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 4d8a347..8f4f2d7 100644 --- a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md +++ b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md @@ -692,7 +692,7 @@ public class BufferingSink @Override public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception { bufferedElements.add(value); - if (bufferedElements.size() == threshold) { + if (bufferedElements.size() >= threshold) { for (Tuple2<String, Integer> element: bufferedElements) { // send it to the sink } @@ -739,7 +739,7 @@ class BufferingSink(threshold: Int = 0) override def invoke(value: (String, Int), context: Context): Unit = { bufferedElements += value - if (bufferedElements.size == threshold) { + if (bufferedElements.size >= threshold) { for (element <- bufferedElements) { // send it to the sink } diff --git a/docs/content/docs/dev/datastream/fault-tolerance/state.md b/docs/content/docs/dev/datastream/fault-tolerance/state.md index fb16f40..9cc3e23 100644 --- a/docs/content/docs/dev/datastream/fault-tolerance/state.md +++ b/docs/content/docs/dev/datastream/fault-tolerance/state.md @@ -769,7 +769,7 @@ public class BufferingSink @Override public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception { bufferedElements.add(value); - if (bufferedElements.size() == threshold) { + if (bufferedElements.size() >= threshold) { for (Tuple2<String, Integer> element: bufferedElements) { // send it to the sink } @@ -816,7 +816,7 @@ class BufferingSink(threshold: Int = 0) override def invoke(value: (String, Int), context: Context): Unit = { bufferedElements += value - if (bufferedElements.size == threshold) { + if (bufferedElements.size >= threshold) { for (element <- bufferedElements) { // send it to the sink }