[
https://issues.apache.org/jira/browse/FLINK-21311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363759#comment-17363759
]
Yue Ma edited comment on FLINK-21311 at 6/15/21, 4:39 PM:
----------------------------------------------------------
[~forrest_feng] The main reason is that *EventTime* is used in flink-1.12 as
the default TimeCharacteristic, so you need to extract the event time from your
input data. If you still want to process with the *ProcessingTime* , you can do
like this
{code:java}
CEP.pattern(eventDataStream, pattern).inProcessingTime().select(...)...{code}
was (Author: mayuehappy):
[~forrest_feng] The main reason is that *EventTime* is used in flink-1.12 as
the default TimeCharacteristic, so you need to extract the event time from your
input data. If you still want to process with the *ProcessingTime* , you can do
like this
{code:java}
// code placeholder{code}
CEP.pattern(eventDataStream, pattern).*inProcessingTime*().select(...)...
> 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: Minor
> Labels: auto-deprioritized-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)
