Skip to content

Commit de4723f

Browse files
committed
[Bug] Fix the bug if expire tags procedure LocalDateTime using wrong timezone
1 parent 19cf86d commit de4723f

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

paimon-common/src/test/java/org/apache/paimon/utils/DateTimeUtilsTest.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,10 @@ public void testParseTimestampData() {
6767
ts = DateTimeUtils.parseTimestampData(dt, 3);
6868
assertThat(dt)
6969
.isEqualTo(ts.toLocalDateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
70+
71+
dt = "2025-04-22 17:49:21";
72+
LocalDateTime ld = DateTimeUtils.toLocalDateTime(dt, 3);
73+
assertThat(dt).isEqualTo(ld.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
7074
}
7175

7276
@Test

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ExpireTagsProcedure.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -55,9 +55,7 @@ public class ExpireTagsProcedure extends ProcedureBase {
5555
TagTimeExpire tagTimeExpire =
5656
fileStoreTable.store().newTagCreationManager().getTagTimeExpire();
5757
if (olderThanStr != null) {
58-
LocalDateTime olderThanTime =
59-
DateTimeUtils.parseTimestampData(olderThanStr, 3, TimeZone.getDefault())
60-
.toLocalDateTime();
58+
LocalDateTime olderThanTime = DateTimeUtils.toLocalDateTime(olderThanStr, 3);
6159
tagTimeExpire.withOlderThanTime(olderThanTime);
6260
}
6361
List<String> expired = tagTimeExpire.expire();

0 commit comments

Comments
 (0)