@Test
public void testBuilder() throws FlumeSpecException {

  Exception ex = null;
  try {
    String src = "collectorSink";
    FlumeBuilder.buildSink(new Context(), src);
  } catch (Exception e) {
    return;
  }
  assertNotNull("No exception thrown!", ex != null);
  // dir / filename
  String src2 = "collectorSink(\"file:///tmp/test\", \"testfilename\")";
  FlumeBuilder.buildSink(new Context(), src2);
  // millis
  String src3 = "collectorSink(\"file:///tmp/test\", \"testfilename\", 1000)";
  FlumeBuilder.buildSink(new Context(), src3);
  // format
  String src4 = "collectorSink(\"file:///tmp/test\", \"testfilename\", 1000, avro)";
  FlumeBuilder.buildSink(new Context(), src4);
  // format
  src4 = "collectorSink(\"file:///tmp/test\", \"testfilename\", 1000, seqfile)";
  FlumeBuilder.buildSink(new Context(), src4);
  // format
  src4 = "collectorSink(\"file:///tmp/test\", \"testfilename\", 1000, seqfile(\"bzip2\"))";
  FlumeBuilder.buildSink(new Context(), src4);
}