The above code can run under the spark - shell
But run into jars on cluster will go wrong, wrong is as follows:

Don't know what's the problem, some people met this kind of situation