You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/12/09 07:46:53 UTC
[flink] branch master updated (2e9f9ad -> 4d142b3)
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%)