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)
