flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From juanmirocks <...@git.apache.org>
Subject [GitHub] flink issue #4997: [FLINK-8046] [flink-streaming-java] Have filter of timest...
Date Sun, 12 Nov 2017 16:49:58 GMT
Github user juanmirocks commented on the issue:

    No. I don't think this is going to be a suitable solution, as if = is allowed in the comparison,
the very same file will be triggered multiple times.
    Note that the older and deprecated `FileMonitoringFunction` solves this situation by having
a map of filenames to modification times. More robust but also more expensive memory-wise.
A limit to a possible map could be given in `LinkedHashMap` with `removeEldestEntry`.


View raw message