diff --git a/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java b/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java index 4136c4c..58b5e53 100644 --- a/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java +++ b/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java @@ -94,6 +94,6 @@ public class CorrelateApp { voIpOperator.addSink(producer); - env.execute("VoIP Fusion Job"); + env.execute("SIP-RTP-CORRELATION"); } }