[jira] [Created] (FLINK-4138) error with Kinesis connector

[Shang Yuanchun (Jira)]

Zhenhao Li created FLINK-4138:
---------------------------------

             Summary: error with Kinesis connector
                 Key: FLINK-4138
                 URL: https://issues.apache.org/jira/browse/FLINK-4138
             Project: Flink
          Issue Type: Bug
            Reporter: Zhenhao Li
            Priority: Critical


Exception in thread "main" java.lang.NoClassDefFoundError: com/google/common/util/concurrent/FutureCallback

It seems the error is caused by the following line.

val kinesis = new FlinkKinesisProducer[String](new SimpleStringSchema(), kinesisProducerConfig)

My dependences are as follows.


<properties>
                <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
                <flink.version>1.0.3</flink.version>
</properties>

<dependencies>
                <dependency>
                        <groupId>org.apache.flink</groupId>
                        <artifactId>flink-scala_2.10</artifactId>
                        <version>${flink.version}</version>
                </dependency>
                <dependency>
                        <groupId>org.apache.flink</groupId>
                        <artifactId>flink-streaming-scala_2.10</artifactId>
                        <version>${flink.version}</version>
                </dependency>
                <dependency>
                        <groupId>org.apache.flink</groupId>
                        <artifactId>flink-clients_2.10</artifactId>
                        <version>${flink.version}</version>
                </dependency>
                <dependency>
                        <groupId>org.apache.flink</groupId>
                        <artifactId>flink-connector-kafka-0.8_2.10</artifactId>
                        <version>${flink.version}</version>
                </dependency>
        </dependencies>



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)