Accepted answer

is your spark-mqtt jar the same version of your spark? it's possible that different versions cause these problems. i had a similar problem when using spark 1.6 from cloudera express. after upgrading it to the same version the problem was solved

Related Query

More Query from same tag