You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In the MixedUtils.buildMessage() function, there is a bug hidden in the above part: when the filter item does not exist, the message reporting time information will not be filled in the message, although these two parameters are filled in through the same API, analyze the implementation of putSystemHeader, It is a setting that supports the case where two parameters are null at the same time. Therefore, it is necessary to adjust here to avoid the situation of missing information.
What happened
See https://github.com/apache/incubator-inlong/blob/master/inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/utils/MixedUtils.java#L125
In the MixedUtils.buildMessage() function, there is a bug hidden in the above part: when the filter item does not exist, the message reporting time information will not be filled in the message, although these two parameters are filled in through the same API, analyze the implementation of putSystemHeader, It is a setting that supports the case where two parameters are null at the same time. Therefore, it is necessary to adjust here to avoid the situation of missing information.
What you expected to happen
send message without filter item
How to reproduce
send message without filter item
Environment
windows
InLong version
master
InLong Component
InLong TubeMQ
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: