(flink) branch master updated: [FLINK-40671][network] Document why UnknownInputChannel graduation hardcodes needsRecovery=false

[fanrui]

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

1996fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 93749bbe71c [FLINK-40671][network] Document why UnknownInputChannel 
graduation hardcodes needsRecovery=false
93749bbe71c is described below

commit 93749bbe71c010461b0ea5cd98ba34df7c24f79a
Author: Rui Fan <1996fan...@gmail.com>
AuthorDate: Tue Sep 15 13:27:05 2026 +0200

    [FLINK-40671][network] Document why UnknownInputChannel graduation 
hardcodes needsRecovery=false
---
 .../runtime/io/network/partition/consumer/UnknownInputChannel.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnknownInputChannel.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnknownInputChannel.java
index 9db9df9c613..c5a12bcb829 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnknownInputChannel.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnknownInputChannel.java
@@ -192,6 +192,8 @@ class UnknownInputChannel extends InputChannel implements 
ChannelStateHolder {
                         metrics.getNumBytesInRemoteCounter(),
                         metrics.getNumBuffersInRemoteCounter(),
                         channelStateWriter == null ? ChannelStateWriter.NO_OP 
: channelStateWriter,
+                        // Unknown channels exist only in BATCH jobs, which 
have no channel
+                        // state, so this channel is never in recovery.
                         false);
         return channel;
     }
@@ -210,6 +212,8 @@ class UnknownInputChannel extends InputChannel implements 
ChannelStateHolder {
                 metrics.getNumBuffersInLocalCounter(),
                 channelStateWriter == null ? ChannelStateWriter.NO_OP : 
channelStateWriter,
                 networkBuffersPerChannel,
+                // Unknown channels exist only in BATCH jobs, which have no 
channel
+                // state, so this channel is never in recovery.
                 false);
     }