[flink] branch master updated: Minor example typo fix

[rmetzger]

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;
       }