@Test
public void testGenCollectorArgs() throws FlumeSpecException {

  EventSink snk = FlumeBuilder
      .buildSink(LogicalNodeContext.testingContext(),
          "collector(foo=\"bar\") { customDfsSink(\"file:///tmp/foo\",\"foo\") }");
  assertTrue(snk instanceof CollectorSink);
  snk = FlumeBuilder
      .buildSink(LogicalNodeContext.testingContext(),
          "collector(3,foo=\"bar\") { customDfsSink(\"file:///tmp/foo\",\"foo\") }");
  assertTrue(snk instanceof CollectorSink);
  snk = FlumeBuilder.buildSink(LogicalNodeContext.testingContext(),
      "collector(3) { customDfsSink(\"file:///tmp/foo\",\"foo\") }");
  assertTrue(snk instanceof CollectorSink);
}