Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-5611

Wrong validation check: when a unique constraint or PK is built out of more columns than specified in `include.list` property

    XMLWordPrintable

Details

    • Bug
    • Resolution: Unresolved
    • Major
    • 2.4-backlog
    • None
    • debezium-server
    • None
    • False
    • None
    • False

    Description

      This check seems irrelevant:
      You can specify the number of columns in the index (or more), but it may not include all the columns that are part of the primary key. In this case, the validation is OK, but you'll get empty values in the `key` part as these coluimns are not included.

      We should check that the columns of the index are included in the row. (or, we should have gotten them in the `key` part regardless, just not in the `payload`).
      We can start with this.

      jpechane ccranfor@redhat.com WDYT?

      if (recordIndexes[position] >= row.length) {
      LOGGER.error("Error requesting a row value, row: {}, requested index: {} at position {}", row.length, recordIndexes[position], position);
      throw new ConnectException("Data row is smaller than a column index, internal schema representation is probably out of sync with real database schema");
      }

      Attachments

        Activity

          People

            Unassigned Unassigned
            yossish Yossi Shirizli
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: