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

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

          Activity

            People

            • Assignee:
              nicholasjiang Nicholas Jiang
              Reporter:
              jark Jark Wu

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment