From ce09fb63138df9fe00af1281e8ee41cc0ad5bb45 Mon Sep 17 00:00:00 2001 From: minwenjun Date: Sat, 21 Oct 2017 04:11:58 +0800 Subject: [PATCH] fix error in example in get late message in window doc --- docs/dev/stream/operators/windows.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/dev/stream/operators/windows.md b/docs/dev/stream/operators/windows.md index 52c4b479e711b..8b204f8133840 100644 --- a/docs/dev/stream/operators/windows.md +++ b/docs/dev/stream/operators/windows.md @@ -1043,7 +1043,7 @@ final OutputTag lateOutputTag = new OutputTag("late-data"){}; DataStream input = ...; -DataStream result = input +SingleOutputStreamOperator result = input .keyBy() .window() .allowedLateness(