[TSG-18743] - To adapt the application and protocol metric log field modifications.

2024-01-25 11:30:20 +08:00
parent cd11905877
commit 6047a09e5f
3 changed files with 7 additions and 5 deletions
--- a/src/main/java/com/zdjizhi/utils/functions/process/ParsingData.java
+++ b/src/main/java/com/zdjizhi/utils/functions/process/ParsingData.java
@@ -28,9 +28,11 @@ public class ParsingData extends ProcessFunction<String, Tuple3<Tags, Fields, Lo
                    Tags tags = JSONObject.parseObject(originalLog.getString("tags"), Tags.class);
                    Long timestamp_ms = originalLog.getLong("timestamp_ms");

-                    joinProtocol(tags);
+                    if (StringUtil.isNotBlank(tags.getProtocol_stack_id())) {
+                        joinProtocol(tags);

-                    out.collect(new Tuple3<>(tags, fields, timestamp_ms));
+                        out.collect(new Tuple3<>(tags, fields, timestamp_ms));
+                    }
                }
            }
        } catch (RuntimeException e) {