Исключение в потоке "main" java.lang.NoClassDefFoundError: com / twitter / chill / KryoBase - PullRequest
Новая
       25

Исключение в потоке "main" java.lang.NoClassDefFoundError: com / twitter / chill / KryoBase

0 голосов
/ 30 апреля 2018

Я пишу простую программу spark-cassandra в java с dasastax cassandra, но получаю ниже исключения

Исключение в потоке "main" java.lang.NoClassDefFoundError: com / twitter / chill / KryoBase Причина: java.lang.ClassNotFoundException: com.twitter.chill.KryoBase

pom.xml 

 <dependency>
        <groupId>com.datastax.dse</groupId>
        <artifactId>dse-spark-dependencies</artifactId>
        <version>5.1.1</version>
        <exclusions>
            <exclusion>
                <groupId>com.datastax.dse</groupId>
                <artifactId>dse-java-driver-core</artifactId>
            </exclusion>
            <exclusion>
                <groupId>org.apache.solr</groupId>
                <artifactId>solr-solrj</artifactId>
            </exclusion>
        </exclusions>
    </dependency>

App.java 

 SparkConf conf = new SparkConf().setMaster("local").setAppName("SparkJavaFirst")
                    .set("spark.cassandra.connection.host", "localhost");     
JavaSparkContext sc = new JavaSparkContext(conf);  
JavaRDD<CassandraRow> cassandraJavaRDD =  CassandraJavaUtil.javaFunctions(sc).
                    cassandraTable("my_keyspace","my_table" ).
                    select("my_column");

Сбой программы на JavaSparkContext sc = new JavaSparkContext(conf);

Любая помощь будет оценена.

1 Ответ

0 голосов
/ 03 мая 2018

Эта проблема была решена, поскольку я удалил исключение 

 <groupId>com.datastax.dse</groupId>  
  <artifactId>dse-java-driver-core</artifactId>
...