From f4b8ba69d0fc4beadf0a9d96d0df531c4b7c5ab5 Mon Sep 17 00:00:00 2001
From: chaoc <liangchao@geedgenetworks.com>
Date: Thu, 10 Aug 2023 15:31:45 +0800
Subject: [PATCH] fix: error ttl conf

---
 .../com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 dd19245..6fd8d64 100644
--- a/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java
+++ b/src/main/java/com/zdjizhi/flink/voip/functions/VoIPFusionFunction.java
@@ -40,7 +40,7 @@ public class VoIPFusionFunction extends KeyedCoProcessFunction<Tuple2<Integer, A
         final RuntimeContext context = getRuntimeContext();
         final ValueStateDescriptor<ObjectNodeInfo> sipDescriptor =
                 new ValueStateDescriptor<>("sip-state", ObjectNodeInfo.class);
-        sipDoubleDirState = context.getState(sipDescriptor);
+
         final ValueStateDescriptor<ObjectNodeInfo> rtpDescriptor =
                 new ValueStateDescriptor<>("rtp-state", ObjectNodeInfo.class);
 
@@ -55,6 +55,7 @@ public class VoIPFusionFunction extends KeyedCoProcessFunction<Tuple2<Integer, A
         sipDescriptor.enableTimeToLive(ttlConfig);
 
         rtpState = context.getState(rtpDescriptor);
+        sipDoubleDirState = context.getState(sipDescriptor);
     }
 
     @Override