Description
this line is at the end MemoryChannel.configure(Context)
queue = new LinkedBlockingDeque<StampedEvent>(capacity);
memory channel is meant to be dynamically configurable, however every time it's reconfigured, all existing events are dropped.
Attachments
Attachments
Issue Links
- is duplicated by
-
FLUME-936 MemoryChannel is not thread safe
- Resolved