JingsongLi commented on code in PR #5954:
URL: https://github.com/apache/paimon/pull/5954#discussion_r2227784704
##########
paimon-core/src/main/java/org/apache/paimon/tag/TagBatchCreation.java:
##########
@@ -45,22 +45,24 @@ public class TagBatchCreation {
private final TagManager tagManager;
private final SnapshotManager snapshotManager;
private final TagDeletion tagDeletion;
+ private final ZoneId zoneId;
public TagBatchCreation(FileStoreTable table) {
this.table = table;
this.snapshotManager = table.snapshotManager();
this.tagManager = table.tagManager();
this.tagDeletion = table.store().newTagDeletion();
this.options = table.coreOptions();
+ this.zoneId = options.sinkProcessTimeZone();
}
public void createTag() {
Snapshot snapshot = snapshotManager.latestSnapshot();
if (snapshot == null) {
return;
}
- Instant instant = Instant.ofEpochMilli(snapshot.timeMillis());
- LocalDateTime localDateTime = LocalDateTime.ofInstant(instant,
ZoneId.systemDefault());
+ LocalDateTime localDateTime =
+
Instant.ofEpochMilli(snapshot.timeMillis()).atZone(zoneId).toLocalDateTime();
Review Comment:
Add a test for this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@paimon.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
