incubator-flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From s ravi <sravi7...@gmail.com>
Subject Re: Need help in source commands
Date Thu, 17 Nov 2011 14:21:53 GMT
Hi Mingjie,

Please find the attached code with this mail.I haven't added my
business logic here, i downloaded this from online.

And regarding Mikes concern about
 "tcp://<ipaddress>:61616:61616",
i am passing correct ip its typo in the mail. p am using
tcp://<ipaddress>:61616 only.



Thanks,
Saritha.

On Thu, Nov 17, 2011 at 3:13 AM, Mingjie Lai <mjlai09@gmail.com> wrote:
> I think the error message is straightforward:
>
> Attempted to write an
> invalid sink/source: Invalid source: activeMQEventSource(
> "tcp://<ipaddress>:61616:61616",
> "VirtualTopic.consumer.asc.answerSent" )
> java.lang.IllegalArgumentException: Attempted to write an invalid
> sink/source: Invalid source: activeMQEventSource(
> "tcp://<ipaddress>:61616:61616",
>
> your activemq source threw java.lang.IllegalArgumentException.
>
> However there is no way for us to help if you don't post your code here. In
> addition, you may want to go to activemq community to ask activemq related
> questions since they're the best resources you can refer to.
>
> -mingjie
>
> On 11/15/2011 01:55 PM, s ravi wrote:
>>
>> Hi All,
>>
>> I am trying to run below activemq source command on agent(it is in
>> cloud lab) node and getting error. i tried both internal and expernal
>> IP's...
>>
>> Could anyone please help me when will this error comes. i can see my
>> source/sink in extn page
>>
>> command:
>>
>> config [agent,
>> activeMQEventSource("tcp://<ipaddress>:61616:61616","VirtualTopic.consumer.asc.answerSent"),
>> text("/var/log/flume/testactivemq.log")]
>>
>> error:
>>
>>
>> 2011-11-15 21:50:19,819 ERROR
>> com.cloudera.flume.master.CommandManager: Unexpected exception during
>> cmdid:0 config [agent,
>>
>> activeMQEventSource("tcp://<ipaddress>:61616:61616","VirtualTopic.consumer.asc.answerSent"),
>> text("/var/log/flume/testactivemq.log")] : Attempted to write an
>> invalid sink/source: Invalid source: activeMQEventSource(
>> "tcp://<ipaddress>:61616:61616",
>> "VirtualTopic.consumer.asc.answerSent" )
>> java.lang.IllegalArgumentException: Attempted to write an invalid
>> sink/source: Invalid source: activeMQEventSource(
>> "tcp://<ipaddress>:61616:61616",
>> "VirtualTopic.consumer.asc.answerSent" )
>>         at
>> com.cloudera.flume.master.ConfigManager.setConfig(ConfigManager.java:96)
>>         at
>> com.cloudera.flume.master.flows.FlowConfigManager.setConfig(FlowConfigManager.java:285)
>>         at
>> com.cloudera.flume.master.TranslatingConfigurationManager.setConfig(TranslatingConfigurationManager.java:101)
>>         at
>> com.cloudera.flume.master.ConfigCommand$1.exec(ConfigCommand.java:87)
>>         at
>> com.cloudera.flume.master.CommandManager.exec(CommandManager.java:266)
>>         at
>> com.cloudera.flume.master.CommandManager.handleCommand(CommandManager.java:205)
>>         at
>> com.cloudera.flume.master.CommandManager$ExecThread.run(CommandManager.java:236)
>> Caused by: com.cloudera.flume.conf.FlumeIdException: Invalid source:
>> activeMQEventSource( "tcp://<ipaddress>:61616:61616",
>> "VirtualTopic.consumer.asc.answerSent" )
>>         at
>> com.cloudera.flume.conf.FlumeBuilder.buildEventSource(FlumeBuilder.java:477)
>>         at
>> com.cloudera.flume.conf.FlumeBuilder.buildSource(FlumeBuilder.java:275)
>>         at
>> com.cloudera.flume.master.ConfigManager.setConfig(ConfigManager.java:94)
>>         ... 6 more
>>
>>
>>                                           842,2-9       Bot
>> Thanks,
>> Ravi
>>
>

Mime
View raw message