Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-9863

AvroUtils is converting incorrectly LogicalType Timestamps from long into Joda DateTimes

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
    • sdk-java-core

    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:

      https://lists.apache.org/thread.html/r43fb2896e496b7493a962207eb3b95360abc30b9d091b26f110264d0%40%3Cuser.beam.apache.org%3E

      Attachments

        Activity

          People

            Unassigned Unassigned
            iemejia Ismaël Mejía
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated: