[jira] [Created] (FLINK-11852) Improve Processing function example

[Shang Yuanchun (Jira)]

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)