Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Won't Fix
-
None
-
None
-
None
Description
Here is related code:
public Tuple2<Long, Long> poll() { long oldestTimestamp = timeQueue.poll(); Tuple2<Long, Long> pair = new Tuple2<>(oldestTimestamp, counter.get(oldestTimestamp));
We should check the return value from timeQueue.poll() before casting to long.