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(