From a530d9691849f756f6a86b605d15047bc5229700 Mon Sep 17 00:00:00 2001 From: HunterXHunter <1356469429@qq.com> Date: Tue, 11 Jun 2024 10:15:47 +0800 Subject: [PATCH] [minor] Just ignore the Long.MIN_VALUE watermark when creating the tag. (#3490) --- .../src/main/java/org/apache/paimon/tag/TagTimeExtractor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java b/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java index 29bc345030dd..5b046e752f4e 100644 --- a/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java +++ b/paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java @@ -56,7 +56,7 @@ private WatermarkExtractor(ZoneId watermarkZoneId) { @Override public Optional extract(long timeMilli, @Nullable Long watermark) { - if (watermark == null || watermark < 0) { + if (watermark == null || watermark == Long.MIN_VALUE) { return Optional.empty(); }