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

Amar3tto pushed a commit to branch fix-jms-compile
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/fix-jms-compile by this push:
     new ed667a62113 Fix instanceof
ed667a62113 is described below

commit ed667a6211382d0c6bec589b519cf500a8a2ac5b
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Tue Oct 20 14:17:43 2026 +0400

    Fix instanceof
---
 .../test/java/org/apache/beam/sdk/io/delta/DeltaWriteTestUtils.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/sdks/java/io/delta/src/test/java/org/apache/beam/sdk/io/delta/DeltaWriteTestUtils.java
 
b/sdks/java/io/delta/src/test/java/org/apache/beam/sdk/io/delta/DeltaWriteTestUtils.java
index 90f987859d7..502c185d09f 100644
--- 
a/sdks/java/io/delta/src/test/java/org/apache/beam/sdk/io/delta/DeltaWriteTestUtils.java
+++ 
b/sdks/java/io/delta/src/test/java/org/apache/beam/sdk/io/delta/DeltaWriteTestUtils.java
@@ -148,8 +148,7 @@ public final class DeltaWriteTestUtils {
       public long getLong(int rowId) {
         if (dataType instanceof TimestampType) {
           Object val = rows.get(rowId).getValue(fieldIndex);
-          if (val instanceof java.time.Instant) {
-            java.time.Instant inst = (java.time.Instant) val;
+          if (val instanceof java.time.Instant inst) {
             return inst.getEpochSecond() * 1_000_000L + inst.getNano() / 1000L;
           } else {
             throw new RuntimeException(

Reply via email to