Re: Classloader issue using AvroParquetInputFormat via HadoopInputFormat

2016-08-09 Thread Ufuk Celebi
;> 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

Re: Classloader issue using AvroParquetInputFormat via HadoopInputFormat

2016-08-09 Thread Ufuk Celebi
> > 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! > > >

RE: Classloader issue using AvroParquetInputFormat via HadoopInputFormat

2016-08-09 Thread LINZ, Arnaud
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

Re: Classloader issue using AvroParquetInputFormat via HadoopInputFormat

2016-08-09 Thread Stephan Ewen
Hi Shannon! It seams that the something in the maven deployment went wrong with this release. There should be: - *flink-java* (the default, with a transitive dependency to hadoop 2.x for hadoop compatibility features) - *flink-java-hadoop1* (with a transitive dependency for hadoop 1.x fir old

Re: Classloader issue using AvroParquetInputFormat via HadoopInputFormat

2016-08-08 Thread Shannon Carey
Correction: I cannot work around the problem. If I exclude hadoop1, I get the following exception which appears to be due to flink-java-1.1.0's dependency on Hadoop1. Failed to submit job 4b6366d101877d38ef33454acc6ca500 (com.expedia.www.flink.jobs.DestinationCountsHistoryJob$) org.apache.flink