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

Oracle transaction reconciliation fails to lookup primary key columns if UPDATE sets columns to only NULL

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 1.6.0.CR1
    • 1.6.0.Beta2
    • oracle-connector
    • None

      We use connector 1.6 beta2.
      ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31) io.debezium.DebeziumException: Could not find column ID in event

      Full log file connect.log
      Connector config

      {"connector.class": "io.debezium.connector.oracle.OracleConnector", 
      "tasks.max": "1", 
      "snapshot.mode": "schema_only", 
      "snapshot.delay.ms": "5000", 
      "heartbeat.interval.ms": "1000", 
      "provide.transaction.metadata": "true", 
      "decimal.handling.mode": "string",
      "sanitize.field.names": "true",
      "event.processing.failure.handling.mode": "skip", 
      "database.server.name": "ABCDf2", 
      "database.hostname": "192.168.2.68", 
      "database.port": "1521", 
      "database.user": "logminer", 
      "database.password": "lm", 
      "database.dbname": "ABCDf2",  
      "database.history.kafka.bootstrap.servers": "10.204.192.111:9092,10.204.192.112:9092,10.204.192.113:9092", 
      "database.history.kafka.topic": "history_logminer_160621_v0",
      "log.mining.archive.log.hours": "1",
      "log.mining.archive.log.only.mode": "true",
      "table.include.list": "ABCD_SHARD_1_3.D_LOT_VERSION,ABCD_SHARD_1_3.D_LOT_ENTITY,ABCD_SHARD_1_3.D_LOT_STATUS_HISTORY,ABCD_SHARD_1_3.D_PROCEDURE_LOT_ENTRY,ABCD_SHARD_1_3.D_LOT_LOT_ENTRY,ABCD_SHARD_1_3.D_PROCEDURE_VERSION,ABCD_SHARD_1_3.D_PROCEDURE_ENTITY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_LOT_ENTRY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_VERSION,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_ENTITY,ABCD_SHARD_1_3.D_BID,ABCD_SHARD_1_3.D_EA_PARTICIPANT,ABCD_SHARD_1_3.D_LOT_LOTNUM_ENTRY,ABCD_NSI.N_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ,ABCD_NSI.N_SPGZ_CHARACTERISTIC_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ_ENUM,ABCD_NSI.N_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ,ABCD_NSI.N_KPGZ_CHARACTERISTIC_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ_ENUM,ABCD_NSI.N_KPGZ_CONTRACT_TEMPLATE,ABCD_NSI.N_KPGZ_TECH_TASK,ABCD_NSI.N_CHARACTERISTIC,ABCD_NSI.N_OKEI_SPGZ" }
      

      DDL:

      -- auto-generated definition
      create table D_PLAN_SCHEDULE_VERSION
      (
          ID                               NUMBER(38) not null
              constraint PK_SPLAN_VERSION_ID
                  primary key,
          ENTITY_ID                        NUMBER(38) not null
              constraint FK_PSV_PLAN_SCHEDULE_ENTITY
                  references D_PLAN_SCHEDULE_ENTITY,
          CREATED_DATE                     TIMESTAMP(6),
          DELETED_DATE                     DATE,
          PUBLICATION_DATE                 DATE,
          APPROVED_VERSION                 NUMBER(38),
          ACTUAL                           NUMBER(1),
          REASON_FOR_CHANGE_ID             NUMBER(38),
          GRBS_APPROVED_SENT_DATE          DATE,
          GRBS_APPROVED_DATE               DATE,
          GRBS_RESULT_OF_REVIEW_ID         NUMBER(38),
          OPERATION_ID                     NVARCHAR2(50),
          APPROVED_DATE                    DATE,
          DOCX                             BLOB,
          DOCX_SIGNATURE                   BLOB,
          XML_OOS                          BLOB,
          XML_OOS_SIGNATURE                BLOB,
          SIGNER_USER_ID                   NUMBER(38),
          DOCX_FILE_ACCESS_CODE            NVARCHAR2(50),
          OOS_XML_FILE_ACCESS_CODE         NVARCHAR2(50),
          OOS_REF_ID                       NVARCHAR2(50),
          OOS_USER                         VARCHAR2(50),
          OOS_PASSWORD                     VARCHAR2(50),
          VERSION                          NUMBER(10) default 1,
          STATUS_ID                        NUMBER(10),
          DF_REQUEST_ID                    NUMBER(38),
          DF_RESULT_OF_REVIEW_ID           NUMBER(38),
          DF_APPROVED_DATE                 DATE,
          DF_APPROVED_SENT_DATE            DATE,
          YEAR_SUM                         NUMBER(19, 2),
          FO_APPROVAL_RECEIVED             NUMBER(1),
          PRINT_FORM_FILE_ID               NUMBER(10),
          EXCLUDED_PURCHASE_VOLUME         NUMBER,
          PLANNED_PURCHASE_VOLUME          NUMBER,
          AGGREGATE_ANNUAL_CONTR_VALUE     NUMBER,
          ANNUAL_MSP_PURCHASE_VOLUME       NUMBER,
          ANNUAL_ONLY_MSP_PURCHASE_VOL     NUMBER,
          SPGZ_INNOVATION_SUM              NUMBER,
          PLANNED_ONLY_MSP_PURCHASE_VOLUME NUMBER,
          OOS_VERSION                      NUMBER(10)
      )
      /
      create index PLAN_SCHEDULE_VERSION_ENT_ID
          on D_PLAN_SCHEDULE_VERSION (ENTITY_ID)
      /
      

        1. connect.log
          3.88 MB
          Dmitriy Rum

              ccranfor@redhat.com Chris Cranford
              chapeauclaque Dmitriy Rum (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: