[jira] [Created] (FLINK-22442) Using scala api to change the TimeCharacteristic of the PatternStream is invalid

["Cedric Chen (Jira)" <ji...@apache.org>]

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)