Re: Query regarding akka.framesize in Flink

2022-09-15 Thread Danny Cranmer
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 co

Query regarding akka.framesize in Flink

2022-09-15 Thread Mahima Agarwal
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 getti