240 发简信
IP属地:天津
  • 你好!我最近将写好的sparksql的程序发布到standalone集群中运行时就出现了ClassNotFoundException: com.datastax.spark.connector.rdd.partitioner.CassandraPartition的问题!查了很多资料感觉是worker节点没有spark针对cassandra的连接器!根据你的方法:$SPARK_HOME/bin/spark-shell --packages datastax:spark-cassandra-connector:1.6.0-s_2.10修改了对应版本还是不成功!请问你有时间可以帮忙解答一下吗?

    java spark sql操作cassandar

    前期准备: cassandra集群(可以参考网站 https://cassandrazh.github.io/) spark集群(可以参考我的文章 http://www.ji...