Skip to content

Commit

Permalink
ifx
Browse files Browse the repository at this point in the history
  • Loading branch information
dataroaring committed Jun 21, 2024
1 parent 03e920d commit a6f66bd
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1219,6 +1219,8 @@ public boolean isExpired(long currentTimeMs) {
expireTime = Config.streaming_label_keep_max_second;
}

LOG.INFO("state {}, expireTime {}, currentTimeMs {}, finishTimestamp {}",
state, expireTime, currentTimeMs, getFinishTimestamp());
return (currentTimeMs - getFinishTimestamp()) / 1000 > expireTime;
}

Expand Down

0 comments on commit a6f66bd

Please sign in to comment.