[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16786624#comment-16786624 ]
chunpinghe commented on FLINK-11852: ------------------------------------ you are right,it's meaningful! > Improve Processing function example > ----------------------------------- > > Key: FLINK-11852 > URL: https://issues.apache.org/jira/browse/FLINK-11852 > Project: Flink > Issue Type: Improvement > Components: Documentation > Affects Versions: 1.7.2 > Reporter: Flavio Pompermaier > Priority: Minor > > In the processing function documentation > ([https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/process_function.html)] > there's an "abusive" usage of the timers since a new timer is registered for > every new tuple coming in. This could cause problems in terms of allocated > objects and could burden the overall application. > It could worth to mention this problem and remove useless timers, e.g.: > > {code:java} > CountWithTimestamp current = state.value(); > if (current == null) { > current = new CountWithTimestamp(); > current.key = value.f0; > } else { > ctx.timerService().deleteEventTimeTimer(current.lastModified + timeout); > }{code} > -- This message was sent by Atlassian JIRA (v7.6.3#76005)