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<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.