[
https://issues.apache.org/jira/browse/FLINK-24160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-24160:
---------------------------------
Fix Version/s: 1.15.0
1.14.0
> 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
> Priority: Major
> Labels: test-stability
> Fix For: 1.14.0, 1.15.0
>
>
> 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)
