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

DBZ-1588 Fresh timestamp for each snapshot event

Browse Source
This commit is contained in:
Jiri Pechanec 2019-11-08 14:46:43 +01:00 committed by Chris Cranford
parent 73e1b8f5d8
commit fd62e7d3ef
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/SnapshotReader.java
View File

@ -605,7 +605,7 @@ protected void execute() {
Column actualColumn = table.columns().get(i);
row[i] = readField(rs, j, actualColumn, table);
}
recorder.recordRow(recordMaker, row, ts); // has no row number!
recorder.recordRow(recordMaker, row, clock.currentTimeInMillis()); // has no row number!
rowNum.incrementAndGet();
if (rowNum.get() % 100 == 0 && !isRunning()) {
// We've stopped running ...