chukwa-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eric Yang <>
Subject PipelineStageWriter doesn't work as expected
Date Fri, 18 Dec 2009 01:12:28 GMT
Hi all,

I'd setup SocketTeeWriter by itself, and having data stream to next socket
reader program.  When I tried to configure two writers, i.e., SeqFileWriter
follow by SocketTeeWriter.  It doesn't work because SeqFileWriter isn't
extending PipelineableWriter.  I went ahead to extend SeqFileWriter as
PipelineableWriter and do that and implemented setNextStage method, and
configured collector with:



SeqFileWriter writes the data correctly, but when connect to
SocketTeeWriter, there was no data visible in SocketTeeWriter.  Commands
works fine, but data streaming doesn't happen.  How do I configure the
collector and PipelineStageWriter to be able to write data into multiple
writer?  Is there something on SeqFileWriter that could prevent this from


View raw message