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