[
https://issues.apache.org/jira/browse/FLINK-22592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-22592.
--------------------------------
Fix Version/s: 1.12.5
1.13.1
1.14.0
Resolution: Fixed
Fixed via
- master (1.14): 6c6256130583a246309d1585029ad30d243941b3
- release-1.13: 9b2f97d07dfa39c58572655f0a30d76ad9156546
- release-1.12: 60093e4c51fd0e566e44c8ec7585a67c9376e164
> numBuffersInLocal is always zero when using unaligned checkpoints
> -----------------------------------------------------------------
>
> Key: FLINK-22592
> URL: https://issues.apache.org/jira/browse/FLINK-22592
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Affects Versions: 1.11.3, 1.13.0, 1.12.3
> Reporter: Piotr Nowojski
> Assignee: Nicholas Jiang
> Priority: Major
> Labels: beginner-friendly, pull-request-available
> Fix For: 1.14.0, 1.13.1, 1.12.5
>
>
> This is because {{LocalRecoveredInputChannel#toInputChannelInternal}} is
> passing wrong parameter to {{LocalInputChannel}}'s constructor (twice
> {{numBytesIn}}):
> {code:java}
> protected InputChannel toInputChannelInternal() {
> return new LocalInputChannel(
> inputGate,
> getChannelIndex(),
> partitionId,
> partitionManager,
> taskEventPublisher,
> initialBackoff,
> maxBackoff,
> numBytesIn,
> numBytesIn,
> channelStateWriter);
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
