[flink] 13/15: [hotfix] [docs] Correct the parameter in Operators Overview doc

[tz...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 0078a7c5eb62725ff74bd2411853125096e52d0b
Author: KarmaGYZ <ka...@gmail.com>
AuthorDate: Mon Dec 3 19:09:28 2018 +0800

    [hotfix] [docs] Correct the parameter in Operators Overview doc
    
    This closes #7219.
---
 docs/dev/stream/operators/index.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/dev/stream/operators/index.md b/docs/dev/stream/operators/index.md
index 422dbbf..b89fa89 100644
--- a/docs/dev/stream/operators/index.md
+++ b/docs/dev/stream/operators/index.md
@@ -434,14 +434,14 @@ IterativeStream<Long> iteration = initialStream.iterate();
 DataStream<Long> iterationBody = iteration.map (/*do something*/);
 DataStream<Long> feedback = iterationBody.filter(new FilterFunction<Long>(){
     @Override
-    public boolean filter(Integer value) throws Exception {
+    public boolean filter(Long value) throws Exception {
         return value > 0;
     }
 });
 iteration.closeWith(feedback);
 DataStream<Long> output = iterationBody.filter(new FilterFunction<Long>(){
     @Override
-    public boolean filter(Integer value) throws Exception {
+    public boolean filter(Long value) throws Exception {
         return value <= 0;
     }
 });