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

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

     [ https://issues.apache.org/jira/browse/FLINK-4138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Zhenhao Li closed FLINK-4138.
-----------------------------
    Resolution: Invalid

I found out the cause. It was version conflict.

> 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)