Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22442

Using scala api to change the TimeCharacteristic of the PatternStream is invalid

    XMLWordPrintableJSON

Details

    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

          Activity

            People

              wydhcws Cedric Chen
              wydhcws Cedric Chen
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: