Dear Marton
Thanks for supporting again.
I am running these examples at the same project and I am using Eclipse IDE to
submit it to my Flink cluster.
Here is my dependencies
******************************************************************************
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>0.9.0-milestone-1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients</artifactId>
<version>0.9.0-milestone-1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-connectors</artifactId>
<version>0.9.0-milestone-1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-core</artifactId>
<version>0.9.0-milestone-1</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.8.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.8.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-hdfs</artifactId>
<version>2.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-auth</artifactId>
<version>2.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-common</artifactId>
<version>2.6.0</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-core</artifactId>
<version>1.2.1</version>
</dependency>
</dependencies>
*****************************************************************************************
Best regards
Email: [email protected]
From: Márton Balassi [mailto:[email protected]]
Sent: Thursday, June 11, 2015 12:58 AM
To: [email protected]
Subject: Re: Kafka0.8.2.1 + Flink0.9.0 issue
Dear Hawin,
This looks like a dependency issue, the java compiler does not find the kafka
dependency. How are you trying to run this example? Is it from an IDE or
submitting it to a flink cluster with bin/flink run? How do you define your
dependencies, do you use maven or sbt for instance?
Best,
Marton
On Thu, Jun 11, 2015 at 9:43 AM, Hawin Jiang <[email protected]> wrote:
