Re: ConnectedStream keyby issues

[yunfan123]

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.