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; }