[flink] 04/04: [hotfix] Clarification ownerships of the buffer for Remote InputChannel#onBuffer in javadoc

[pn...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 6a2f80605b1cc2545ac1400ae6a131fb7b5093b4
Author: Anton Kalashnikov <ka...@yandex.ru>
AuthorDate: Wed Jun 2 19:39:04 2021 +0300

    [hotfix] Clarification ownerships of the buffer for Remote InputChannel#onBuffer in javadoc
    
    (cherry picked from commit bc8c739320210432128bbb486259b70a7250de9c)
---
 .../runtime/io/network/partition/consumer/RemoteInputChannel.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
index 128fd18..0cd918f 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
@@ -443,6 +443,10 @@ public class RemoteInputChannel extends InputChannel {
         }
     }
 
+    /**
+     * Handles the input buffer. This method is taking over the ownership of the buffer and is fully
+     * responsible for cleaning it up both on the happy path and in case of an error.
+     */
     public void onBuffer(Buffer buffer, int sequenceNumber, int backlog) throws IOException {
         boolean recycleBuffer = true;