Hi Sandesh. this worked as expected.
Regards
Vivek
--
View this message in context:
http://apache-apex-users-list.78494.x6.nabble.com/AvroToPojo-Operator-doesn-t-recover-after-failure-and-keeps-throwing-Kryo-exception-tp1660p1667.html
Sent from the Apache Apex Users list mailing list archive
Thanks a lot Sandesh.. This problem was bugging for quite some time. I will
try these to see if it resolves the problem
--
View this message in context:
AvroToPojo has a bug, transient modifier needs to be added to 2 fields.
private transient List fieldInfos;
private transient List columnFieldSetters;
Also there is one more bug in Avro input operator, there is a PR open for
that.
Fix is to add the below line to beginWindow call in the operator.
I am using the AvroToPojo Malhar operator in conjunction with
AvroFileInputOperator for converting the avro records to POJO. While doing
the testing for application's stability, I found that AvroToPojo opwerator
doesn't recover in case of failure and keeps throwing below exception. This
in turn
