You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2026/10/20 10:17:54 UTC

(beam) branch fix-jms-compile updated: Fix instanceof

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 <vi...@akvelon.com>
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(