Cedric Chen created FLINK-22442:
-----------------------------------
Summary: 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.2, 1.12.1, 1.12.0
Reporter: Cedric Chen
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)
