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

Flaky Oracle test: shouldCaptureChangesForTransactionsAcrossSnapshotBoundaryWithoutReemittingDDLChanges

XMLWordPrintable

      Test seems to error out on the Github CI quite regularly:

      Error:    OracleConnectorIT.shouldCaptureChangesForTransactionsAcrossSnapshotBoundaryWithoutReemittingDDLChanges:3389 
      Expected size:<6> but was:<7> in:
      <[SourceRecord{sourcePartition={server=server1}, sourceOffset={snapshot_pending_tx=0a00100086020000:2363159, snapshot_scn=2363761, snapshot=true, scn=2363761, snapshot_completed=false}} ConnectRecord{topic='server1', kafkaPartition=0, key=Struct{databaseName=ORCLPDB1}, keySchema=Schema{io.debezium.connector.oracle.SchemaChangeKey:STRUCT}, value=Struct{source=Struct{version=2.4.0-SNAPSHOT,connector=oracle,name=server1,ts_ms=1689329673371,snapshot=true,db=ORCLPDB1,schema=DEBEZIUM,table=A,scn=2363761,ssn=0},ts_ms=1689329673569,databaseName=ORCLPDB1,schemaName=DEBEZIUM,ddl=
        CREATE TABLE "DEBEZIUM"."A" 
         (	"PK" NUMBER(9,0), 
      	"AA" NUMBER(9,0), 
      	 PRIMARY KEY ("PK")
        USING INDEX  ENABLE, 
      	 SUPPLEMENTAL LOG DATA (ALL) COLUMNS
         ) ;,tableChanges=[Struct{type=CREATE,id="ORCLPDB1"."DEBEZIUM"."A",table=Struct{primaryKeyColumnNames=[PK],columns=[Struct{name=PK,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=1,optional=false,autoIncremented=false,generated=false}, Struct{name=AA,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=2,optional=true,autoIncremented=false,generated=false}]}}]}, valueSchema=Schema{io.debezium.connector.oracle.SchemaChangeValue:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)},
          SourceRecord{sourcePartition={server=server1}, sourceOffset={snapshot_pending_tx=0a00100086020000:2363159, snapshot_scn=2363761, snapshot=true, scn=2363761, snapshot_completed=false}} ConnectRecord{topic='server1', kafkaPartition=0, key=Struct{databaseName=ORCLPDB1}, keySchema=Schema{io.debezium.connector.oracle.SchemaChangeKey:STRUCT}, value=Struct{source=Struct{version=2.4.0-SNAPSHOT,connector=oracle,name=server1,ts_ms=1689329673570,snapshot=true,db=ORCLPDB1,schema=DEBEZIUM,table=CUSTOMER,scn=2363761,ssn=0},ts_ms=1689329673708,databaseName=ORCLPDB1,schemaName=DEBEZIUM,ddl=
        CREATE TABLE "DEBEZIUM"."CUSTOMER" 
         (	"ID" NUMBER(9,0) NOT NULL ENABLE, 
      	"NAME" VARCHAR2(1000), 
      	"SCORE" NUMBER(6,2), 
      	"REGISTERED" TIMESTAMP (6), 
      	 PRIMARY KEY ("ID")
        USING INDEX  ENABLE, 
      	 SUPPLEMENTAL LOG DATA (ALL) COLUMNS
         ) ;,tableChanges=[Struct{type=CREATE,id="ORCLPDB1"."DEBEZIUM"."CUSTOMER",table=Struct{primaryKeyColumnNames=[ID],columns=[Struct{name=ID,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=1,optional=false,autoIncremented=false,generated=false}, Struct{name=NAME,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=1000,position=2,optional=true,autoIncremented=false,generated=false}, Struct{name=SCORE,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=6,scale=2,position=3,optional=true,autoIncremented=false,generated=false}, Struct{name=REGISTERED,jdbcType=93,typeName=TIMESTAMP(6),typeExpression=TIMESTAMP(6),length=6,position=4,optional=true,autoIncremented=false,generated=false}]}}]}, valueSchema=Schema{io.debezium.connector.oracle.SchemaChangeValue:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)},
          SourceRecord{sourcePartition={server=server1}, sourceOffset={snapshot_pending_tx=0a00100086020000:2363159, snapshot_scn=2363761, snapshot=true, scn=2363761, snapshot_completed=false}} ConnectRecord{topic='server1', kafkaPartition=0, key=Struct{databaseName=ORCLPDB1}, keySchema=Schema{io.debezium.connector.oracle.SchemaChangeKey:STRUCT}, value=Struct{source=Struct{version=2.4.0-SNAPSHOT,connector=oracle,name=server1,ts_ms=1689329673708,snapshot=true,db=ORCLPDB1,schema=DEBEZIUM,table=DBZ4367,scn=2363761,ssn=0},ts_ms=1689329673840,databaseName=ORCLPDB1,schemaName=DEBEZIUM,ddl=
        CREATE TABLE "DEBEZIUM"."DBZ4367" 
         (	"ID" NUMBER(9,0), 
      	"DATA" VARCHAR2(50), 
      	 SUPPLEMENTAL LOG DATA (ALL) COLUMNS
         ) ;,tableChanges=[Struct{type=CREATE,id="ORCLPDB1"."DEBEZIUM"."DBZ4367",table=Struct{primaryKeyColumnNames=[],columns=[Struct{name=ID,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=1,optional=true,autoIncremented=false,generated=false}, Struct{name=DATA,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=50,position=2,optional=true,autoIncremented=false,generated=false}]}}]}, valueSchema=Schema{io.debezium.connector.oracle.SchemaChangeValue:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)},
          SourceRecord{sourcePartition={server=server1}, sourceOffset={snapshot_pending_tx=0a00100086020000:2363159, snapshot_scn=2363761, snapshot=true, scn=2363761, snapshot_completed=false}} ConnectRecord{topic='server1', kafkaPartition=0, key=Struct{databaseName=ORCLPDB1}, keySchema=Schema{io.debezium.connector.oracle.SchemaChangeKey:STRUCT}, value=Struct{source=Struct{version=2.4.0-SNAPSHOT,connector=oracle,name=server1,ts_ms=1689329673841,snapshot=true,db=ORCLPDB1,schema=DEBEZIUM,table=DBZ4367_EXTRA,scn=2363761,ssn=0},ts_ms=1689329674226,databaseName=ORCLPDB1,schemaName=DEBEZIUM,ddl=
        CREATE TABLE "DEBEZIUM"."DBZ4367_EXTRA" 
         (	"ID" NUMBER(9,0), 
      	"DATA" VARCHAR2(50), 
      	"DATA2" VARCHAR2(50) DEFAULT 'default2', 
      	 SUPPLEMENTAL LOG DATA (ALL) COLUMNS
         ) ;,tableChanges=[Struct{type=CREATE,id="ORCLPDB1"."DEBEZIUM"."DBZ4367_EXTRA",table=Struct{primaryKeyColumnNames=[],columns=[Struct{name=ID,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=1,optional=true,autoIncremented=false,generated=false}, Struct{name=DATA,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=50,position=2,optional=true,autoIncremented=false,generated=false}, Struct{name=DATA2,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=50,position=3,optional=true,autoIncremented=false,generated=false,defaultValueExpression='default2'}]}}]}, valueSchema=Schema{io.debezium.connector.oracle.SchemaChangeValue:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)},
          SourceRecord{sourcePartition={server=server1}, sourceOffset={snapshot_pending_tx=0a00100086020000:2363159, snapshot_scn=2363761, snapshot=true, scn=2363761, snapshot_completed=false}} ConnectRecord{topic='server1', kafkaPartition=0, key=Struct{databaseName=ORCLPDB1}, keySchema=Schema{io.debezium.connector.oracle.SchemaChangeKey:STRUCT}, value=Struct{source=Struct{version=2.4.0-SNAPSHOT,connector=oracle,name=server1,ts_ms=1689329674227,snapshot=true,db=ORCLPDB1,schema=DEBEZIUM,table=DT_TABLE,scn=2363761,ssn=0},ts_ms=1689329674369,databaseName=ORCLPDB1,schemaName=DEBEZIUM,ddl=
        CREATE TABLE "DEBEZIUM"."DT_TABLE" 
         (	"ID" NUMBER(9,0) NOT NULL ENABLE, 
      	"C1" NUMBER(*,0), 
      	"C2" NUMBER(*,0), 
      	"C3A" NUMBER(5,2), 
      	"C3B" VARCHAR2(128), 
      	"F1" FLOAT(10), 
      	"F2" NUMBER(8,4), 
      	 PRIMARY KEY ("ID")
        USING INDEX  ENABLE, 
      	 SUPPLEMENTAL LOG DATA (ALL) COLUMNS
         ) ;,tableChanges=[Struct{type=CREATE,id="ORCLPDB1"."DEBEZIUM"."DT_TABLE",table=Struct{primaryKeyColumnNames=[ID],columns=[Struct{name=ID,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=1,optional=false,autoIncremented=false,generated=false}, Struct{name=C1,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=38,scale=0,position=2,optional=true,autoIncremented=false,generated=false}, Struct{name=C2,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=38,scale=0,position=3,optional=true,autoIncremented=false,generated=false}, Struct{name=C3A,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=5,scale=2,position=4,optional=true,autoIncremented=false,generated=false}, Struct{name=C3B,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=128,position=5,optional=true,autoIncremented=false,generated=false}, Struct{name=F1,jdbcType=6,typeName=FLOAT,typeExpression=FLOAT,length=10,position=6,optional=true,autoIncremented=false,generated=false}, Struct{name=F2,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=8,scale=4,position=7,optional=true,autoIncremented=false,generated=false}]}}]}, valueSchema=Schema{io.debezium.connector.oracle.SchemaChangeValue:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)},
          SourceRecord{sourcePartition={server=server1}, sourceOffset={snapshot_pending_tx=0a00100086020000:2363159, snapshot_scn=2363761, snapshot=true, scn=2363761, snapshot_completed=false}} ConnectRecord{topic='server1', kafkaPartition=0, key=Struct{databaseName=ORCLPDB1}, keySchema=Schema{io.debezium.connector.oracle.SchemaChangeKey:STRUCT}, value=Struct{source=Struct{version=2.4.0-SNAPSHOT,connector=oracle,name=server1,ts_ms=1689329674369,snapshot=true,db=ORCLPDB1,schema=DEBEZIUM,table=MASKED_HASHED_COLUMN_TABLE,scn=2363761,ssn=0},ts_ms=1689329674506,databaseName=ORCLPDB1,schemaName=DEBEZIUM,ddl=
        CREATE TABLE "DEBEZIUM"."MASKED_HASHED_COLUMN_TABLE" 
         (	"ID" NUMBER(9,0) NOT NULL ENABLE, 
      	"NAME" VARCHAR2(255), 
      	"NAME2" VARCHAR2(255), 
      	"NAME3" VARCHAR2(20), 
      	 PRIMARY KEY ("ID")
        USING INDEX  ENABLE, 
      	 SUPPLEMENTAL LOG DATA (ALL) COLUMNS
         ) ;,tableChanges=[Struct{type=CREATE,id="ORCLPDB1"."DEBEZIUM"."MASKED_HASHED_COLUMN_TABLE",table=Struct{primaryKeyColumnNames=[ID],columns=[Struct{name=ID,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=1,optional=false,autoIncremented=false,generated=false}, Struct{name=NAME,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=255,position=2,optional=true,autoIncremented=false,generated=false}, Struct{name=NAME2,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=255,position=3,optional=true,autoIncremented=false,generated=false}, Struct{name=NAME3,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=20,position=4,optional=true,autoIncremented=false,generated=false}]}}]}, valueSchema=Schema{io.debezium.connector.oracle.SchemaChangeValue:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)},
          SourceRecord{sourcePartition={server=server1}, sourceOffset={snapshot_pending_tx=0a00100086020000:2363159, snapshot_scn=2363761, snapshot=true, scn=2363761, snapshot_completed=false}} ConnectRecord{topic='server1', kafkaPartition=0, key=Struct{databaseName=ORCLPDB1}, keySchema=Schema{io.debezium.connector.oracle.SchemaChangeKey:STRUCT}, value=Struct{source=Struct{version=2.4.0-SNAPSHOT,connector=oracle,name=server1,ts_ms=1689329674506,snapshot=true,db=ORCLPDB1,schema=DEBEZIUM,table=TRUNCATED_COLUMN_TABLE,scn=2363761,ssn=0},ts_ms=1689329674641,databaseName=ORCLPDB1,schemaName=DEBEZIUM,ddl=
        CREATE TABLE "DEBEZIUM"."TRUNCATED_COLUMN_TABLE" 
         (	"ID" NUMBER(9,0) NOT NULL ENABLE, 
      	"NAME" VARCHAR2(20), 
      	 PRIMARY KEY ("ID")
        USING INDEX  ENABLE, 
      	 SUPPLEMENTAL LOG DATA (ALL) COLUMNS
         ) ;,tableChanges=[Struct{type=CREATE,id="ORCLPDB1"."DEBEZIUM"."TRUNCATED_COLUMN_TABLE",table=Struct{primaryKeyColumnNames=[ID],columns=[Struct{name=ID,jdbcType=2,typeName=NUMBER,typeExpression=NUMBER,length=9,scale=0,position=1,optional=false,autoIncremented=false,generated=false}, Struct{name=NAME,jdbcType=12,typeName=VARCHAR2,typeExpression=VARCHAR2,length=20,position=2,optional=true,autoIncremented=false,generated=false}]}}]}, valueSchema=Schema{io.debezium.connector.oracle.SchemaChangeValue:STRUCT}, timestamp=null, headers=ConnectHeaders(headers=)}]>
      

            ccranfor@redhat.com Chris Cranford
            ccranfor@redhat.com Chris Cranford
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

              Created:
              Updated:
              Resolved: