Hi!
I'm using Apache Beam Java(2.19.0) with Dataflow. I created class and
annotated it with DefaultCoder
@DefaultCoder(AvroCoder.class)
public class ProductCatalog {
When I trying to submit it to cluster I get an error:
Caused by: java.io.NotSerializableException: ...common.ProductCatalog
If I add `implements Serializable` to the class definition everything works
fine. In the Apache Beam guide, I don't see anything about using implements
Serializable. What I'm doing wrong? Thank you in advance for your help
