From 3f35ce57dca6b6d5131655151e1926ad7d8cdb67 Mon Sep 17 00:00:00 2001
From: Max Zinal <zinal@ydb.tech>
Date: Wed, 3 Sep 2025 19:21:20 +0300
Subject: [PATCH] fixes #27

---
 .gitignore                                                    | 3 +++
 .../src/main/java/tech/ydb/spark/connector/YdbTypes.java      | 4 ++--
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/.gitignore b/.gitignore
index e0dc125..0461e55 100644
--- a/.gitignore
+++ b/.gitignore
@@ -37,3 +37,6 @@
 
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
+
+# vscode files
+.vscode/
\ No newline at end of file
diff --git a/connector/src/main/java/tech/ydb/spark/connector/YdbTypes.java b/connector/src/main/java/tech/ydb/spark/connector/YdbTypes.java
index c4302c3..cf1e989 100644
--- a/connector/src/main/java/tech/ydb/spark/connector/YdbTypes.java
+++ b/connector/src/main/java/tech/ydb/spark/connector/YdbTypes.java
@@ -939,14 +939,14 @@ public void setRowValue(InternalRow row, int i, ValueReader vr) {
                     if (dateAsString) {
                         row.update(i, UTF8String.fromString(vr.getDatetime().toString()));
                     } else {
-                        row.setLong(i, vr.getDatetime().toInstant(ZoneOffset.UTC).getEpochSecond());
+                        row.setLong(i, vr.getDatetime().toInstant(ZoneOffset.UTC).toEpochMilli() * 1000L);
                     }
                     break;
                 case Timestamp:
                     if (dateAsString) {
                         row.update(i, UTF8String.fromString(vr.getTimestamp().toString()));
                     } else {
-                        row.setLong(i, vr.getTimestamp().toEpochMilli());
+                        row.setLong(i, vr.getTimestamp().toEpochMilli() * 1000L);
                     }
                     break;
                 case Interval: