You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flume.apache.org by Bharath Ravi <bh...@gmail.com> on 2012/03/19 21:31:47 UTC

Piping stdin into flume shell does not work

Hi all,

The user guide<http://archive.cloudera.com/cdh/3/flume/UserGuide/#_using_the_flume_command_shell>
says
it is possible to pipe stdin into flume shell.
This does not work for me. Manually logging into the shell and running the
same commands works perfectly fine.
Any pointers as to what might be going wrong? Here's a command I tried with
its output:


# echo "connect fm-vm-010.cercs.int\nexec unconfig fm-vm-011.cercs.int" |
./bin/flume shell
2012-03-19 16:31:05,768 [main] INFO conf.FlumeConfiguration: Loading
configurations from conf
==================================================
FlumeShell v0.9.4
Copyright (c) Cloudera 2010, All Rights Reserved
==================================================
Type a command to execute (hint: many commands
only work when you are connected to a master node)

You may connect to a master node by typing:
    connect host[:adminport=35873[:reportport=45678]]

[flume (disconnected)] connect fm-vm-010.cercs.int\nexec unconfig
fm-vm-011.cercs.int
Failed to run command 'connect fm-vm-010.cercs.int\nexec unconfig
fm-vm-011.cercs.int' due to null
2012-03-19 16:31:06,149 [main] ERROR util.FlumeShell: Failed to run command
'connect fm-vm-010.cercs.int\nexec unconfig fm-vm-011.cercs.int'

Re: Piping stdin into flume shell does not work

Posted by Bharath Ravi <bh...@gmail.com>.
On 19 March 2012 18:04, Jay Stricks <ja...@wapolabs.com> wrote:

> I couldn't get this to work either, so I started writing commands to a
> file and running: flume shell -c {master} -s {file}.
>
>
That's the workaround I've resorted too as well, for now. Is there a better
solution anyone knows of?


>
>
> On Mon, Mar 19, 2012 at 4:31 PM, Bharath Ravi <bh...@gmail.com>wrote:
>
>> Hi all,
>>
>> The user guide<http://archive.cloudera.com/cdh/3/flume/UserGuide/#_using_the_flume_command_shell> says
>> it is possible to pipe stdin into flume shell.
>> This does not work for me. Manually logging into the shell and running
>> the same commands works perfectly fine.
>> Any pointers as to what might be going wrong? Here's a command I tried
>> with its output:
>>
>>
>> # echo "connect fm-vm-010.cercs.int\nexec unconfig fm-vm-011.cercs.int"
>> | ./bin/flume shell
>> 2012-03-19 16:31:05,768 [main] INFO conf.FlumeConfiguration: Loading
>> configurations from conf
>> ==================================================
>> FlumeShell v0.9.4
>> Copyright (c) Cloudera 2010, All Rights Reserved
>> ==================================================
>> Type a command to execute (hint: many commands
>> only work when you are connected to a master node)
>>
>> You may connect to a master node by typing:
>>     connect host[:adminport=35873[:reportport=45678]]
>>
>> [flume (disconnected)] connect fm-vm-010.cercs.int\nexec unconfig
>> fm-vm-011.cercs.int
>> Failed to run command 'connect fm-vm-010.cercs.int\nexec unconfig
>> fm-vm-011.cercs.int' due to null
>> 2012-03-19 16:31:06,149 [main] ERROR util.FlumeShell: Failed to run
>> command 'connect fm-vm-010.cercs.int\nexec unconfig fm-vm-011.cercs.int'
>>
>>
>>
>

Re: Piping stdin into flume shell does not work

Posted by Jay Stricks <ja...@wapolabs.com>.
I couldn't get this to work either, so I started writing commands to a file
and running: flume shell -c {master} -s {file}.


On Mon, Mar 19, 2012 at 4:31 PM, Bharath Ravi <bh...@gmail.com>wrote:

> Hi all,
>
> The user guide<http://archive.cloudera.com/cdh/3/flume/UserGuide/#_using_the_flume_command_shell> says
> it is possible to pipe stdin into flume shell.
> This does not work for me. Manually logging into the shell and running the
> same commands works perfectly fine.
> Any pointers as to what might be going wrong? Here's a command I tried
> with its output:
>
>
> # echo "connect fm-vm-010.cercs.int\nexec unconfig fm-vm-011.cercs.int" |
> ./bin/flume shell
> 2012-03-19 16:31:05,768 [main] INFO conf.FlumeConfiguration: Loading
> configurations from conf
> ==================================================
> FlumeShell v0.9.4
> Copyright (c) Cloudera 2010, All Rights Reserved
> ==================================================
> Type a command to execute (hint: many commands
> only work when you are connected to a master node)
>
> You may connect to a master node by typing:
>     connect host[:adminport=35873[:reportport=45678]]
>
> [flume (disconnected)] connect fm-vm-010.cercs.int\nexec unconfig
> fm-vm-011.cercs.int
> Failed to run command 'connect fm-vm-010.cercs.int\nexec unconfig
> fm-vm-011.cercs.int' due to null
> 2012-03-19 16:31:06,149 [main] ERROR util.FlumeShell: Failed to run
> command 'connect fm-vm-010.cercs.int\nexec unconfig fm-vm-011.cercs.int'
>
>
>