-
Notifications
You must be signed in to change notification settings - Fork 3.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
fix opentsdb emitter always be running and fail sending tags whose value contains colon #6251
Conversation
|`druid.emitter.opentsdb.flushThreshold`|Queue flushing threshold.(Events will be sent as one batch)|no|100| | ||
|`druid.emitter.opentsdb.maxQueueSize`|Maximum size of the queue used to buffer events.|no|1000| | ||
|`druid.emitter.opentsdb.consumeDelay`|Queue consuming delay(in milliseconds).|no|10000| |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can we add a short description about what this means like what happen if increased or decreased ? and maybe why 10second is a good default?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done.
@@ -40,28 +43,40 @@ | |||
*/ | |||
private static final String PATH = "/api/put"; | |||
private static final Logger log = new Logger(OpentsdbSender.class); | |||
private static final long FLUSH_TIMEOUT = 60000; // default flush wait 1 min |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
does this means the emitter will block 1 min waiting for the flush to finish?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yes it is. This is learned from other emitter extensions, e.g graphite-emitter.
extensions-contrib/opentsdb-emitter/src/main/java/io/druid/emitter/opentsdb/OpentsdbSender.java
Outdated
Show resolved
Hide resolved
I have tested in my enviroment and worked fine. @b-slim can you help review this PR again, then we can end this as soon as possible. |
Fix #6247 and #6292 . Opentsdb emitter extension was contributed by me, so I help fix these two issues.