From 6e915b7cfd10e444c21e36cf0135bdd8cf5bf15d Mon Sep 17 00:00:00 2001
From: Nathan Mills <rivernate@gmail.com>
Date: Thu, 3 Sep 2020 23:50:34 -0600
Subject: [PATCH] DBZ-2473 Decrement remaining for skipped tables

---
 .../debezium/relational/RelationalSnapshotChangeEventSource.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java b/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java
index 1fbc02c89..7fa31a047 100644
--- a/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java
+++ b/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java
@@ -305,6 +305,7 @@ private void createDataEventsForTable(ChangeEventSourceContext sourceContext, Re
         final Optional<String> selectStatement = determineSnapshotSelect(snapshotContext, table.id());
         if (!selectStatement.isPresent()) {
             LOGGER.warn("For table '{}' the select statement was not provided, skipping table", table.id());
+            snapshotProgressListener.dataCollectionSnapshotCompleted(table.id(), 0);
             return;
         }
         LOGGER.info("\t For table '{}' using select statement: '{}'", table.id(), selectStatement.get());