Details
-
Bug
-
Status: Open
-
P3
-
Resolution: Unresolved
-
2.22.0
-
None
Description
Observed on v2.22.0
When withMaxReadTime() is used, Beam creates an BoundedReadFromUnboundedSource [1]. The ReadFn<T> class in BoundedReadFromUnboundedSource which is responsible for reading records from source. You can see this class doesnt verify if there is a recoverable checkpoint exist. Instead it always creates Reader with checkpointMark set as null [2].
Reference: