[FLINK-19750] Deserializer is not opened in Kafka consumer when restoring from state

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.11.0, 1.11.1, 1.11.2
• Fix Version/s: 1.11.3, 1.12.0
• Component/s: Connectors / Kafka
• Labels: pull-request-available

Release Note

Patch merged.
master: 200be714ff7476f66b7f56cd9b266670b752afe0
release-1.11: 78cd4628285c9dfdc0ada3f59cdefc4e8a7eb0bc

• Assignee: Qingsheng Ren
• Reporter: Qingsheng Ren
• Created: 21/Oct/20 08:02
• Updated: 26/Oct/20 04:04
• Resolved: 26/Oct/20 04:04

Description

When a job using Kafka consumer is recovered from a checkpoint or savepoint, the open method of the record deserializer is not called. This is possibly because this.deserializer.open is put into the else clause by mistake, which will only be called if the job has a clean start. 

Issue Links

• links to: GitHub Pull Request #13785