You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@inlong.apache.org by GitBox <gi...@apache.org> on 2022/10/12 08:09:40 UTC
[GitHub] [inlong] gosonzhang opened a new issue, #6156: [Bug][DataProxy] Twice event write when topic is empty
gosonzhang opened a new issue, #6156:
URL: https://github.com/apache/inlong/issues/6156
### What happened
In SinkTask.java, if the Topic is empty, the following lines of code will be re-sent twice:
1. https://github.com/apache/inlong/blob/master/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/SinkTask.java#L163
### What you expected to happen
only sent once and topic is null should discard the message
### How to reproduce
use pulsar sink without topic configure and send message
### Environment
Linux
### InLong version
master
### InLong Component
InLong DataProxy
### Are you willing to submit PR?
- [X] Yes, I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@inlong.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [inlong] gosonzhang closed issue #6156: [Bug][DataProxy] Twice event write when topic is empty
Posted by GitBox <gi...@apache.org>.
gosonzhang closed issue #6156: [Bug][DataProxy] Twice event write when topic is empty
URL: https://github.com/apache/inlong/issues/6156
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@inlong.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org