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
the sink lost span while sending them to zipkin collecter
cased by class ZipkinSpanCollectorSink on line 114
while ((event = channel.take()) != null && count < batchSize) {
some events are already taken from the channel even count < batchSize is false
should be changed to
while (count < batchSize && (event = channel.take()) != null) {
The text was updated successfully, but these errors were encountered:
Bugfix is checked in. Problem is that there are no unit tests for flume sinks because they are a pain to test because of the inheriting from AbstractSink. But I might add tests later anyway to ensure these kinds of bugs do not recur.
the sink lost span while sending them to zipkin collecter
cased by class ZipkinSpanCollectorSink on line 114
while ((event = channel.take()) != null && count < batchSize) {
some events are already taken from the channel even count < batchSize is false
should be changed to
while (count < batchSize && (event = channel.take()) != null) {
The text was updated successfully, but these errors were encountered: