Hi,
I’ve a *ProcessFunction* which initially was receiving input & output type
of String (1) & inside *processElement* I was updating MapState. Now I have
changed the Input & Output type to be Map, String (2), 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
