final EventSink snk = FlumeBuilder.buildSink(new Context(),
"collectorSink(\"hdfs://nonexistant/user/foo\", \"foo\")");
final CountDownLatch started = new CountDownLatch(1);
final CountDownLatch done = new CountDownLatch(1);
final AtomicReference<Exception> are = new AtomicReference(null);
Thread t = new Thread("append thread") {
public void run() {
Event e = new EventImpl("foo".getBytes());
try {
snk.open();
started.countDown();
snk.append(e);
} catch (Exception e1) {
// could be an exception but we don't care.
LOG.info("don't care about this exception: ", e1);
are.set(e1);
}
done.countDown();
}
};
t.start();