jackylau created FLINK-27992:
--------------------------------
Summary: cep StreamExecMatch need check the parallelism and
maxParallelism of the two transformation in it
Key: FLINK-27992
URL: https://issues.apache.org/jira/browse/FLINK-27992
Project: Flink
Issue Type: Improvement
Components: Library / CEP
Affects Versions: 1.16.0
Reporter: jackylau
Fix For: 1.16.0
StreamExecMatch node has two transformation (StreamRecordTimestampInserter ->
Match), the upstream of StreamExecMatch is hash edge when use set different
parallelism and maxParallelism it will cause problem.
because the window operator using downstream node's max parallelism compute
keygroup and cep operator using max parallelism of itself and it may not equal
such as:
window - --(hash edge)> StreamRecordTimestampInserter --(forward edge)–> Cep
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
