The was a changed on AvroRecord will return a org.joda.time.DateTime type instead of a Long when logicalType is date/time related.
This leads to such kind of exceptions:
org.apache.beam.sdk.Pipeline$PipelineExecutionException: org.apache.avro.AvroRuntimeException: Unknown datum type org.joda.time.DateTime: 2018-12-25T00:00:00.000Z
or even
org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.IllegalArgumentException: long can't be converted to class java.time.ZonedDateTime