Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

NPE if kafka has null record key

avatar
Expert Contributor

I'm using the patch from FLUME-2578 but when I pass the patched jar via --classpath option of flume-ng, I see the old jar being used instead of the patched jar since it is being appended.

 

Is there a way to override or append the patched jar to java classpath and run flume agent?

 

Thanks!

1 ACCEPTED SOLUTION

avatar
Expert Contributor

Thanks Joey, looks like "/usr/bin/flume-ng agent ... -Duser.home=/user/xyz -c /path/to/jar1:/path/to/jar2" seem to have done the trick by prepending to the java.class.path.

View solution in original post

2 REPLIES 2

avatar
Rising Star
I'm not aware of an option to get it added to the classpath first.

In the past when I've had to deploy a patched jar to a core component,
I replace the jar file in the lib directory.



avatar
Expert Contributor

Thanks Joey, looks like "/usr/bin/flume-ng agent ... -Duser.home=/user/xyz -c /path/to/jar1:/path/to/jar2" seem to have done the trick by prepending to the java.class.path.