From b2f15b3919fb19e60689a45fa438748adeb2d5bb Mon Sep 17 00:00:00 2001 From: chaoc Date: Mon, 28 Aug 2023 11:11:02 +0800 Subject: [PATCH] style: modify job name --- src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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"); } }