Skip to content

Commit caef653

Browse files
committed
Fix inconsistent AvroSchema type and value for SqlType.Date values
1 parent ec397ce commit caef653

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils

sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1380,7 +1380,7 @@ private static org.apache.avro.Schema getFieldSchema(
13801380
return Days.daysBetween(Instant.EPOCH, (Instant) value).getDays();
13811381
} else if (SqlTypes.DATE.getIdentifier().equals(identifier)) {
13821382
// portable SqlTypes.DATE is backed by java.time.LocalDate
1383-
return ((java.time.LocalDate) value).toEpochDay();
1383+
return (int) ((java.time.LocalDate) value).toEpochDay();
13841384
} else if ("TIME".equals(identifier)) {
13851385
return (int) ((Instant) value).getMillis();
13861386
} else if (SqlTypes.TIMESTAMP.getIdentifier().equals(identifier)) {

0 commit comments

Comments
 (0)