Flavio Pompermaier created FLINK-11852:
------------------------------------------
Summary: 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
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)
