You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2021/11/29 11:04:32 UTC
[flink] branch release-1.14 updated: [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario
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 <11...@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
}