????????????Watermark??flatmap??????????????

env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...) env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...); kafka??Watermark??flatMap()?? flatMap??1-N

?????? ????????????Watermark??flatmap??????????????

??kafka??event-time?? ??kafka ??flatmap??event-time

?????????????????????? ????????????Watermark??flatmap??????????????

??github https://github.com/maobuji/Blog/blob/master/image/changeEventTime.jpg --  -- ??: ""<16770...@qq.com>; : 2019??12??18??(??) 4:03 ??: "user-zh"