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

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

                Dates

                • Created:
                  Updated:
                  Resolved: