pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic
CheckpointBarrierHandler for unaligned checkpoint
URL: https://github.com/apache/flink/pull/11507#discussion_r399236422
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/AvailabilityProvider.java
##########
@@ -66,6 +66,16 @@ default boolean isApproximatelyAvailable() {
return getAvailableFuture() == AVAILABLE;
}
+ /**
Review comment:
> Fix non-blocking output availability logic.
I guess good catch, but deserves it's own Jira ticket and it's really
missing a unit test.
Can we extract this out of this PR and move it out from the MVP scope, to
not block them?
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
