<%= @agent_name %>.channels = memoryChannel
<%= @agent_name %>.channels.memoryChannel.type = memory
<%= @agent_name %>.sources = pstream
<%= @agent_name %>.sources.pstream.channels = memoryChannel
<%= @agent_name %>.sources.pstream.type = exec
<%= @agent_name %>.sources.pstream.command = tail -f <%= @log_location %>
<%= @agent_name %>.sinks = hdfsSink
<%= @agent_name %>.sinks.hdfsSink.type = hdfs
<%= @agent_name %>.sinks.hdfsSink.channel = memoryChannel
<%= @agent_name %>.sinks.hdfsSink.hdfs.useLocalTimeStamp = true
<%= @agent_name %>.sinks.hdfsSink.hdfs.path = <%= node['bcpc']['hadoop']['hdfs_url'] %>/user/flume/logs/%y-%m-%d
<%= @agent_name %>.sinks.hdfsSink.hdfs.filePrefix = <%= @agent_name %>-<%= node.hostname %>
<%= @agent_name %>.sinks.hdfsSink.hdfs.fileType = DataStream
<%= @agent_name %>.sinks.hdfsSink.hdfs.writeFormat = Text
<%= @agent_name %>.sinks.hdfsSink.hdfs.rollInterval = <%= node['bcpc']['hadoop']['copylog_rollup_interval'] %>
<%= @agent_name %>.sinks.hdfsSink.hdfs.rollSize = 0
<%= @agent_name %>.sinks.hdfsSink.hdfs.rollCount = 0

<%= @agent_name %>.channels = memoryChannel
<%= @agent_name %>.channels.memoryChannel.type = memory
<%= @agent_name %>.channels.memoryChannel.capacity = 10000
<%= @agent_name %>.sources = pstream
<%= @agent_name %>.sources.pstream.channels = memoryChannel
<%= @agent_name %>.sources.pstream.type = exec
<%= @agent_name %>.sources.pstream.command = tail -f <%= @log_location %>
<%= @agent_name %>.sinks = hdfsSink
<%= @agent_name %>.sinks.hdfsSink.type = hdfs
<%= @agent_name %>.sinks.hdfsSink.channel = memoryChannel
<%= @agent_name %>.sinks.hdfsSink.hdfs.useLocalTimeStamp = true
<%= @agent_name %>.sinks.hdfsSink.hdfs.path = <%= node['bcpc']['hadoop']['hdfs_url'] %>/user/flume/logs/%y-%m-%d
<%= @agent_name %>.sinks.hdfsSink.hdfs.filePrefix = <%= @agent_name %>-<%= node.hostname %>
<%= @agent_name %>.sinks.hdfsSink.hdfs.fileType = DataStream
<%= @agent_name %>.sinks.hdfsSink.hdfs.writeFormat = Text
<%= @agent_name %>.sinks.hdfsSink.hdfs.rollInterval = <%= node['bcpc']['hadoop']['copylog_rollup_interval'] %>
<%= @agent_name %>.sinks.hdfsSink.hdfs.rollSize = 0
<%= @agent_name %>.sinks.hdfsSink.hdfs.rollCount = 0

Set a higher value for Flume channel capacity where the default is 100 which is not sufficient
Set a higher value for Flume channel capacity where the default is 100 which is not sufficient
