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

Deserialization exception when using 'canal-json.table.include' to filter out the binlog of the specified table

    XMLWordPrintableJSON

    Details

      Description

      I found a bug in the canal code. 'canal-json.table.include' does not filter out the binlog of the specified table correctly, which will cause an error in the parsing section. For example, if I want to read the binlog of canal-json.table.include = 'a' table, there is a source field of int in table a, but at this time if table b also has a source field of string, An error will be reported.

        Attachments

        1. screenshot-1.png
          255 kB
          Jark Wu
        2. image-2021-01-13-15-02-33-266.png
          72 kB
          wangfei
        3. image-2021-01-08-14-53-40-476.png
          273 kB
          wangfei
        4. image-2021-01-08-14-52-53-443.png
          160 kB
          wangfei

          Issue Links

            Activity

              People

              • Assignee:
                nicholasjiang Nicholas Jiang
                Reporter:
                jark Jark Wu
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: