I am calling env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); I am using Flink 11.1 (because I need to run on AWS Kinesis Data Analytics).
-Pilgrim -- Learn more at https://devicepilot.com @devicepilot <https://t.sidekickopen70.com/s2t/c/5/f18dQhb0S7kv8cpgQZVc6VPt59hl3kW7_k2842PjkFxW2R1KhZ7v4vclW2Rxbb82bzNKzf7GYHvr01?te=W3R5hFj4cm2zwW4fQ47l4fGCmnW3Fbt5S3H4THtF3F6jFSWsSg1&si=5987503666495488&pi=4b3a0a5f-bfb3-4288-eaa5-6f8e5d0f77cb> +44 7961 125282 See our latest features <https://t.sidekickopen70.com/s2t/c/5/f18dQhb0S7kv8cpgQZVc6VPt59hl3kW7_k2842PjkFxW2R1KhZ7v4vclW2Rxbb82bzNKzf7GYHvr01?te=W3R5hFj4cm2zwW3Q_1QY1JxXxvW3SYLMH3T0vWRW1JxwY51LDhHjW3K1M0S1GFyF-3b732&si=5987503666495488&pi=4b3a0a5f-bfb3-4288-eaa5-6f8e5d0f77cb> and book me <https://t.sidekickopen70.com/s2t/c/5/f18dQhb0S7kv8cpgQZVc6VPt59hl3kW7_k2842PjkFxW2R1KhZ7v4vclW2Rxbb82bzNKzf7GYHvr01?te=W3R5hFj4cm2zwW3T1k3k1JxXxvW3SYLMH3T0vWRW1JxwY51LBcj1W4fJfX_4cgB3QW3ZW3jf3_qrT_4Wt5h1&si=5987503666495488&pi=4b3a0a5f-bfb3-4288-eaa5-6f8e5d0f77cb> for a video call. On Wed, 27 Jan 2021 at 17:07, Aljoscha Krettek <[email protected]> wrote: > On 2021/01/27 15:09, Chesnay Schepler wrote: > >Put another way, if you use any of the built-in WatermarkGenerators and > >use event-time, then it appears that you *must* set this interval. > > > >This behavior is...less than ideal I must admit, and it does not > >appear to be properly documented. > > Setting the watermark interval is done when calling > `env.setStreamTimeCharacteristic()`. It's the first thing we documented > for working with event time [1]. > > [1] > > https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/event_time.html > > To me it was always a usability problem that we didn't have event time > enabled by default. We didn't have this because of "performance > considerations". This changed in Flink 1.12 [2]. > > [2] https://issues.apache.org/jira/browse/FLINK-19317 > > @Pilgrim: Which version of Flink are you using? >
