Hi all,
I'm migrating `OldDoFn` to `DoFn` in gearpump-runner. We serialize all the
functions locally and ship to remote cluster. Hence, I try to make sure the
functions are serializable. Unluckily, the integration-tests fail with
`NotSerializableException` as follows. Anyone knows what that
*AddTimestampsDoFn$auxiliary$x5sQZaqi
is *?
Caused by: java.io.NotSerializableException:
org.apache.beam.sdk.transforms.WithTimestamps$AddTimestampsDoFn$auxiliary$x5sQZaqi
at
java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184)
at
java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548)
at
java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1509)
at
java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1432)
at
java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1178)
at
java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
at
org.apache.beam.sdk.util.SerializableUtils.serializeToByteArray(SerializableUtils.java:49)
... 83 more
Thanks,
Manu
