Hey, Akka frame maximum size is 2GB, which is limited by maximum java byte[] size. Not sure why you config is being rejected. If your Akka frames are getting large you can consider reducing state.storage.fs.memory-threshold [1],l. If you are using RocksDB with incremental checkpoints, triggering compaction more regularly will help reduce the frame size, since you would get fewer large files rather than more smaller. Or generally scaling out across more task managers.
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/#state-storage-fs-memory-threshold On Thu, 15 Sept 2022, 11:56 Mahima Agarwal, <mahi.29agar...@gmail.com> wrote: > Hi Team, > > I am trying to set the value of akka.framesize in flinkconf.yaml to 2 gb, > because of which I am getting the below exception which staring flink: > > "Caused by: java.lang.IllegalArgumentException: requirement failed: > Setting 'maximum-frame-size' must be at least 32000 bytes" > > Flink is getting started perfectly would any error if this akka.framesize > is set to 1 gb. > > My queries are : > 1. Is there any limit for setting the value of akka.framesize. > 2. Are there any dependent parameters that we need to set if we increase > the size of akka.framesize. > > Thanks in advance. > > Regards > Mahima Agarwal > >
