[
https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429565#comment-17429565
]
Yuepeng Pan edited comment on FLINK-24489 at 10/22/21, 8:58 AM:
----------------------------------------------------------------
Hi, [~dwysakowicz], [~airblader], [~twalthr], [~jark], [~chesnay]
If it could make sense for introducing threshold values to limit the number of
the cache entries, what about replacing the old cache objects in Map type with
LocalCache in google guava dependency ?
And the corresponding configuration values would be transported via
GlobalParameters.
was (Author: rocmarshal):
Hi, [~dwysakowicz], [~airblader], [~twalthr], [~jark]
If it could make sense for introducing threshold values to limit the number of
the cache entries, what about replacing the old cache objects in Map type with
LocalCache in google guava dependency ?
And the corresponding configuration values would be transported via
GlobalParameters.
> The size of entryCache & eventsBufferCache in the SharedBuffer should be
> defined with a threshold to limit the number of the elements in the cache
> --------------------------------------------------------------------------------------------------------------------------------------------------
>
> 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: Yuepeng Pan
> Priority: Major
> Attachments: 截屏2021-10-13 20.28.17.png
>
>
> 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)
