This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 4863bc1 [hotfix][docs] Update references to deprecated SinkFunction#invoke(Object) 4863bc1 is described below commit 4863bc1aa7c376a996b66953c2cbd7afb6eccc1f Author: intsmaze <liuyang...@vip.qq.com> AuthorDate: Wed Jan 16 20:26:02 2019 +0800 [hotfix][docs] Update references to deprecated SinkFunction#invoke(Object) --- docs/dev/stream/state/state.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md index 8fe2981..1654c9a 100644 --- a/docs/dev/stream/state/state.md +++ b/docs/dev/stream/state/state.md @@ -475,7 +475,7 @@ public class BufferingSink } @Override - public void invoke(Tuple2<String, Integer> value) throws Exception { + public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception { bufferedElements.add(value); if (bufferedElements.size() == threshold) { for (Tuple2<String, Integer> element: bufferedElements) { @@ -523,7 +523,7 @@ class BufferingSink(threshold: Int = 0) private val bufferedElements = ListBuffer[(String, Int)]() - override def invoke(value: (String, Int)): Unit = { + override def invoke(value: (String, Int), context: Context): Unit = { bufferedElements += value if (bufferedElements.size == threshold) { for (element <- bufferedElements) {