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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0, 1.12.1, 1.12.2
• Fix Version/s: 1.14.0, 1.13.1, 1.12.4
• Component/s: Library / CEP
• Labels: pull-request-available
• Assignee: Cedric Chen
• Reporter: Cedric Chen
• Created: 24/Apr/21 13:32
• Updated: 28/May/21 11:08
• Resolved: 05/May/21 19:12

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
  }
｝
}

Issue Links

• links to: GitHub Pull Request #15742