Re: problem with avro serialization

2019-08-30 Thread Debasish Ghosh
Hello Aljoscha - I made a comment on your PR ( https://github.com/apache/flink/pull/9565/files#r319598469). With the suggested fix it runs fine .. Thanks. regards. On Fri, Aug 30, 2019 at 4:48 PM Debasish Ghosh wrote: > Thanks a lot .. sure I can do a build with this PR and check. > > regards.

Re: problem with avro serialization

2019-08-30 Thread Debasish Ghosh
Thanks a lot .. sure I can do a build with this PR and check. regards. On Fri, Aug 30, 2019 at 2:20 PM Aljoscha Krettek wrote: > Hi, > > I cut a PR that should fix this issue for Avrohugger: > https://github.com/apache/flink/pull/9565 > > Would you be able to build this and see if it solves you

Re: problem with avro serialization

2019-08-30 Thread Aljoscha Krettek
Hi, I cut a PR that should fix this issue for Avrohugger: https://github.com/apache/flink/pull/9565 Would you be able to build this and see if it solves your problem? Best, Aljoscha > On 30. Aug 2019, at 09:02, Debasish Ghosh wrote: > > From https

Re: problem with avro serialization

2019-08-30 Thread Debasish Ghosh
>From https://stackoverflow.com/a/56104518 .. AFAIK the only solution is to update Flink to use avro's > non-reflection-based constructors in AvroInputFormat >

Re: problem with avro serialization

2019-08-29 Thread Debasish Ghosh
Any update on this ? regards. On Tue, May 14, 2019 at 2:22 PM Tzu-Li (Gordon) Tai wrote: > Hi, > > Aljoscha opened a JIRA just recently for this issue: > https://issues.apache.org/jira/browse/FLINK-12501. > > Do you know if this is a regression from previous Flink versions? > I'm asking just to

Re: problem with avro serialization

2019-05-14 Thread Debasish Ghosh
Hi Gordon - I have been trying out Flink 1.8 only recently. But this problem looks to to have existed since a long time. It's related to the way Flink handles Avro serialization, which I guess has not changed in recent times. regards. On Tue, May 14, 2019 at 2:22 PM Tzu-Li (Gordon) Tai wrote:

Re: problem with avro serialization

2019-05-14 Thread Tzu-Li (Gordon) Tai
Hi, Aljoscha opened a JIRA just recently for this issue: https://issues.apache.org/jira/browse/FLINK-12501. Do you know if this is a regression from previous Flink versions? I'm asking just to double check, since from my understanding of the issue, the problem should have already existed before.

problem with avro serialization

2019-05-12 Thread Debasish Ghosh
Hello - Facing an issue with avro serialization with Scala case classes generated through avrohugger .. Scala case classes generated by avrohugger has the avro schema in the companion object. This is a sample generated class (details elided) .. case class Data(var id: Int, var name: String) exten