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 51e0a1f066a Suppress warning
51e0a1f066a is described below
commit 51e0a1f066a57668ce8d7a2bab4a49799a7a32bd
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Tue Oct 20 15:58:31 2026 +0400
Suppress warning
---
.../test/java/org/apache/beam/sdk/io/delta/DeltaWriteTestUtils.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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 502c185d09f..4c707f0394f 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
@@ -144,11 +144,13 @@ public final class DeltaWriteTestUtils {
return rows.get(rowId).getInt32(fieldIndex);
}
+ @SuppressWarnings("PatternMatchingInstanceof")
@Override
public long getLong(int rowId) {
if (dataType instanceof TimestampType) {
Object val = rows.get(rowId).getValue(fieldIndex);
- if (val instanceof java.time.Instant inst) {
+ if (val instanceof java.time.Instant) {
+ java.time.Instant inst = (java.time.Instant) val;
return inst.getEpochSecond() * 1_000_000L + inst.getNano() / 1000L;
} else {
throw new RuntimeException(
