Skip to content

Commit

Permalink
[minor] Just ignore the Long.MIN_VALUE watermark when creating the ta…
Browse files Browse the repository at this point in the history
…g. (apache#3490)
  • Loading branch information
LinMingQiang authored Jun 11, 2024
1 parent cf9de27 commit a530d96
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ private WatermarkExtractor(ZoneId watermarkZoneId) {

@Override
public Optional<LocalDateTime> extract(long timeMilli, @Nullable Long watermark) {
if (watermark == null || watermark < 0) {
if (watermark == null || watermark == Long.MIN_VALUE) {
return Optional.empty();
}

Expand Down

0 comments on commit a530d96

Please sign in to comment.