Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.12.0, 1.12.1, 1.12.2
Description
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
// 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 } } }
Attachments
Issue Links
- links to