[hotfix][network] Fix JavaDoc of the InputGate

Pance · Jun 5, 2019 · f35b1a3 · f35b1a3
1 parent 663b40d
commit f35b1a3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...ntime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGate.java b/...ntime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGate.java
@@ -99,8 +99,9 @@ public abstract class InputGate implements AutoCloseable {
  public abstract int getPageSize();
 
  /**
- * @return a future that is completed if there are more records available. If there more records
- * available immediately, {@link #AVAILABLE} should be returned.
+ * @return a future that is completed if there are more records available. If there are more
+ * records available immediately, {@link #AVAILABLE} should be returned. Previously returned
+ * not completed futures should become completed once there are more records available.
  */
  public CompletableFuture<?> isAvailable() {
  return isAvailable;