[incubator-seatunnel] branch dev updated: [Hotfix][SqlServer CDC] fix SqlServerCDC IT failure (#3807)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new fd66de5f9 [Hotfix][SqlServer CDC] fix SqlServerCDC IT failure (#3807)
fd66de5f9 is described below

commit fd66de5f98dab7461538cabc4e3dc56c90881249
Author: ic4y <83933160+i...@users.noreply.github.com>
AuthorDate: Mon Dec 26 17:24:17 2022 +0800

    [Hotfix][SqlServer CDC] fix SqlServerCDC IT failure (#3807)
---
 .../apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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
index 134fec9a1..bd4ad3fd5 100644
--- 
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 class SourceRecordUtils {
     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;
     }