From 4d3b53cbb7b730d736a6df803dce75d312e3bdf9 Mon Sep 17 00:00:00 2001
From: chaoc <liangchao@geedgenetworks.com>
Date: Thu, 3 Aug 2023 17:16:09 +0800
Subject: [PATCH] fix: collect expire rtp data record

---
 .../com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java b/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java
index 3e600f7..c1d1b12 100644
--- a/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java
+++ b/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java
@@ -104,6 +104,7 @@ public class VoIPFusionFunction extends KeyedCoProcessFunction<Integer, ObjectNo
                 out.collect(obj);
             }
             if (entry.getValue().getExpireTime() <= timestamp) {
+                out.collect(rtpState.get(address).getObj());
                 rtpState.remove(address);
             }
         }