Xintong Song created FLINK-24160: ------------------------------------ Summary: PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.' Key: FLINK-24160 URL: https://issues.apache.org/jira/browse/FLINK-24160 Project: Flink Issue Type: Bug Reporter: Xintong Song
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23526&view=logs&j=39d5b1d5-3b41-54dc-6458-1e2ddd1cdcf3&t=0c010d0c-3dec-5bf1-d408-7b18988b1b2b&l=5526 {code} Sep 04 02:31:13 Caused by: java.io.IOException: Size of the state is larger than the maximum permitted memory-backed state. Size=6281708, maxSize=5242880. Consider using a different checkpoint storage, like the FileSystemCheckpointStorage. Sep 04 02:31:13 at org.apache.flink.runtime.state.memory.MemCheckpointStreamFactory.checkSize(MemCheckpointStreamFactory.java:63) Sep 04 02:31:13 at org.apache.flink.runtime.state.memory.MemCheckpointStreamFactory$MemoryCheckpointOutputStream.closeAndGetBytes(MemCheckpointStreamFactory.java:140) Sep 04 02:31:13 at org.apache.flink.runtime.state.memory.MemCheckpointStreamFactory$MemoryCheckpointOutputStream.closeAndGetHandle(MemCheckpointStreamFactory.java:120) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.finishWriteAndResult(ChannelStateCheckpointWriter.java:218) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.doComplete(ChannelStateCheckpointWriter.java:240) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.lambda$complete$5(ChannelStateCheckpointWriter.java:202) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.runWithChecks(ChannelStateCheckpointWriter.java:296) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.complete(ChannelStateCheckpointWriter.java:200) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateCheckpointWriter.completeInput(ChannelStateCheckpointWriter.java:187) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.CheckpointInProgressRequest.execute(ChannelStateWriteRequest.java:212) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestDispatcherImpl.dispatchInternal(ChannelStateWriteRequestDispatcherImpl.java:85) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestDispatcherImpl.dispatch(ChannelStateWriteRequestDispatcherImpl.java:62) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.loop(ChannelStateWriteRequestExecutorImpl.java:96) Sep 04 02:31:13 at org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl.run(ChannelStateWriteRequestExecutorImpl.java:75) Sep 04 02:31:13 ... 1 more {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)