You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ji...@apache.org on 2018/12/25 07:29:34 UTC

[flink] branch release-1.7 updated: [hotfix] [docs] Fix wrong window time unit for window join documentation.

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

jincheng pushed a commit to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.7 by this push:
     new 30e0a8d  [hotfix] [docs]  Fix wrong window time unit for window join documentation.
30e0a8d is described below

commit 30e0a8d64fe5e1d13d3a82064affa17439fc2d65
Author: libenchao <li...@guazi.com>
AuthorDate: Fri Dec 21 19:53:20 2018 +0800

    [hotfix] [docs]  Fix wrong window time unit for window join documentation.
    
    This closes #7349
---
 docs/dev/stream/operators/joining.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/dev/stream/operators/joining.md b/docs/dev/stream/operators/joining.md
index 7e9915e..c415f63 100644
--- a/docs/dev/stream/operators/joining.md
+++ b/docs/dev/stream/operators/joining.md
@@ -70,7 +70,7 @@ DataStream<Integer> greenStream = ...
 orangeStream.join(greenStream)
     .where(<KeySelector>)
     .equalTo(<KeySelector>)
-    .window(TumblingEventTimeWindows.of(Time.seconds(2)))
+    .window(TumblingEventTimeWindows.of(Time.milliseconds(2)))
     .apply (new JoinFunction<Integer, Integer, String> (){
         @Override
         public String join(Integer first, Integer second) {