alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2473 Decrement remaining for skipped tables

Browse Source
This commit is contained in:
Nathan Mills 2020-09-03 23:50:34 -06:00 committed by GitHub
parent b4cc6a141e
commit 6e915b7cfd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java
View File

@ -305,6 +305,7 @@ private void createDataEventsForTable(ChangeEventSourceContext sourceContext, Re
final Optional<String> selectStatement = determineSnapshotSelect(snapshotContext, table.id()); final Optional<String> selectStatement = determineSnapshotSelect(snapshotContext, table.id());
if (!selectStatement.isPresent()) { if (!selectStatement.isPresent()) {
LOGGER.warn("For table '{}' the select statement was not provided, skipping table", table.id()); LOGGER.warn("For table '{}' the select statement was not provided, skipping table", table.id());
snapshotProgressListener.dataCollectionSnapshotCompleted(table.id(), 0);
return; return;
} }
LOGGER.info("\t For table '{}' using select statement: '{}'", table.id(), selectStatement.get()); LOGGER.info("\t For table '{}' using select statement: '{}'", table.id(), selectStatement.get());