Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19316 FLIP-134: Batch execution for the DataStream API
  3. FLINK-19326

Allow explicitly configuring time behaviour on CEP PatternStream

    XMLWordPrintableJSON

Details

    • Hide
      Before Flink 1.12 the CEP operations were changing their behavior based on the globally set Stream TimeCharacteristic. In Flink 1.12 we introduced explicit `inProcessingTime()` and `inEventTime()` methods on `PatternStream` and the CEP operations no longer change their behaviour based on the global characteristic.
      Show
      Before Flink 1.12 the CEP operations were changing their behavior based on the globally set Stream TimeCharacteristic. In Flink 1.12 we introduced explicit `inProcessingTime()` and `inEventTime()` methods on `PatternStream` and the CEP operations no longer change their behaviour based on the global characteristic.

    Description

      With the deprecation of StreamExecutionEnvironment.setStreamTimeCharacteristic() in FLINK-19319 we need a way of explicitly configuring the time behaviour of CEP operations. Currently, all CEP operations use the characteristic to configure themselves.

      Attachments

        Issue Links

          Activity

            People

              nicholasjiang Nicholas Jiang
              aljoscha Aljoscha Krettek
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: