The configuration file as:

weblog-agent.sources = avro-AppSrv-source

weblog-agent.sinks = hdfs-Cluster1-sink

weblog-agent.channels = mem-channel-1


#set channel for sources, sinks

#properties of avro-AppSrv-source

weblog-agent.sources.avro-AppSrv-source.type = avro

weblog-agent.sources.avro-AppSrv-source.bind = localhost

weblog-agent.sources.avro-AppSrv-source.port = 10000


#properties of mem-channel-1

weblog-agent.channels.mem-channel-1.type = memory

weblog-agent.channels.mem-channel-1.capacity = 1000

weblog-agent.channels.mem-channel-1.transactionCapacity = 100


#properties of hdfs-Cluster1-sink

weblog-agent.sinks.hdfs-Cluster1-sink.type = hdfs

weblog-agent.sinks.hdfs-Cluster1-sink.hdfs.path = hdfs://
134.83.35.24/user/mardan/



I am typing the following commad:

 $: /usr/bin/flume-ng agent -n weblog-agent -f /etc/flume-ng/conf/flume.conf




I am using flume1.x version.


Thanks

On Mon, Jul 23, 2012 at 7:37 AM, shekhar sharma <[email protected]>wrote:

> And can you please tell which version of flume you are using?
>
>
>
> On Mon, Jul 23, 2012 at 12:06 PM, shekhar sharma <[email protected]>wrote:
>
>> What is the command you are running and and what you have specified in
>> conf file?
>>
>> Regards,
>> Som
>>
>>  On Mon, Jul 23, 2012 at 11:49 AM, mardan Khan <[email protected]>wrote:
>>
>>> Hi,
>>>
>>> when i am running my flume agent, i am getting the following error
>>> message:
>>>
>>> 12/07/23 06:59:38 ERROR properties.PropertiesFileConfigurationProvider:
>>> Failed to load configuration data. Exception follows.
>>> java.lang.NullPointerException
>>>     at
>>> org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.loadSources(PropertiesFileConfigurationProvider.java:324)
>>>     at
>>> org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(PropertiesFileConfigurationProvider.java:222)
>>>     at
>>> org.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(AbstractFileConfigurationProvider.java:123)
>>>     at
>>> org.apache.flume.conf.file.AbstractFileConfigurationProvider.access$300(AbstractFileConfigurationProvider.java:38)
>>>     at
>>> org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:202)
>>>     at
>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
>>>     at
>>> java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
>>>     at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
>>>
>>>
>>> I have search in the google and found some information like on link:
>>> https://issues.apache.org/jira/browse/FLUME-1271?attachmentSortBy=dateTime
>>> .
>>>
>>> I dont know how I can add the patch into my configuration file.
>>>
>>> Help please.
>>>
>>> Thanks
>>>
>>
>>
>

Reply via email to