Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.11.3, 1.13.0, 1.12.3
Description
This is because LocalRecoveredInputChannel#toInputChannelInternal is passing wrong parameter to LocalInputChannel's constructor (twice numBytesIn):
protected InputChannel toInputChannelInternal() { return new LocalInputChannel( inputGate, getChannelIndex(), partitionId, partitionManager, taskEventPublisher, initialBackoff, maxBackoff, numBytesIn, numBytesIn, channelStateWriter); }
Attachments
Issue Links
- links to