This is an automated email from the ASF dual-hosted git repository. dianfu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 6f7c273be14 [FLINK-27304][hive] Calcite's varbinary type should be converted to Hive's binary type. add 4a82df07d70 [FLINK-27392][cep] CEP Pattern supports definition of the maximum time gap between events No new revisions were added by this update. Summary of changes: .../org/apache/flink/cep/nfa/ComputationState.java | 31 ++- .../org/apache/flink/cep/nfa/MigrationUtils.java | 2 +- .../main/java/org/apache/flink/cep/nfa/NFA.java | 47 +++- .../apache/flink/cep/nfa/NFAStateSerializer.java | 31 ++- .../flink/cep/nfa/NFAStateSerializerSnapshot.java | 40 ++- .../apache/flink/cep/nfa/compiler/NFACompiler.java | 81 ++++-- .../cep/nfa/compiler/NFAStateNameHandler.java | 2 +- .../java/org/apache/flink/cep/pattern/Pattern.java | 100 ++++++- .../org/apache/flink/cep/pattern/Quantifier.java | 29 +- ...formedPatternException.java => WithinType.java} | 17 +- .../test/java/org/apache/flink/cep/CEPITCase.java | 131 ++++++++- .../apache/flink/cep/NFASerializerUpgradeTest.java | 5 +- .../java/org/apache/flink/cep/nfa/NFAITCase.java | 305 ++++++++++++++++++++- .../java/org/apache/flink/cep/nfa/NFATest.java | 49 +++- .../org/apache/flink/cep/nfa/NotPatternITCase.java | 26 +- .../apache/flink/cep/nfa/TimesOrMoreITCase.java | 136 +++++---- .../org/apache/flink/cep/nfa/TimesRangeITCase.java | 145 ++++++---- .../flink/cep/nfa/compiler/NFACompilerTest.java | 41 +++ 18 files changed, 1015 insertions(+), 203 deletions(-) copy flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/{MalformedPatternException.java => WithinType.java} (70%)