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

Postgres snapshot - On null records, clear prior value from currentRecord

Browse Source
This commit is contained in:
Kevin Pullin 2019-02-01 13:21:28 -08:00 committed by Jiri Pechanec
parent 16620f0bf9
commit 1330df8908
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/RecordsSnapshotProducer.java
View File

@ -367,6 +367,9 @@ private Object valueForColumn(ResultSet rs, int colIdx, ResultSetMetaData metaDa
} }
protected void generateReadRecord(TableId tableId, Object[] rowData) { protected void generateReadRecord(TableId tableId, Object[] rowData) {
// Clear the existing record to prevent reprocessing stale data.
currentRecord.set(null);
if (rowData.length == 0) { if (rowData.length == 0) {
return; return;
} }