RE: Kafka0.8.2.1 + Flink0.9.0 issue

[Hawin Jiang]

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: hawin.ji...@gmail.com

 

From: Márton Balassi [mailto:balassi.mar...@gmail.com] 
Sent: Thursday, June 11, 2015 12:58 AM
To: user@flink.apache.org
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 <hawin.ji...@gmail.com> wrote: