Questions around MemoryStateBackend size limits

2020-06-02 Thread vishalovercome
The documentation says: *The size of each individual state is by default limited to 5 MB. This value can be increased in the constructor of the MemoryStateBackend.* 1. I want to know what would happen if a job ended up adding elements to a state variable causing its size to exceed 5MB. There are

Re: Questions around MemoryStateBackend size limits

2020-06-01 Thread Yun Tang
From: vishalovercome Sent: Tuesday, June 2, 2020 13:58 To: dev@flink.apache.org Subject: Questions around MemoryStateBackend size limits The documentation says: *The size of each individual state is by default limited to 5 MB. This value can be increased in the constructor of the MemoryStateBackend