Re: ConnectedStream keyby issues

[Aljoscha Krettek]

Yes, that looks right.

> On 10. May 2017, at 14:56, yunfan123 <yunfanfight...@foxmail.com> wrote:
> 
> In upstairs example, it seems I should clear the state in onTimer function in
> order to free resource like follows:
> public void onTimer(long l, OnTimerContext onTimerContext,
> Collector<Tuple2&lt;Integer, ObjectNode>> collector) throws Exception { 
>            if (state.value() != null) { 
>                collector.collect(state.value()); 
>                state.update(null);
>            } 
>        } 
> 
> 
> 
> --
> View this message in context: 
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13090.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at 
> Nabble.com.