From b15ce52021226802ff34a10e1a94a7f1ca82f87d Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Tue, 3 Sep 2024 06:46:14 -0400 Subject: [PATCH] DBZ-8142 Clean-up casting to be type-safe --- .../oracle/olr/OpenLogReplicatorValueConverter.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/olr/OpenLogReplicatorValueConverter.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/olr/OpenLogReplicatorValueConverter.java index 0451c18b9..f7ce9ac7b 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/olr/OpenLogReplicatorValueConverter.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/olr/OpenLogReplicatorValueConverter.java @@ -115,7 +115,7 @@ protected Object convertTimestampWithZone(Column column, Field fieldDefn, Object @Override protected Object convertTimestampWithLocalZone(Column column, Field fieldDefn, Object value) { if (value instanceof Number) { - final Instant instant = Instant.ofEpochSecond(0, (Long) value); + final Instant instant = Instant.ofEpochSecond(0, ((Number) value).longValue()); return getTimestampWithLocalTimeZoneFormatter(column).format(OffsetDateTime.ofInstant(instant, ZoneOffset.UTC)); } return super.convertTimestampWithLocalZone(column, fieldDefn, value); @@ -160,12 +160,12 @@ private Object convertTimestampValue(Column column, Object value) { value = ((BigInteger) value).divide(BigInteger.valueOf(1_000_000L)).longValue(); } else { - value = ((Long) value) / 1_000_000L; + value = ((Number) value).longValue() / 1_000_000L; } } else { // TIMESTAMP(n) - value = Instant.ofEpochSecond(0, (Long) value); + value = Instant.ofEpochSecond(0, ((Number) value).longValue()); } return value; }