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