[
https://issues.apache.org/jira/browse/FLINK-21311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17280396#comment-17280396
]
HunterHunter edited comment on FLINK-21311 at 2/7/21, 7:10 AM:
---------------------------------------------------------------
I think it may be that your eligible data are in different partitions, try
adding a keyby to make the data fall in the same partition.
like keyby(_.uid())
was (Author: hunterhunter):
I think it may be that your eligible data are in different partitions, try
adding a keyby to make the data fall in the same partition
> flink1.12 cep does not execute pattern but flink1.10 is ok
> ------------------------------------------------------------
>
> Key: FLINK-21311
> URL: https://issues.apache.org/jira/browse/FLINK-21311
> Project: Flink
> Issue Type: Bug
> Components: Library / CEP
> Affects Versions: 1.12.0
> Reporter: forrest_feng
> Priority: Major
> Attachments: CEPTest.java
>
>
> I am trying to test CEP demo according to Official website example, I found
> no data enter the pattern to print log , finally, I replace my FLINK
> version from 1.12 to 1.10, Flink 1.10 is ok, may be this is bug of Flink
> 1.12
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
