stankiewicz commented on PR #35919:
URL: https://github.com/apache/beam/pull/35919#issuecomment-3437578753
npe was happening when code was as follows:
```
@Override
public Instant getWatermark() {
// should be only used by a test receiver
if (checkNotNull(sessionService).getReceiver().isEOF()) {
return BoundedWindow.TIMESTAMP_MAX_VALUE;
}
return watermarkPolicy.getWatermark();
```
Current implementation is different so I'm not sure if this PR and issue is
relevant anymore.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
