This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e2fe4fb [hotfix][table-planner-blink] Fix the failed
FileSystemTableSinkTest
add 4f6a94f [hotfix] Drop compatibility with Flink <= 1.5
add 5a22de9 [FLINK-19970] State leak in CEP Operators
add fab2e55 [FLINK-19970] Update documentation regarding backwards
compatibility
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/libs/cep.md | 23 +---
docs/content/docs/libs/cep.md | 28 +----
.../main/java/org/apache/flink/cep/nfa/NFA.java | 21 ++--
.../cep/nfa/aftermatch/AfterMatchSkipStrategy.java | 4 +-
.../flink/cep/nfa/sharedbuffer/Lockable.java | 4 +
.../flink/cep/nfa/sharedbuffer/SharedBuffer.java | 114 +++++++++++++-----
.../cep/nfa/sharedbuffer/SharedBufferAccessor.java | 44 +++++--
.../cep/nfa/sharedbuffer/SharedBufferNode.java | 32 ++++--
.../sharedbuffer/SharedBufferNodeSerializer.java | 127 +++++++++++++++++++++
.../SharedBufferNodeSerializerSnapshotV2.java | 39 +++----
.../org/apache/flink/cep/operator/CepOperator.java | 27 +----
.../apache/flink/cep/NFASerializerUpgradeTest.java | 11 +-
.../java/org/apache/flink/cep/nfa/NFAITCase.java | 31 +++++
.../cep/nfa/sharedbuffer/SharedBufferTest.java | 40 +++----
.../flink/cep/operator/CEPMigrationTest.java | 3 -
...cep-migration-after-branching-flink1.3-snapshot | Bin 21980 -> 0 bytes
...cep-migration-after-branching-flink1.4-snapshot | Bin 19058 -> 0 bytes
...cep-migration-after-branching-flink1.5-snapshot | Bin 19390 -> 0 bytes
.../cep-migration-conditions-flink1.3-snapshot | Bin 22425 -> 0 bytes
.../cep-migration-conditions-flink1.4-snapshot | Bin 19503 -> 0 bytes
.../cep-migration-conditions-flink1.5-snapshot | Bin 19835 -> 0 bytes
...ion-single-pattern-afterwards-flink1.3-snapshot | Bin 19770 -> 0 bytes
...ion-single-pattern-afterwards-flink1.4-snapshot | Bin 16848 -> 0 bytes
...ion-single-pattern-afterwards-flink1.5-snapshot | Bin 17180 -> 0 bytes
...igration-starting-new-pattern-flink1.3-snapshot | Bin 21788 -> 0 bytes
...igration-starting-new-pattern-flink1.4-snapshot | Bin 18866 -> 0 bytes
...igration-starting-new-pattern-flink1.5-snapshot | Bin 19198 -> 0 bytes
27 files changed, 374 insertions(+), 174 deletions(-)
create mode 100644
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNodeSerializer.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/runtime/types/CRowSerializerSnapshot.java
=>
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNodeSerializerSnapshotV2.java
(52%)
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.3-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.4-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.5-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.3-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.4-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.5-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.3-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.4-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.5-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.3-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.4-snapshot
delete mode 100644
flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.5-snapshot
