diff options
| author | chaochaoc <[email protected]> | 2024-11-16 16:07:06 +0800 |
|---|---|---|
| committer | chaochaoc <[email protected]> | 2024-11-16 16:07:06 +0800 |
| commit | 170f495a1123662387613753086814a856db848c (patch) | |
| tree | 48b42b588be23f1e82796b3b8210df331e0c9bcd | |
| parent | b3b233172fbe2c296e0e464957e04a4161624b98 (diff) | |
fix: remove duplicate sip and rtp
| -rw-r--r-- | pom.xml | 2 | ||||
| -rw-r--r-- | src/main/resources/jobs/job.yml | 11 |
2 files changed, 11 insertions, 2 deletions
@@ -7,7 +7,7 @@ <groupId>com.geedgenetworks.application</groupId> <artifactId>sip-rtp-correlation</artifactId> - <version>2.1</version> + <version>2.1.1</version> <name>Flink : SIP-RTP : Correlation</name> diff --git a/src/main/resources/jobs/job.yml b/src/main/resources/jobs/job.yml index 7d6eb76..5d3fd0e 100644 --- a/src/main/resources/jobs/job.yml +++ b/src/main/resources/jobs/job.yml @@ -825,6 +825,12 @@ pipeline: - name: voip-fusion category: CORRELATE cache: + - name: sip_status + type: VALUE + ttl: 10 minute + schema: + - name: be_used + data-type: BOOLEAN - name: sip type: VALUE ttl: 7 minute @@ -1575,6 +1581,7 @@ pipeline: @i.$rtp_payload_type_s2c AS rtp_payload_type_s2c, @i.$rtp_pcap_path AS rtp_pcap_path, ( @i.$client_ip == sip_originator_sdp_connect_ip).?(1, (@i.$client_ip == sip_responder_sdp_connect_ip).?(2, 0) ) AS rtp_originator_dir + - SET sip_status FROM true AS be_used - TRUNCATE rtp # TODO USE EVENT - SCHEDULING USING PROCESS TIME FOR NOW + 6 * 60 * 1000 @@ -1662,6 +1669,8 @@ pipeline: @i.$rtp_payload_type_s2c AS rtp_payload_type_s2c, @i.$rtp_pcap_path AS rtp_pcap_path, ( @i.$client_ip == @sip.$sip_originator_sdp_connect_ip).?(1, (@i.$client_ip == @sip.$sip_responder_sdp_connect_ip).?(2, 0) ) AS rtp_originator_dir + - SET sip_status FROM true AS be_used + - TRUNCATE rtp - SCHEDULING USING PROCESS TIME FOR NOW + 6 * 60 * 1000 schedule: - if: '@rtp.isNotNull && @rtp.cardinality > 0' @@ -1797,7 +1806,7 @@ pipeline: @i.$rtp_pcap_path AS rtp_pcap_path, @i.$rtp_originator_dir AS rtp_originator_dir - TRUNCATE rtp - - if: '@sip.isNotNull' + - if: '@sip.isNotNull && ( @sip_status.isNull || !@sip_status.$be_used )' then: - |- OUTPUT fail FROM @sip.$recv_time AS recv_time, |