Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Won't Fix
-
0.9.4
-
None
-
None
Description
I have a setup like this:
agent: source | agentDFOChain("collector1:35853", "collector2:35853")
collector1: collectorSource(35853) | collectorSink("hdfs://namenode.company.net:54310/flume/", "%Y_%m_%d_%H-")
collector2: collectorSource(35853) | collectorSink("hdfs://namenode.company.net:54310/flume/", "%Y_%m_%d_%H-")
If both collectors are running, and then collector1 gets into an ERROR state (such as because of the FLUME-798), events are silently dropped. No fail-over takes place to the other node in the chain, and no events are written to disk.