From 96fa19aea1da08c48f888eae4c1dfcf830a53d9f Mon Sep 17 00:00:00 2001
From: chaoc <liangchao@geedgenetworks.com>
Date: Thu, 12 Oct 2023 10:36:44 +0800
Subject: [PATCH] fix: use event time timer

---
 .../java/com/zdjizhi/flink/voip/functions/FunctionHelper.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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);
     }
 }