hard20 pts · first answer countskafkaflinkcheckpoints

State lost after a code change

After adding a filter step to a Flink job and restoring from a savepoint, the job fails to map old state to operators. What should have been set on stateful operators?

A.A higher parallelism on each operatorB.A shorter checkpoint intervalC.A larger memory limit for the task managersD.A stable uid() for each operator

Discussion 0

Join free to post in the discussion.

State lost after a code change

Discussion 0

Related questions