AvroIO не удается java.lang.ClassCastException для чтения даты логического типа

Question

Я использую AvroIO из Apache Beam с Spark Runner.Я определил запись avro с полем

{
          "name" : "serviceDate",
          "type" : [ "null", {
            "type" : "int",
            "logicalType" : "date"
          } ],
          "doc" : "date",
          "default" : null
        }

. Чтение этих данных завершается неудачно с java.lang.ClassCastException: java.lang.Integer не может быть приведен к org.joda.time.LocalDate

Я использую Avro 1.8.2