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)
