DBZ-4979 Guard against NPE for non-table related DDLs

debezium · Apr 12, 2022 · 053bf60 · 053bf60
1 parent 7b95aa7
commit 053bf60
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...um/pipeline/source/snapshot/incremental/AbstractIncrementalSnapshotChangeEventSource.java b/...um/pipeline/source/snapshot/incremental/AbstractIncrementalSnapshotChangeEventSource.java
@@ -102,7 +102,7 @@ public void closeWindow(P partition, String id, OffsetContext offsetContext) thr
 
     @Override
     public void processSchemaChange(P partition, DataCollectionId dataCollectionId) throws InterruptedException {
-        if (dataCollectionId.equals(context.currentDataCollectionId())) {
+        if (dataCollectionId != null && dataCollectionId.equals(context.currentDataCollectionId())) {
             rereadChunk(partition);
         }
     }