fix timestamp type to use microseconds instead

apache · Dec 16, 2020 · c0c758d · c0c758d
1 parent 55b1e5b
commit c0c758d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/spark/src/main/java/org/apache/iceberg/spark/source/StructInternalRow.java b/spark/src/main/java/org/apache/iceberg/spark/source/StructInternalRow.java
@@ -138,7 +138,7 @@ public long getLong(int ordinal) {
     if (longVal instanceof Long) {
       return (long) longVal;
     } else if (longVal instanceof OffsetDateTime) {
-      return TimeUnit.SECONDS.toDays(((OffsetDateTime) longVal).toEpochSecond());
+      return Duration.between(Instant.EPOCH, (OffsetDateTime) longVal).toNanos() / 1000;
     } else if (longVal instanceof LocalDate) {
       return ((LocalDate) longVal).toEpochDay();
     } else {