[
https://issues.apache.org/jira/browse/FLINK-22442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cedric Chen updated FLINK-22442:
--------------------------------
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
{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}
was:
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}
> 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](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)
