Re: Flink on AWS EMR Protobuf

2017-09-07 Thread Timo Walther
I'm not sure if this is a Flink issue. It popped up on other non-Flink projects as well: http://community.cloudera.com/t5/Storage-Random-Access-HDFS/map-red-over-hbase-in-cdh-5-7/td-p/43902 I would defenitely check your dependencies. This looks like conflicting versions in your classpaths. T

Re: Flink on AWS EMR Protobuf

2017-09-07 Thread ant burton
Please find a stack trace below, and thank you for taking a look :-) java.lang.ClassCastException: org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$GetFileInfoRequestProto cannot be cast to com.google.protobuf.Message at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.

Re: Flink on AWS EMR Protobuf

2017-09-06 Thread Aljoscha Krettek
Hi, Could you please give a bit more context around that exception? Maybe a log or a full stack trace. Best, Aljoscha > On 5. Sep 2017, at 23:52, ant burton wrote: > > Hello, > > Has anybody experienced the following error on AWS EMR 5.8.0 with Flink 1.3.1 > > java.lang.ClassCastException:

Flink on AWS EMR Protobuf

2017-09-05 Thread ant burton
Hello, Has anybody experienced the following error on AWS EMR 5.8.0 with Flink 1.3.1 java.lang.ClassCastException: org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$GetFileInfoRequestProto cannot be cast to com.google.protobuf.Message Thanks,