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) {