The flume exec source can not get content while using python command

["shengyi.pan" <sh...@gmail.com>]

hi, all:
I want to use exec source under Flume 1.5.0.  Follow the flume user guide, tail command is running successfully on my computer, the flume.conf is :

a1.sources.r1.type = exec
      a1.sources.r1.command = tail -F /var/log/secure

When I want to run Python script,  change the flume.conf as follows:

a1.sources.r1.type = exec
      a1.sources.r1.command = python /home/test.py

The  test.py is very simpe,  just print string line periodically

cat test_flume.py 

#!/usr/bin/python

import sys
import time

sys.stdout.write("gogogo\n")
while True:
           sys.stdout.write("gogogo\n")
           time.sleep(3)

Start the flume with: nohup bin/flume-ng agent --conf ./conf/ -f ./conf/flume.conf -n a1 &
The flume is running and the python subprocess is existed, but no data is catched from command : python /home/test.py, looks like Flume cann't read anything from Python stdout.

Can someone help me ? T_T   Thank you very much!




2014-09-18



shengyi.pan