;> Arnaud
>>
>>
>>
>> De : Stephan Ewen [mailto:se...@apache.org]
>> Envoyé : mardi 9 août 2016 12:41
>> À : user@flink.apache.org
>> Objet : Re: Classloader issue using AvroParquetInputFormat via
>> HadoopInputFormat
>>
>>
>>
>&g
>
> Greetings,
>
> Arnaud
>
>
>
> De : Stephan Ewen [mailto:se...@apache.org]
> Envoyé : mardi 9 août 2016 12:41
> À : user@flink.apache.org
> Objet : Re: Classloader issue using AvroParquetInputFormat via
> HadoopInputFormat
>
>
>
> Hi Shannon!
>
>
>
Okay,
That would also solve my issue.
Greetings,
Arnaud
De : Stephan Ewen [mailto:se...@apache.org]
Envoyé : mardi 9 août 2016 12:41
À : user@flink.apache.org
Objet : Re: Classloader issue using AvroParquetInputFormat via HadoopInputFormat
Hi Shannon!
It seams that the something in the maven
utFormatBase.java:56)
> at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.(
> ExecutionJobVertex.java:156)
> ... 21 more
>
> And if I exclude hadoop2, I get the exception from my previous email with
> AvroParquetInputFormat.
>
>
>
> From: Shannon Carey
&
@flink.apache.org>>
Subject: Classloader issue using AvroParquetInputFormat via HadoopInputFormat
Hi folks, congrats on 1.1.0!
FYI, after updating to Flink 1.1.0 I get the exception at bottom when
attempting to run a job that uses AvroParquetInputFormat wrapped in a Flink
HadoopInputFormat. The
Hi folks, congrats on 1.1.0!
FYI, after updating to Flink 1.1.0 I get the exception at bottom when
attempting to run a job that uses AvroParquetInputFormat wrapped in a Flink
HadoopInputFormat. The ContextUtil.java:71 is trying to execute:
Class.forName("org.apache.hadoop.mapreduce.task.JobCont
