Frank, great patch! I think there a few think about from looking at the code before I try it:
How does this parse? – I think we many needs a different start and end tokens.
- a b # c # d e #
Update copyright RoundRobinSink.java to the standard apache one instead of cloudera. Here's an example:
Some comment nits – get rid of the TODO (jon). (its legacy stuff).
Would be great if you could document what happens if something fails to open or blocks when attempting to send to something that fails to open? Another thougher question is what should happen when there is a failure (runtime, io, or interrupted),