[
https://issues.apache.org/jira/browse/FLINK-36959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-36959:
-------------------------------
Description:
The computation of readable buffer offsets and sizes fails when the range
starts or ends with empty buffers.
The offsets and sizes of buffers can follow these patterns:
* {\{0,0}, ..., \{1,3}, ..., \{0,0}, ....\{5,6}, ...} for non-broadcast
scenarios.
* {\{1,2}, ..., \{1,2}, ...\{1,2}} for broadcast scenarios.
However, the current logic does not correctly handle situations where the
sequence starts or ends with an empty buffer (\{0, 0}). This needs to be fixed.
was:
The computation of readable buffer offsets and sizes fails when the range
starts or ends with empty buffers.
The offsets and sizes of buffers can follow these patterns:
* {{{\{0,0}, ..., \{1,3}, ..., \{0,0}, \{5,6}, ...}}} for non-broadcast
scenarios.
* {{{\{1,2}, ..., \{1,2}, ..., \{1,2}, ...}}} for broadcast scenarios.
However, the current logic does not correctly handle situations where the
sequence starts or ends with an empty buffer (\{0, 0}). This needs to be fixed.
> Computing readable buffer offsets and sizes when including empty buffers
> fails.
> -------------------------------------------------------------------------------
>
> Key: FLINK-36959
> URL: https://issues.apache.org/jira/browse/FLINK-36959
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Reporter: Junrui Lee
> Assignee: Junrui Lee
> Priority: Major
>
> The computation of readable buffer offsets and sizes fails when the range
> starts or ends with empty buffers.
> The offsets and sizes of buffers can follow these patterns:
> * {\{0,0}, ..., \{1,3}, ..., \{0,0}, ....\{5,6}, ...} for non-broadcast
> scenarios.
> * {\{1,2}, ..., \{1,2}, ...\{1,2}} for broadcast scenarios.
> However, the current logic does not correctly handle situations where the
> sequence starts or ends with an empty buffer (\{0, 0}). This needs to be
> fixed.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
