flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yunfan123 <yunfanfight...@foxmail.com>
Subject Re: ConnectedStream keyby issues
Date Wed, 10 May 2017 12:56:08 GMT
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.

Mime
View raw message