jason.lee created FLUME-3097: -------------------------------- Summary: CLONE - WAL data grows forever even though data is delivered in E2E Key: FLUME-3097 URL: https://issues.apache.org/jira/browse/FLUME-3097 Project: Flume Issue Type: Bug Components: Master, Node, Sinks+Sources Reporter: jason.lee Priority: Blocker
With a heavy enough write load, it appears that the E2E agent WAL will get into a state where data just gets constantly shuffled around between the various directories / states (e.g. writing, logged, sending, sent). When this happens, the WAL directories grow indefinitely until the disk is exhausted, no matter how much data caused the problem. To reproduce: * Use the supplied config (or something similar). * Write to the agent source at a rate of > 1MB/s for a short burst (using something like the provided generator below). * Note that data is delivered to the collectorSink but the agent WAL manager constantly grows the data. The config: {code} n1 : execStream("tail -F datafile") | agentE2ESink("host", 12345); n2 : collectorSource(12345) | collectorSink("file://...", "n2-"); {code} Generator: {code} perl -e 'while (1) { print $i++, "\n"; }' >> datafile {code} This looks and smells just like FLUME-430. I haven't yet examined the WAL or destination data for duplicates / missing events. -- This message was sent by Atlassian JIRA (v6.3.15#6346)