(beam) branch master updated: Fix inconsistent AvroSchema type and value for SqlType.Date values (#39414)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new de234c72b88 Fix inconsistent AvroSchema type and value for 
SqlType.Date values (#39414)
de234c72b88 is described below

commit de234c72b881c7823d66ed9c070a66b036b448d9
Author: Yi Hu <ya...@google.com>
AuthorDate: Mon Jul 27 18:27:26 2026 -0400

    Fix inconsistent AvroSchema type and value for SqlType.Date values (#39414)
---
 .../org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java  | 2 +-
 .../apache/beam/sdk/extensions/avro/schemas/utils/AvroUtilsTest.java  | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java
 
b/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java
index 854b0d3c8bb..3c9064466d5 100644
--- 
a/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java
+++ 
b/sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java
@@ -1380,7 +1380,7 @@ public class AvroUtils {
           return Days.daysBetween(Instant.EPOCH, (Instant) value).getDays();
         } else if (SqlTypes.DATE.getIdentifier().equals(identifier)) {
           // portable SqlTypes.DATE is backed by java.time.LocalDate
-          return ((java.time.LocalDate) value).toEpochDay();
+          return (int) ((java.time.LocalDate) value).toEpochDay();
         } else if ("TIME".equals(identifier)) {
           return (int) ((Instant) value).getMillis();
         } else if (SqlTypes.TIMESTAMP.getIdentifier().equals(identifier)) {
diff --git 
a/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtilsTest.java
 
b/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtilsTest.java
index 6db5206c3cf..d2452452f14 100644
--- 
a/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtilsTest.java
+++ 
b/sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtilsTest.java
@@ -1077,7 +1077,9 @@ public class AvroUtilsTest {
 
     org.apache.avro.Schema avroSchema = AvroUtils.toAvroSchema(beamSchema);
     GenericRecord expectedRecord =
-        new GenericRecordBuilder(avroSchema).set("local_date", 
localDate.toEpochDay()).build();
+        new GenericRecordBuilder(avroSchema)
+            .set("local_date", (int) localDate.toEpochDay())
+            .build();
 
     assertEquals(expectedRecord, AvroUtils.toGenericRecord(rowData, 
avroSchema));
   }