I have spark 2.3.2 , atlas 1.1 and kafka 2.0 in my cluster.
When I'm running spark atlas connector v0.1.0-2.3-1.0.0 user jar, but my spark job is failing.
I have attached the screenshot of the error.
P.S. : I have tried using latest version of spark atlas connector as well but my job is failing with
Error : java.lang.IncompatibleClassChangeError: Implementing class.
Hi All,
I have spark 2.3.2 , atlas 1.1 and kafka 2.0 in my cluster.
When I'm running spark atlas connector v0.1.0-2.3-1.0.0 user jar, but my spark job is failing. I have attached the screenshot of the error.
P.S. : I have tried using latest version of spark atlas connector as well but my job is failing with Error : java.lang.IncompatibleClassChangeError: Implementing class.