Hi Martin,
The AM classpath contains the application jar is because user code can
implements an event handler than runs inside the AM. I have not seeing issue in
my cluster. Does your application jar contains Kafka jars ?
Terence
Sent from my iPhone
> On Feb 10, 2017, at 12:29 PM, Martin
Devs,
In our full deployment environment I could not get the Kafka forwarding
of logs to work. I kept getting Kafka errors on the AM trying to lookup
the topic. Seeing as how I had been able to get this same runnable
working in a unit test environment I figured it had to do with the
