You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by yuvraj singh <19...@gmail.com> on 2018/08/13 08:22:20 UTC

Error with Cassandra

Hi ,

I am getting

java.lang.NoClassDefFoundError: Could not initialize class
com.datastax.driver.core.Cluster

please help with it .

my pom is


<properties>
    <flink.version>1.5.0</flink.version>
    <maven.version>3.7.0</maven.version>
    <java.version>1.8</java.version>
    <scala.major.version>2.11</scala.major.version>
    <jackson.version>2.9.4</jackson.version>
    <protobuf.version>3.5.1</protobuf.version>
    <slf4j.version>1.7.5</slf4j.version>
    <lombook.version>1.16.18</lombook.version>
    <spring.boot.version>2.0.4.RELEASE</spring.boot.version>
    <spring.kafka.version>2.1.4.RELEASE</spring.kafka.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <cassandra.version>3.11.3</cassandra.version>
    <driver.version>3.5.1</driver.version>
</properties>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>${jackson.version}</version>
        </dependency>
        <dependency>
            <groupId>com.google.protobuf</groupId>
            <artifactId>protobuf-java</artifactId>
            <version>${protobuf.version}</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>${jackson.version}</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>${jackson.version}</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.module</groupId>
            <artifactId>jackson-module-scala_${scala.major.version}</artifactId>
            <version>${jackson.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-core</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-streaming-java_2.11</artifactId>
            <version>${flink.version}</version>
        </dependency>

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.5</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-simple</artifactId>
            <version>1.6.4</version>
        </dependency>

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kafka-0.10_${scala.major.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-statebackend-rocksdb_${scala.major.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-cassandra_${scala.major.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>com.ola.ai.ss.platform</groupId>
            <artifactId>common</artifactId>
            <version>${project.version}</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>${lombook.version}}</version>
        </dependency>
        <dependency>
            <groupId>com.jillesvangurp</groupId>
            <artifactId>geogeometry</artifactId>
            <version>2.11</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>${lombook.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>${spring.boot.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>com.fasterxml.jackson.core</groupId>
                    <artifactId>jackson-databind</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>com.fasterxml.jackson.core</groupId>
                    <artifactId>jackson-annotations</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>com.fasterxml.jackson.core</groupId>
                    <artifactId>jackson-core</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>log4j-over-slf4j</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot</artifactId>
            <version>${spring.boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
            <version>${spring.boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
            <version>${spring.kafka.version}</version>
        </dependency>
        <dependency>
            <groupId>com.datastax.cassandra</groupId>
            <artifactId>cassandra-driver-core</artifactId>
            <version>${driver.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>log4j-over-slf4j</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>ch.qos.logback</groupId>
                    <artifactId>logback-classic</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.datastax.cassandra</groupId>
            <artifactId>cassandra-driver-mapping</artifactId>
            <version>${driver.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>log4j-over-slf4j</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>ch.qos.logback</groupId>
                    <artifactId>logback-classic</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

Re: Error with Cassandra

Posted by Deepak Sharma <de...@gmail.com>.
can you try with this?

<cassandra.version>3.3.0</cassandra.version>



On Mon, Aug 13, 2018 at 1:52 PM yuvraj singh <19...@gmail.com>
wrote:

> Hi ,
>
> I am getting
>
> java.lang.NoClassDefFoundError: Could not initialize class
> com.datastax.driver.core.Cluster
>
> please help with it .
>
> my pom is
>
>
> <properties>
>     <flink.version>1.5.0</flink.version>
>     <maven.version>3.7.0</maven.version>
>     <java.version>1.8</java.version>
>     <scala.major.version>2.11</scala.major.version>
>     <jackson.version>2.9.4</jackson.version>
>     <protobuf.version>3.5.1</protobuf.version>
>     <slf4j.version>1.7.5</slf4j.version>
>     <lombook.version>1.16.18</lombook.version>
>     <spring.boot.version>2.0.4.RELEASE</spring.boot.version>
>     <spring.kafka.version>2.1.4.RELEASE</spring.kafka.version>
>     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>     <cassandra.version>3.11.3</cassandra.version>
>     <driver.version>3.5.1</driver.version>
> </properties>
> <dependencyManagement>
>     <dependencies>
>         <dependency>
>             <groupId>com.fasterxml.jackson.core</groupId>
>             <artifactId>jackson-core</artifactId>
>             <version>${jackson.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>com.google.protobuf</groupId>
>             <artifactId>protobuf-java</artifactId>
>             <version>${protobuf.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>com.fasterxml.jackson.core</groupId>
>             <artifactId>jackson-databind</artifactId>
>             <version>${jackson.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>com.fasterxml.jackson.core</groupId>
>             <artifactId>jackson-annotations</artifactId>
>             <version>${jackson.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>com.fasterxml.jackson.module</groupId>
>             <artifactId>jackson-module-scala_${scala.major.version}</artifactId>
>             <version>${jackson.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-core</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-streaming-java_2.11</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>
>         <dependency>
>             <groupId>org.slf4j</groupId>
>             <artifactId>slf4j-api</artifactId>
>             <version>1.7.5</version>
>         </dependency>
>         <dependency>
>             <groupId>org.slf4j</groupId>
>             <artifactId>slf4j-simple</artifactId>
>             <version>1.6.4</version>
>         </dependency>
>
>         <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-connector-kafka-0.10_${scala.major.version}</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-statebackend-rocksdb_${scala.major.version}</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-connector-cassandra_${scala.major.version}</artifactId>
>             <version>${flink.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>com.ola.ai.ss.platform</groupId>
>             <artifactId>common</artifactId>
>             <version>${project.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.projectlombok</groupId>
>             <artifactId>lombok</artifactId>
>             <version>${lombook.version}}</version>
>         </dependency>
>         <dependency>
>             <groupId>com.jillesvangurp</groupId>
>             <artifactId>geogeometry</artifactId>
>             <version>2.11</version>
>         </dependency>
>         <dependency>
>             <groupId>org.projectlombok</groupId>
>             <artifactId>lombok</artifactId>
>             <version>${lombook.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.springframework.boot</groupId>
>             <artifactId>spring-boot-starter-web</artifactId>
>             <version>${spring.boot.version}</version>
>             <exclusions>
>                 <exclusion>
>                     <groupId>com.fasterxml.jackson.core</groupId>
>                     <artifactId>jackson-databind</artifactId>
>                 </exclusion>
>                 <exclusion>
>                     <groupId>com.fasterxml.jackson.core</groupId>
>                     <artifactId>jackson-annotations</artifactId>
>                 </exclusion>
>                 <exclusion>
>                     <groupId>com.fasterxml.jackson.core</groupId>
>                     <artifactId>jackson-core</artifactId>
>                 </exclusion>
>                 <exclusion>
>                     <groupId>org.slf4j</groupId>
>                     <artifactId>log4j-over-slf4j</artifactId>
>                 </exclusion>
>             </exclusions>
>         </dependency>
>         <dependency>
>             <groupId>org.springframework.boot</groupId>
>             <artifactId>spring-boot</artifactId>
>             <version>${spring.boot.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.springframework.boot</groupId>
>             <artifactId>spring-boot-autoconfigure</artifactId>
>             <version>${spring.boot.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>org.springframework.kafka</groupId>
>             <artifactId>spring-kafka</artifactId>
>             <version>${spring.kafka.version}</version>
>         </dependency>
>         <dependency>
>             <groupId>com.datastax.cassandra</groupId>
>             <artifactId>cassandra-driver-core</artifactId>
>             <version>${driver.version}</version>
>             <exclusions>
>                 <exclusion>
>                     <groupId>org.slf4j</groupId>
>                     <artifactId>log4j-over-slf4j</artifactId>
>                 </exclusion>
>                 <exclusion>
>                     <groupId>ch.qos.logback</groupId>
>                     <artifactId>logback-classic</artifactId>
>                 </exclusion>
>             </exclusions>
>         </dependency>
>         <dependency>
>             <groupId>com.datastax.cassandra</groupId>
>             <artifactId>cassandra-driver-mapping</artifactId>
>             <version>${driver.version}</version>
>             <exclusions>
>                 <exclusion>
>                     <groupId>org.slf4j</groupId>
>                     <artifactId>log4j-over-slf4j</artifactId>
>                 </exclusion>
>                 <exclusion>
>                     <groupId>ch.qos.logback</groupId>
>                     <artifactId>logback-classic</artifactId>
>                 </exclusion>
>             </exclusions>
>         </dependency>
>     </dependencies>
>
>
>
>

-- 
Thanks
Deepak
www.bigdatabig.com
www.keosha.net