1、传输kafka数据添加字段

e3f262be · 周昊 · bd02b255 · e3f262be
Commit e3f262be authored Oct 10, 2023 by 周昊
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

src/main/java/com/censoft/flink/StreamingJob.java src/main/java/com/censoft/flink/StreamingJob.java +1 -0

No files found.
--- a/src/main/java/com/censoft/flink/StreamingJob.java
+++ b/src/main/java/com/censoft/flink/StreamingJob.java
@@ -93,6 +93,7 @@ public class StreamingJob {
            warnPushBase.setStatus("wait");
            warnPushBase.setSendUserIds("|1|");
            warnPushBase.setDelFlag(0);
+            warnPushBase.setRemark(algorithmPushDto.getRemark());
            return JSON.toJSONString(warnPushBase);
        });