Is MapState tied to Operator Input & Output type?

Posted by Arpith P on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Is-MapState-tied-to-Operator-Input-Output-type-tp38683.html

Hi,

I’ve a ProcessFunction which initially was receiving input & output type of String ⁽¹⁾ & inside processElement I was updating MapState. Now I have changed the Input & Output type to be Map, String ⁽²⁾, but if I restore from the last checkpoint folder MapState is coming in as empty. I’ve checked that checkpoint folder actually saves data (i.e. Files size > 1GB). Does map state tied with ProcessFunction input & output type, if not why doesn't mapstate get restored.

 

(1)    

       public class TestProcess extends ProcessFunction<String, String> implements CheckpointedFunction

(2)    

    public class TestProcess extends ProcessFunction<Map<String, String>, String> implements CheckpointedFunction