You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Zhijiang (Jira)" <ji...@apache.org> on 2020/04/29 02:30:00 UTC
[jira] [Assigned] (FLINK-17440) Potential Buffer leak in output
unspilling for unaligned checkpoints
[ https://issues.apache.org/jira/browse/FLINK-17440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhijiang reassigned FLINK-17440:
--------------------------------
Assignee: Zhijiang
> Potential Buffer leak in output unspilling for unaligned checkpoints
> --------------------------------------------------------------------
>
> Key: FLINK-17440
> URL: https://issues.apache.org/jira/browse/FLINK-17440
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Reporter: Piotr Nowojski
> Assignee: Zhijiang
> Priority: Critical
> Fix For: 1.11.0
>
>
> {code}
> @Override
> public void PipelinedSubpartition#initializeState(ChannelStateReader stateReader) throws IOException, InterruptedException {
> for (ReadResult readResult = ReadResult.HAS_MORE_DATA; readResult == ReadResult.HAS_MORE_DATA;) {
> BufferBuilder bufferBuilder = parent.getBufferPool().requestBufferBuilderBlocking();
> BufferConsumer bufferConsumer = bufferBuilder.createBufferConsumer();
> readResult = stateReader.readOutputData(subpartitionInfo, bufferBuilder); // <<<<<<<<<<<<<<<<<<<<<<<
> // check whether there are some states data filled in this time
> if (bufferConsumer.isDataAvailable()) {
> add(bufferConsumer, false, false);
> bufferBuilder.finish();
> } else {
> bufferConsumer.close();
> }
> }
> }
> {code}
> There is a memory leak in output unspilling in case of an exception coming from the {{stateReader}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)