Stephan
>
>
> On Sat, Feb 27, 2016 at 11:05 AM, Pankaj Kumar
> wrote:
>
>> Yes Robert ,
>> i was trying to start Flink on cluster 0.10.1.
>>
>> But after changing flink version to 0.10.1 , also i am getting the same
>> error.
>>
>> On Sat, F
t; installed?
>
> On Sat, Feb 27, 2016 at 9:20 AM, Pankaj Kumar
> wrote:
>
>> I am trying to integrate kafka and flink.
>> my pom file is where {flink.version} is 0.10.2
>>
>>
>> org.apache.flink
>> flink-java
>> ${flink.ve
I am trying to integrate kafka and flink.
my pom file is where {flink.version} is 0.10.2
org.apache.flink
flink-java
${flink.version}
org.apache.flink
flink-streaming-java
${flink.version}
org.apache.flink
flink-clients
${flink.version}
com.fasterxml.
I was using wrong method to create fat jar,
after using mvn clean install -Pbuild-jar i was able to execute code
through flink command line.
On Wed, Feb 24, 2016 at 7:12 PM, Till Rohrmann wrote:
> What is the error message you receive?
>
> On Wed, Feb 24, 2016 at 1:49 PM, Pan
ade plugin or the assembly plugin. We provide a maven
> archetype to set up a pom file which will make sure that a fat jar is built
> [1].
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-master/quickstart/java_api_quickstart.html
>
> Cheers,
> Till
>
> On Wed,
i am trying to write a job, using maven project.
Job is working fine in my editor , but when i am running that job through
flink command line its giving ClassNotFoundException exception . Its not to
find dependency.
If i will create a jar , will flink download all its dependency before
executing
