Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19750

Deserializer is not opened in Kafka consumer when restoring from state

    XMLWordPrintableJSON

    Details

    • Release Note:
      Hide
      Patch merged.
      master: 200be714ff7476f66b7f56cd9b266670b752afe0
      release-1.11: 78cd4628285c9dfdc0ada3f59cdefc4e8a7eb0bc
      Show
      Patch merged. master: 200be714ff7476f66b7f56cd9b266670b752afe0 release-1.11: 78cd4628285c9dfdc0ada3f59cdefc4e8a7eb0bc

      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. 

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                renqs Qingsheng Ren
                Reporter:
                renqs Qingsheng Ren
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: