Details
-
Bug
-
Status: Open
-
P3
-
Resolution: Unresolved
-
2.15.0, 2.16.0, 2.17.0, 2.18.0, 2.19.0, 2.20.0, 2.21.0
-
None
Description
Copied from the mailing list report:
I think the method AvroUtils.toBeamSchema has a not expected side effect.
I found out that, if you invoke it and then you run a pipeline of GenericRecords containing a timestamp (l tried with logical-type timestamp-millis), Beam converts such timestamp from long to org.joda.time.DateTime. Even if you don't apply any transformation to the pipeline.
Do you think it's a bug?
More details on how to reproduce here: