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

["Zhenhao Li (JIRA)" <ji...@apache.org>]

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)