diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt index 317aa9da1..0ba94f396 100644 --- a/COPYRIGHT.txt +++ b/COPYRIGHT.txt @@ -576,3 +576,4 @@ Don Seiler Ahmed Rachid Hazourli Pavithrananda Prabhu حمود سمبول +Peter Hamer 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 56a25f965..1b3664fb0 100644 --- a/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java +++ b/debezium-core/src/main/java/io/debezium/relational/RelationalSnapshotChangeEventSource.java @@ -457,7 +457,7 @@ private void createDataEvents(ChangeEventSourceContext sourceContext, notificationService.initialSnapshotNotificationService().notifyTableInProgress( snapshotContext.partition, snapshotContext.offset, - tableId.table(), + tableId.identifier(), rowCountTables.keySet()); Callable callable = createDataEventsForTableCallable(sourceContext, snapshotContext, snapshotReceiver, snapshotContext.tables.forTable(tableId), firstTable, lastTable, tableOrder++, tableCount, selectStatement, rowCount, connectionPool, offsets); @@ -589,12 +589,12 @@ private void doCreateDataEventsForTable(ChangeEventSourceContext sourceContext, rows, table.id(), tableOrder, tableCount, Strings.duration(clock.currentTimeInMillis() - exportStart)); snapshotProgressListener.dataCollectionSnapshotCompleted(snapshotContext.partition, table.id(), rows); notificationService.initialSnapshotNotificationService().notifyCompletedTableSuccessfully(snapshotContext.partition, - snapshotContext.offset, table.id().table(), rows, snapshotContext.capturedTables); + snapshotContext.offset, table.id().identifier(), rows, snapshotContext.capturedTables); } catch (SQLException e) { notificationService.initialSnapshotNotificationService().notifyCompletedTableWithError(snapshotContext.partition, snapshotContext.offset, - table.id().table()); + table.id().identifier()); throw new ConnectException("Snapshotting of table " + table.id() + " failed", e); } } diff --git a/jenkins-jobs/scripts/config/Aliases.txt b/jenkins-jobs/scripts/config/Aliases.txt index e4aa79035..3ef75d295 100644 --- a/jenkins-jobs/scripts/config/Aliases.txt +++ b/jenkins-jobs/scripts/config/Aliases.txt @@ -247,3 +247,4 @@ methodmissing,Lourens Naudé Prabhu19,Pavithrananda Prabhu Lourens Naude,Lourens Naudé overwatcheddude,حمود سمبول +wukachn,Peter Hamer