This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2e9f9ad [FLINK-24728][tests] Add tests to ensure SQL file sink closes
all created files
add 4d142b3 [FLINK-24489][CEP] The size of entryCache & eventsBufferCache
in the SharedBuffer should be defined with a threshold to limit the number of
the elements in the cache
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/libs/cep.md | 8 +
docs/content/docs/libs/cep.md | 10 ++
.../generated/cep_cache_configuration.html | 30 ++++
flink-docs/pom.xml | 6 +
.../configuration/ConfigOptionsDocGenerator.java | 7 +-
.../flink/cep/configuration/CEPCacheOptions.java | 65 ++++++++
.../cep/configuration/SharedBufferCacheConfig.java | 70 +++++++++
.../flink/cep/nfa/sharedbuffer/SharedBuffer.java | 174 ++++++++++++++++-----
.../org/apache/flink/cep/operator/CepOperator.java | 10 +-
.../test/java/org/apache/flink/cep/CEPITCase.java | 61 ++++++--
.../nfa/NFAIterativeConditionTimeContextTest.java | 2 +-
.../cep/nfa/sharedbuffer/SharedBufferTest.java | 37 +++--
.../flink/cep/operator/CEPMigrationTest.java | 26 +--
.../apache/flink/cep/operator/CEPOperatorTest.java | 29 ++--
.../flink/cep/operator/CEPRescalingTest.java | 4 +-
.../operator/CepProcessFunctionContextTest.java | 2 +-
.../flink/cep/operator/CepRuntimeContextTest.java | 2 +-
.../CepOperatorTestUtilities.java | 13 +-
.../apache/flink/cep/utils/TestSharedBuffer.java | 15 ++
19 files changed, 470 insertions(+), 101 deletions(-)
create mode 100644
docs/layouts/shortcodes/generated/cep_cache_configuration.html
create mode 100644
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/configuration/CEPCacheOptions.java
create mode 100644
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/configuration/SharedBufferCacheConfig.java
rename flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/{operator
=> utils}/CepOperatorTestUtilities.java (91%)
