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

DBZ-5639 Logging enhancement for non-incremental snapshot in postgres connector

Browse Source
This commit is contained in:
harveyyue 2022-09-22 09:00:50 +08:00 committed by Jiri Pechanec
parent bf1e7c89d8
commit 3b4d19c174
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-core/src/main/java/io/debezium/pipeline/source/AbstractSnapshotChangeEventSource.java
View File

@ -89,9 +89,11 @@ public SnapshotResult<O> execute(ChangeEventSourceContext context, P partition,
complete(ctx); complete(ctx);
if (completedSuccessfully) { if (completedSuccessfully) {
LOGGER.info("Snapshot completed");
snapshotProgressListener.snapshotCompleted(partition); snapshotProgressListener.snapshotCompleted(partition);
} }
else { else {
LOGGER.warn("Snapshot uncompleted");
snapshotProgressListener.snapshotAborted(partition); snapshotProgressListener.snapshotAborted(partition);
} }
} }