Can you show the complete stack trace ? Which Spark / Kafka release are you using ?
Thanks On Mon, Aug 24, 2015 at 4:58 PM, Cassa L <lcas...@gmail.com> wrote: > Hi, > I am storing messages in Kafka using protobuf and reading them into > Spark. I upgraded protobuf version from 2.4.1 to 2.5.0. I got > "java.lang.UnsupportedOperationException" for older messages. However, even > for new messages I get the same error. Spark does convert it though. I see > my messages. How do I get rid of this error? > java.lang.UnsupportedOperationException: This is supposed to be overridden > by subclasses. > at > com.google.protobuf.GeneratedMessage.getUnknownFields(GeneratedMessage.java:180) > at > org.apache.hadoop.hdfs.protocol.proto.HdfsProtos$FsPermissionProto.getSerializedSize(HdfsProtos.java:5407) > at > com.google.protobuf.CodedOutputStream.computeMessageSizeNoTag(CodedOutputStream.java:749) >
