diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleSignalBasedIncrementalSnapshotChangeEventSource.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleSignalBasedIncrementalSnapshotChangeEventSource.java
index d78d0545b..fb5d316fb 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleSignalBasedIncrementalSnapshotChangeEventSource.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleSignalBasedIncrementalSnapshotChangeEventSource.java
@@ -47,6 +47,8 @@ protected String getSignalTableName(String dataCollectionId) {
 
     @Override
     protected void preReadChunk(IncrementalSnapshotContext<TableId> context) {
+        super.preReadChunk(context);
+
         if (pdbName != null) {
             connection.setSessionToPdb(pdbName);
         }
@@ -54,6 +56,8 @@ protected void preReadChunk(IncrementalSnapshotContext<TableId> context) {
 
     @Override
     protected void postReadChunk(IncrementalSnapshotContext<TableId> context) {
+        super.postReadChunk(context);
+
         if (pdbName != null) {
             connection.resetSessionToCdb();
         }
@@ -61,6 +65,8 @@ protected void postReadChunk(IncrementalSnapshotContext<TableId> context) {
 
     @Override
     protected void postIncrementalSnapshotCompleted() {
+        super.postIncrementalSnapshotCompleted();
+
         try {
             connection.close();
         }