diff options
| author | gujinkai <[email protected]> | 2023-07-25 10:54:29 +0800 |
|---|---|---|
| committer | gujinkai <[email protected]> | 2023-07-25 11:00:34 +0800 |
| commit | c9ffda0ae547d4dce57a59b33b353e43e56eefec (patch) | |
| tree | 128a385188516005dfc029a4c8bf6fb6a8f69b11 | |
| parent | c061bd2d40d70f3605a143e9bb93d2f445b01ffa (diff) | |
调整DNS预聚合的更新逻辑23.07
| -rw-r--r-- | module-DNS-pre-metrics/src/main/java/com/zdjizhi/dns/pre/process/FirstAggregationProcess.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/module-DNS-pre-metrics/src/main/java/com/zdjizhi/dns/pre/process/FirstAggregationProcess.java b/module-DNS-pre-metrics/src/main/java/com/zdjizhi/dns/pre/process/FirstAggregationProcess.java index 179117a..4386efe 100644 --- a/module-DNS-pre-metrics/src/main/java/com/zdjizhi/dns/pre/process/FirstAggregationProcess.java +++ b/module-DNS-pre-metrics/src/main/java/com/zdjizhi/dns/pre/process/FirstAggregationProcess.java @@ -266,7 +266,7 @@ public class FirstAggregationProcess extends ProcessWindowFunction<CnRecordLog, dnsMetricLog.setDns_count(cnRecordLog.getDns_count()+dnsMetricLog.getDns_count()); dnsMetricLog.setDns_response_latency_ms(cnRecordLog.getDns_response_latency_ms()+dnsMetricLog.getDns_response_latency_ms()); dnsMetricLog.setTraffic_outbound_byte(cnRecordLog.getTraffic_outbound_byte() + dnsMetricLog.getTraffic_outbound_byte()); - dnsMetricLog.setTraffic_inbound_byte(cnRecordLog.getTraffic_outbound_pkt() + dnsMetricLog.getTraffic_inbound_byte()); + dnsMetricLog.setTraffic_inbound_byte(cnRecordLog.getTraffic_inbound_byte() + dnsMetricLog.getTraffic_inbound_byte()); dnsMetricLog.setInternal_query_num(cnRecordLog.getInternal_query_num()+dnsMetricLog.getInternal_query_num()); dnsMetricLog.setExternal_query_num(cnRecordLog.getExternal_query_num()+dnsMetricLog.getExternal_query_num()); } |