You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
as described before on the mailing list, I'm experiencing serialization issues when accessing Avro nested records from Scalding's Typed API. It usually happens in joins, but can easily be reproduced by using .forceToDisk.
Hello,
as described before on the mailing list, I'm experiencing serialization issues when accessing Avro nested records from Scalding's Typed API. It usually happens in joins, but can easily be reproduced by using
.forceToDisk
.I have set up an example project here:
https://github.com/mariussoutier/avro-example/tree/scalding-avro-issue
The crash can be forced this way:
https://github.com/mariussoutier/avro-example/blob/scalding-avro-issue/src/main/scala/jobs/TrendingTagsJob.scala#L22
You can simply generate some tweets and run it locally as described in the README.
The text was updated successfully, but these errors were encountered: