[Hotfix][SqlServer CDC] fix SqlServerCDC IT failure (#3807)

ic4y · web-flow · commit fd66de5f98da · 2022-12-26T17:24:17.000+08:00
diff --git a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java
@@ -97,7 +97,8 @@ public static boolean isSchemaChangeEvent(SourceRecord sourceRecord) {
     public static boolean isDataChangeRecord(SourceRecord record) {
         Schema valueSchema = record.valueSchema();
         Struct value = (Struct) record.value();
-        return valueSchema.field(Envelope.FieldName.OPERATION) != null
+        return valueSchema != null
+                && valueSchema.field(Envelope.FieldName.OPERATION) != null
                 && value.getString(Envelope.FieldName.OPERATION) != null;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,8 @@ public static boolean isSchemaChangeEvent(SourceRecord sourceRecord) {`
`97`	`97`	`public static boolean isDataChangeRecord(SourceRecord record) {`
`98`	`98`	`Schema valueSchema = record.valueSchema();`
`99`	`99`	`Struct value = (Struct) record.value();`
`100`		`- return valueSchema.field(Envelope.FieldName.OPERATION) != null`
	`100`	`+ return valueSchema != null`
	`101`	`+ && valueSchema.field(Envelope.FieldName.OPERATION) != null`
`101`	`102`	`&& value.getString(Envelope.FieldName.OPERATION) != null;`
`102`	`103`	`}`
`103`	`104`