diff --git a/src/main/java/com/zdjizhi/flink/voip/functions/FunctionHelper.java b/src/main/java/com/zdjizhi/flink/voip/functions/FunctionHelper.java index c055db0..216e283 100644 --- a/src/main/java/com/zdjizhi/flink/voip/functions/FunctionHelper.java +++ b/src/main/java/com/zdjizhi/flink/voip/functions/FunctionHelper.java @@ -26,7 +26,7 @@ public interface FunctionHelper extends RichFunction { } default void registerNextFireTimestamp(TimerService timerService, long interval) { - long current = timerService.currentProcessingTime(); - timerService.registerProcessingTimeTimer(current + interval); + long current = timerService.currentWatermark(); + timerService.registerEventTimeTimer(current + interval); } }