mapping physical node to logic node will lead to all nodes refresh
------------------------------------------------------------------
Key: FLUME-763
URL: https://issues.apache.org/jira/browse/FLUME-763
Project: Flume
Issue Type: Bug
Components: Master
Affects Versions: v0.9.4
Reporter: Longda Feng
Priority: Critical
master node's hostname: hbase1
other normal nodes: hbase2, hbase3, hbase6
Steps:
1.hbase6:text("/home/hadoop/open_file")|text("/home/hadoop/output_open_file");
wait 20 minutes
the version is "11/09/15 10:50:55"
2.
multiconfig
[dataProduce:text("/home/hadoop/open_file")|agentDFOChain("hbase3:39998",
"hbase6:39998");
dataConsumer1:collectorSource(39998)|text("/home/hadoop/output_dfochain_open_file");
dataConsumer2:collectorSource(39998)|text("/home/hadoop/output_dfochain_open_file");]
map hbase2 dataProduce
map hbase3 dataConsumer1
map hbase6 dataConsumer2
3. all node's configuration version update to the latest time, resend old data
it will lead to the data in /home/hadoop/open_file has been sent again.
the log is
11/09/15 10:50:55 INFO debug.TextFileSource: File /home/hadoop/open_file opened
11/09/15 11:25:12 INFO debug.TextFileSource: File /home/hadoop/open_file closed
11/09/15 11:25:12 INFO agent.LogicalNode: Node config successfully set to
com.cloudera.flume.conf.FlumeConfigData@1bc58a7
11/09/15 11:25:12 INFO debug.TextFileSource: File /home/hadoop/open_file opened
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira