Looks like you have hit https://issues.apache.org/jira/browse/THRIFT-1447. You should not be using the thrift compatibility source (unless you are piping data from Flume OG). You should use the ThriftSource that Flume now comes with - this has full thrift support for Flume NG style events.
Thanks Hari -- Hari Shreedharan On Tuesday, April 30, 2013 at 2:16 PM, Eran Kutner wrote: > org.apache.thrift.ProcessFunction.process(ProcessFunction.java:34)
