-
Task
-
Resolution: Done
-
Critical
-
2.3.0.Final, 2.4.0.Alpha1
-
None
-
False
-
None
-
False
-
-
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=)}]>
- links to
-
RHEA-2023:120698 Red Hat build of Debezium 2.3.4 release