Re: Multiple windows on a single stream

Dear Carsten, Maybe you need a window with multiple triggers. Best, Alex. On 17 February 2018 at 01:39, Carsten wrote: > Hello all, > > for some of our sensor data we would like to aggregate data for 10sec, > 30sec, 1 min etc., thus conceptually have multiple windows on a single > stream. Curr

Re: [VOTE] Release 1.4.1, release candidate #1

Hi everyone, Is [FLINK-6352] [kafka] Timestamp-based offset configuration for FlinkKafkaConsumer going to make it into 1.4.1? Or it's left for 1.5? Best, Alex. On 13 February 2018 at 19:05, Fabian Hueske wrote: > Hi, > > I check the diff between Flin

Re: [DISCUSS] Releasing Flink 1.4

great On 13 October 2017 at 18:02, Zhijiang(wangzhijiang999) < wangzhijiang...@aliyun.com> wrote: > totally agree with the way.-- > 发件人：Stephan Ewen >发送时间：2017年10月13日(星期五) 21:29收件人：dev@flink.apache.org 主 > 题：Re: [DISCUSS] Releasing

Serialization Issue

My stream is producing records of type Tuple2 *.toString()* output *(usr12345,{"_key":"usr12345","_temperature":46.6})* where the key is *usr12345* and value is *{"_key":"usr12345","_temperature":46.6}* The *.print()* on the stream outputs the value correctly: *(usr12345,{"_key":"usr12345","_tem