;>>>>>>> 'mvn
>>>>>>>>> assembly:assembly'. Neither of these are beautiful but would help
>>>>>>>>> tracking
>>>>>>>>> down the root cause.
>>>>>>>>>
>>>>
;>>>>>> I am running these examples at the same project and I am using
>>>>>>>>> Eclipse IDE to submit it to my Flink cluster.
>>>>>>>>>
>>>>>>>>>
>>>>>>>>>
>>>>>>>&
>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>>>> *junit*
>>>&g
;>
>>>>>>> org.apache.flink
>>>>>>>
>>>>>>> *flink*-java
>>>>>>>
>>>>>>> 0.9.0-milestone-1
>>>>>>>
>>>>>>>
;>> *flink*-java
>>>>>>
>>>>>> 0.9.0-milestone-1
>>>>>>
>>>>>>
>>>>>>
>>>>>>
>>>>>>
>>>>>> org.apache.flink
>>>>>>
>>>>>> *flink*-clients
>>>>>>
>>>>>> 0.9.0-milestone-1
>>>>>>
>>>&g
-clients
>>>>>
>>>>> 0.9.0-milestone-1
>>>>>
>>>>>
>>>>>
>>>>>
>>>>>
>>>>> org.apache.flink
>>>>>
>>>>> *flink*-streaming-connectors
>>>>>
>>>>> 0.9.0-milestone-1
>>>>>
>>>>>
>>>>>
>&g
;
>>>>
>>>>
>>>> org.apache.kafka
>>>>
>>>> kafka_2.10
>>>>
>>>> 0.8.2.1
>>>>
>>>>
>>>>
>>>>
>>>>
gt;
>>>
>>> org.apache.kafka
>>>
>>> *kafka*-clients
>>>
>>> 0.8.2.1
>>>
>>>
>>>
>>>
>>>
>>> org.apache.hadoop
>&
hadoop
>>
>> *hadoop*-*hdfs*
>>
>> 2.6.0
>>
>>
>>
>>
>>
>> org.apache.hadoop
>>
>> *hadoop*-*auth*
>>
>> 2.6.0
>>
>>
>
;
>
>
> org.apache.hadoop
>
> *hadoop*-*auth*
>
> 2.6.0
>
>
>
>
>
> org.apache.hadoop
>
> *hadoop*-common
>
> 2.6.0
>
>
>
>
>
> org.apache.hadoop
>
> *hadoop*-core
>
>
*
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
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,
12 matches
Mail list logo
