You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Ashish Paliwal (JIRA)" <ji...@apache.org> on 2014/11/05 12:21:33 UTC
[jira] [Resolved] (FLUME-895) ThriftEventSource sometime can't be
closed when reconfig plugin , the spawn-threads num increase 1 per
heartbeat
[ https://issues.apache.org/jira/browse/FLUME-895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ashish Paliwal resolved FLUME-895.
----------------------------------
Resolution: Won't Fix
Won't fix. 0.X branch not maintained anymore
> ThriftEventSource sometime can't be closed when reconfig plugin , the spawn-threads num increase 1 per heartbeat
> ------------------------------------------------------------------------------------------------------------------
>
> Key: FLUME-895
> URL: https://issues.apache.org/jira/browse/FLUME-895
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: v0.9.3
> Reporter: jeff
> Priority: Critical
> Fix For: v0.9.5
>
>
> In agent,I config as: rpcSource(333)| agentDFOChain("157.5.210.6:17876","157.5.210.5:17876")
> In collector,I config as: collector(17876)|myCustomplugin
> At agent mashine, I use a flume rpc client send 1000 event per sencond, after about five munite, i looked the agent monitor page, the metric "source.LazyOpenSource.ThriftEventSource.queueCapacity " is 1000 ,which is the default size of the blocke queue in thrifteventsource,the "Source.LazyOpenSource.ThriftEventSource.enqueued" is 1357
> when I use flume shell commit reconfig agent: exec config agent_01 'rpcSource(333)' 'agentDFOChain("157.5.210.6:17876","157.5.210.5:17876")'
> I found the rpcsource cann't be reopen, the netstat command can't found port 3333 is in listen, in log, I found the SpawningLogicalNode thread is spawn on every heartbeat
> [2011-12-12 08:03:15,670] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.handlers.thrift.ThriftEventSource 164] Closed server on port 3333...
> [2011-12-12 08:03:15,670] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.handlers.thrift.ThriftEventSource 167] Queue still has 898 elements ...
> [2011-12-12 08:03:18,614] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:18,614] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:18,615] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:23,630] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:23,630] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:23,661] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:28,643] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:28,644] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:28,644] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:33,659] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:33,659] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:33,659] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:38,665] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:38,704] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:38,704] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:43,672] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:43,673] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:43,673] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:48,680] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:48,680] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:48,680] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:53,684] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:53,685] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:53,764] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:58,688] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:03:58,688] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:03:58,688] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:03,699] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:03,699] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:03,699] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:08,732] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:08,771] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:08,773] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:13,741] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:13,741] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:13,742] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:18,755] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:18,755] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:18,755] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:23,764] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:23,764] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:23,819] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:28,772] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:28,773] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:28,773] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:33,782] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:33,782] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:33,782] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:38,792] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
> [2011-12-12 08:04:38,792] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 164] Setting dfo failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:38,792] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 73] Setting failover chain to < failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") ? diskFailover insistentAppend stubbornAppend insistentOpen failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)") >
> [2011-12-12 08:04:43,796] [INFO ] [SpawningLogicalNode pm_C04_JQ3_CNA03_E6000_a] [com.cloudera.flume.agent.AgentFailChainSink 135] Setting best effort failover chain to failChain("{ lazyOpen => { stubbornAppend => %s } } ","tsink(\"157.5.210.5\",17876)","tsink(\"157.5.210.6\",17876)")
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)