[
https://issues.apache.org/jira/browse/FLINK-22442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331344#comment-17331344
]
Cedric Chen commented on FLINK-22442:
-------------------------------------
fix and add the test in CEPScalaApiPatternStreamTest.scala
> 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
> Priority: Major
> Labels: pull-request-available
>
> 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](var 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)
