java.lang.NoSuchMethodError: com.datastax.driver.core.BoundStatement.set

Question

Je suis nouveau pour spring boot et cassandra. J'ai essayé de sauvegarder les données dans la table cassandra via le connecteur flink-cassandra.

pom.xml

<?xml version="1.0" encoding="UTF-8"?> 
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 
    <modelVersion>4.0.0</modelVersion> 

    <groupId>com.example</groupId> 
    <artifactId>demo</artifactId> 
    <version>0.0.1-SNAPSHOT</version> 
    <packaging>jar</packaging> 

    <name>demo</name> 
    <description>Demo project for Spring Boot</description> 

    <parent> 
     <groupId>org.springframework.boot</groupId> 
     <artifactId>spring-boot-starter-parent</artifactId> 
     <version>1.5.3.RELEASE</version> 
     <relativePath/> <!-- lookup parent from repository --> 
    </parent> 

    <properties> 
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> 
     <java.version>1.8</java.version> 
    </properties> 

    <dependencies> 

     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-data-cassandra</artifactId> 
     </dependency> 

     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-web</artifactId> 
     </dependency> 

     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-test</artifactId> 
      <scope>test</scope> 
     </dependency> 

     <!--Flink-->               
     <dependency> 
      <groupId>org.apache.flink</groupId> 
      <artifactId>flink-java</artifactId> 
      <version>1.2.1</version> 
     </dependency> 

     <dependency> 
      <groupId>org.apache.flink</groupId> 
      <artifactId>flink-streaming-java_2.10</artifactId> 
      <version>1.2.1</version> 
     </dependency> 

     <dependency> 
      <groupId>org.apache.flink</groupId> 
      <artifactId>flink-clients_2.10</artifactId> 
      <version>1.2.1</version> 
     </dependency> 

     <!--Flink Cassandra--> 

     <dependency> 
      <groupId>org.apache.flink</groupId> 
      <artifactId>flink-connector-cassandra_2.10</artifactId> 
      <version>1.2.1</version> 
     </dependency> 
    </dependencies> 

    <build> 
     <plugins> 
      <plugin> 
       <groupId>org.springframework.boot</groupId> 
       <artifactId>spring-boot-maven-plugin</artifactId> 
      </plugin> 
     </plugins> 
    </build> 
</project> 

Date.java

package com.example.demo; 

import com.datastax.driver.mapping.annotations.Column; 
import com.datastax.driver.mapping.annotations.Table; 
import org.springframework.cassandra.core.PrimaryKeyType; 
import org.springframework.data.cassandra.mapping.PrimaryKeyColumn; 

@Table(keyspace = "testing" ,name = "dates") 
public class Date { 

    public Date(int patientid, long date, long timestamp) { 
     super(); 
     this.patientid = patientid; 
     this.date = date; 
     this.timestamp = timestamp; 
    } 
    @PrimaryKeyColumn(name = "patientid", ordinal = 0, type = PrimaryKeyType.PARTITIONED) 
    private int patientid; 
    @PrimaryKeyColumn(name = "date", ordinal = 1, type = PrimaryKeyType.CLUSTERED) 
    private long date; 

    @Column(name = "timestamp") 
    private long timestamp; 

    public long getTimestamp() { 
     return timestamp; 
    } 

    public void setTimestamp(long timestamp) { 
     this.timestamp = timestamp; 
    } 

    public int getPatientid() { 
     return patientid; 
    } 

    public void setPatientid(int patientid) { 
     this.patientid = patientid; 
    } 

    public long getDate() { 
     return date; 
    } 

    public void setDate(long date) { 
     this.date = date; 
    } 

} 

Test.java

package com.example.demo; 

import java.util.ArrayList; 
import java.util.Collection; 
import org.apache.flink.streaming.api.datastream.DataStreamSource; 
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; 
import org.apache.flink.streaming.connectors.cassandra.CassandraSink; 
import org.springframework.boot.CommandLineRunner; 
import org.springframework.stereotype.Component; 

@Component 
public class Test implements CommandLineRunner { 

    private final static Collection<Date> collection = new ArrayList<>(2); 

    static { 
     for (int i = 1; i <= 2; ++i) { 
      collection.add(new Date(i, i, i)); 
     } 
    } 

    @Override 
    public void run(String... strings) { 
      StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); 
      DataStreamSource<Date> fromCollection = env.fromCollection(collection); 

     try { 

      CassandraSink 
        .addSink(fromCollection) 
        .setHost("192.168.1.20") 
        .build(); 

      env.execute(); 
     } catch (Exception e) { 

     } 
    } 
} 

pleine Stacktrace

java.lang.NoSuchMethodError: com.datastax.driver.core.BoundStatement.set(ILjava/lang/Object;Lorg/apache/flink/cassandra/shaded/com/google/common/reflect/TypeToken;)Lcom/datastax/driver/core/BoundStatement; 
    at com.datastax.driver.mapping.Mapper.setObject(Mapper.java:230) 
    at com.datastax.driver.mapping.Mapper.saveQuery(Mapper.java:206) 
    at com.datastax.driver.mapping.Mapper.saveQuery(Mapper.java:163) 
    at com.datastax.driver.mapping.Mapper.saveAsync(Mapper.java:271) 
    at org.apache.flink.streaming.connectors.cassandra.CassandraPojoSink.send(CassandraPojoSink.java:65) 
    at org.apache.flink.streaming.connectors.cassandra.CassandraSinkBase.invoke(CassandraSinkBase.java:75) 
    at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:38) 
    at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:185) 
    at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:63) 
    at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:261) 
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:665) 
    at java.lang.Thread.run(Thread.java:745) 

Je ne trouve pas de solution appropriée. Aidez-moi, s'il vous plaît. Merci d'avance.

Answer 1

java.lang.NoSuchMethodError: com.datastax.driver.core.BoundStatement.set(ILjava/lang/Object;Lorg/apache/flink/cassandra/shaded/com/google/common/reflect/TypeToken;)Lcom/datastax/driver/core/BoundStatement; at com.datastax.driver.mapping.Mapper.setObject(Mapper.java:230)

Le procédé ci-dessus l'indique, il n'y a pas de méthode setObject dans Mapper classe dans le paquet com.datastax.driver.mapping.

Après avoir examiné les versions pot de cassandra-driver-mappinghere, vous avez très probablement l'ancienne version du pilote téléchargé avec flink dépendances spécifiées dans pom.

Pouvez-vous vérifier si vous aviez une ancienne version de com.datastax.driver.mapping.Mapper class dans votre classpath?

Espérons que cela aide, bonne chance!