}
@Override
public void open() throws IOException, InterruptedException {
super.open();
mEmbeddedFlumeNode = new EmbeddedNode(mFlowSourceId, getContext(), mFlumeConfig,
mDataSource, mOutputSchema, mFieldTypes, mStreamSym);
mEmbeddedFlumeNode.open();
}