Currently my flink application has state size of 160GB(around 50 operators), where few state operator size is much higher, I am planning to use state processor API to bootstrap let say one particular state having operator id o1 and inside is a ValueState s1 as ID.
Following steps I have planned to do it : 1. If I take a savepoint of the application I will be having a state folder containing operator and meta data file having o1 and s1. 2. Now II read only that state using state processor API (another flink app)and re-write it with the data that I want with same o1 and s1 ids and copy paste this folder to the savepoint folder taken in step 1. 3. Restore the application with the savepoint taken in step 1. Doing so as I do not want to touch any other state , I have my concerned with a particular state operator. Team, Kindly let me know if this is the right way to do it, or is there any better way using which I can achieve this. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
