This is an automated email from the ASF dual-hosted git repository. rmetzger 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 f9ec828 Minor example typo fix f9ec828 is described below commit f9ec828b91fc475f6169a7edce5c4e23f7e4407e Author: Ankur <angoe...@users.noreply.github.com> AuthorDate: Tue Mar 19 16:44:39 2019 -0700 Minor example typo fix --- docs/dev/batch/dataset_transformations.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/dev/batch/dataset_transformations.md b/docs/dev/batch/dataset_transformations.md index cf2da3f..112572f 100644 --- a/docs/dev/batch/dataset_transformations.md +++ b/docs/dev/batch/dataset_transformations.md @@ -593,7 +593,7 @@ public class DistinctReduce String next = t.f1; // check if strings are different - if (com == null || !next.equals(comp)) { + if (comp == null || !next.equals(comp)) { out.collect(new Tuple2<Integer, String>(key, next)); comp = next; }