[ 
https://issues.apache.org/jira/browse/FLUME-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13105178#comment-13105178
 ] 

Longda Feng edited comment on FLUME-763 at 9/15/11 7:25 AM:
------------------------------------------------------------

I have done several tests
1. when I use logicSink/text/agentDFOSink as sink, it works fine, it won't lead 
to all nodes refresh
2. when I config one logicNode with agentDFSChain which hasn't been mapped, not 
through multiconfig, it also works fine, it won't lead to all nodes refresh

      was (Author: longda):
    I have done several tests
1. when I use logicSink/text/agentDFOSink as sink, it works fine, it won't lead 
to all nodes refresh
2. when I config one logicNode with agentDFSChain which hasn't been mapped, it 
also works fine, it won't lead to all nodes refresh
  
> 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

        

Reply via email to