Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5497#discussion_r169626782
--- Diff: docs/dev/migration.md ---
@@ -145,16 +145,16 @@ public class BufferingSink implements
SinkFunction<Tuple2<String, Integer>>,
bufferedElements.add(value);
if (bufferedElements.size() == threshold) {
for (Tuple2<String, Integer> element: bufferedElements) {
- // send it to the sink
- }
- bufferedElements.clear();
- }
+ // send it to the sink
+ }
+ bufferedElements.clear();
--- End diff --
hmm, it should be `{% highlight java %}`, in particular since
[FLINK-8726](https://issues.apache.org/jira/browse/FLINK-8726) popped up.
---
