[
https://issues.apache.org/jira/browse/FLINK-22442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-22442.
------------------------------------
Fix Version/s: 1.12.4
1.13.1
1.14.0
Resolution: Fixed
Fixed in:
* master
** cb0d8eb85048cfb08be54e75f2f90b1d590b7ae0
* 1.13.1
** 32c64bb4d30499f602079cd34c73371106fe09c3
* 1.12.4
** c9b51568d56b57a905d28b898408166db1f66a15
> Using scala api to change the TimeCharacteristic of the PatternStream is
> invalid
> --------------------------------------------------------------------------------
>
> Key: FLINK-22442
> URL: https://issues.apache.org/jira/browse/FLINK-22442
> Project: Flink
> Issue Type: Bug
> Components: Library / CEP
> Affects Versions: 1.12.0, 1.12.1, 1.12.2
> Reporter: Cedric Chen
> Assignee: Cedric Chen
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.14.0, 1.13.1, 1.12.4
>
>
> Using scala api to change the TimeCharacteristic of the PatternStream is
> invalid
> you can only use the eventTime for PatternStream
> the bug is ：
> in the code in org.apache.flink.cep.scala.PatternStream
> when we called function like inProcessingTime()
> the real JPatternStream in the object not be updated
> {code:java}
> // org.apache.flink.cep.scala.PatternStream
> class PatternStream[T](jPatternStream: JPatternStream[T]) {
> private[flink] def wrappedPatternStream = jPatternStream
> ......
> def sideOutputLateData(lateDataOutputTag: OutputTag[T]): PatternStream[T] = {
> jPatternStream.sideOutputLateData(lateDataOutputTag)
> this
> }
> def inProcessingTime(): PatternStream[T] = {
> jPatternStream.inProcessingTime()
> this
> }
> def inEventTime(): PatternStream[T] = {
> jPatternStream.inEventTime()
> this
> }
> ｝
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
