fix: remove rtp from state when fusion successfully

2023-12-07 17:15:11 +08:00
parent 4179a0a887
commit 6d77d1c3c0
1 changed files with 1 additions and 0 deletions
--- a/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java
+++ b/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java
@@ -83,6 +83,7 @@ public class VoIPFusionFunction extends KeyedCoProcessFunction<Tuple2<Integer, A
            rtpRecord.merge(sipObj)
                    .setString(Record.F_COMMON_SCHEMA_TYPE, SchemaType.VOIP.getValue());
            out.collect(rtpObj);
+            iterator.remove();

            switch (entry.getKey()) {
                case S2C: