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

LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

    XMLWordPrintableJSON

    Details

      Description

      @Override
      public void register*ProcessingTime*Timer(long time) {
        ensureInitialized();
        internalTimerService.registerEventTimeTimer(VoidNamespace.INSTANCE, time);
      }

      Same issue for both registerEventTimeTimer and registerProcessingTimeTimer.

      https://github.com/apache/flink/blob/master/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/LazyTimerService.java#L62

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                sjwiesman Seth Wiesman
                Reporter:
                alaczynski Adam Laczynski
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: