flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Flavio Pompermaier (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-11852) Improve Processing function example
Date Thu, 07 Mar 2019 10:59:00 GMT
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.:

CountWithTimestamp current = state.value();
if (current == null) {
     current = new CountWithTimestamp();
     current.key = value.f0;
 } else {
    ctx.timerService().deleteEventTimeTimer(current.lastModified + timeout);

This message was sent by Atlassian JIRA

View raw message