[incubator-paimon] branch master updated: [core] Fix creationTime in DataFileMeta for JDK11

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new a1535061e [core] Fix creationTime in DataFileMeta for JDK11
a1535061e is described below

commit a1535061e58e9783e9376a9c43283439d87316b6
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Tue Sep 12 12:00:45 2023 +0800

    [core] Fix creationTime in DataFileMeta for JDK11
---
 paimon-common/src/main/java/org/apache/paimon/data/Timestamp.java | 4 ++++
 paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java  | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/paimon-common/src/main/java/org/apache/paimon/data/Timestamp.java 
b/paimon-common/src/main/java/org/apache/paimon/data/Timestamp.java
index 1fe066077..7441d25e7 100644
--- a/paimon-common/src/main/java/org/apache/paimon/data/Timestamp.java
+++ b/paimon-common/src/main/java/org/apache/paimon/data/Timestamp.java
@@ -82,6 +82,10 @@ public final class Timestamp implements 
Comparable<Timestamp>, Serializable {
         return java.sql.Timestamp.valueOf(toLocalDateTime());
     }
 
+    public Timestamp toMillisTimestamp() {
+        return fromEpochMillis(millisecond);
+    }
+
     /** Converts this {@link Timestamp} object to a {@link LocalDateTime}. */
     public LocalDateTime toLocalDateTime() {
         int date = (int) (millisecond / MILLIS_PER_DAY);
diff --git a/paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java 
b/paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java
index 1b7c107fb..933b76e39 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java
@@ -117,7 +117,7 @@ public class DataFileMeta {
                 schemaId,
                 level,
                 Collections.emptyList(),
-                Timestamp.fromLocalDateTime(LocalDateTime.now()));
+                
Timestamp.fromLocalDateTime(LocalDateTime.now()).toMillisTimestamp());
     }
 
     public DataFileMeta(