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

DBZ-7347 use identifiers for initial snapshot notifications

Browse Source
This commit is contained in:
Peter Hamer 2024-01-12 15:05:11 +00:00 committed by Fiore Mario Vitale
parent c2eac1714e
commit a4e660f979
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
COPYRIGHT.txt
View File

@ -576,3 +576,4 @@ Don Seiler
Ahmed Rachid Hazourli
Pavithrananda Prabhu
حمود سمبول
Peter Hamer

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

@ -457,7 +457,7 @@ private void createDataEvents(ChangeEventSourceContext sourceContext,
notificationService.initialSnapshotNotificationService().notifyTableInProgress(
snapshotContext.partition,
snapshotContext.offset,
tableId.table(),
tableId.identifier(),
rowCountTables.keySet());
Callable<Void> 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);
}
}

1
jenkins-jobs/scripts/config/Aliases.txt
View File

@ -247,3 +247,4 @@ methodmissing,Lourens Naudé
Prabhu19,Pavithrananda Prabhu
Lourens Naude,Lourens Naudé
overwatcheddude,حمود سمبول
wukachn,Peter Hamer