style: modify job name

2023-08-28 11:11:02 +08:00
parent 98bb843159
commit b2f15b3919
1 changed files with 1 additions and 1 deletions
--- 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");
    }
 }