[
https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427514#comment-17427514
]
Dawid Wysakowicz commented on FLINK-24489:
------------------------------------------
I believe it is a valid feature request. Bear in mind, the threshold would have
to be implemented on the number of entries, not memory size as we do not know
how much memory those records would occupy as we keep them on the heap. It
might not be straightforward to pick a valid value for such a parameter.
> The size of entryCache in the SharedBuffer should be defined with a threshold
> to avoid OOM
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-24489
> URL: https://issues.apache.org/jira/browse/FLINK-24489
> Project: Flink
> Issue Type: Improvement
> Components: Library / CEP
> Affects Versions: 1.10.0, 1.11.0, 1.12.0, 1.13.0, 1.14.0
> Reporter: Roc Marshal
> Priority: Major
>
> source code :
> [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
