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

DBZ-907 Log refreshing schema due to different column count

Browse Source
This commit is contained in:
Jiri Pechanec 2018-09-11 13:56:04 +02:00 committed by Gunnar Morling
parent e20c183d5d
commit 59fbcca725
1 changed files with 2 additions and 1 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/RecordsStreamProducer.java
View File

@ -450,7 +450,8 @@ private boolean schemaChanged(List<ReplicationMessage.Column> columns, Table tab
if (columnNames.size() != messagesCount) {
// the table metadata has less or more columns than the event, which means the table structure has changed,
// so we need to trigger a refresh...
return true;
logger.info("Different column count {} present in the server message as schema in memory contains {}; refreshing table schema", messagesCount, columnNames.size());
return true;
}
// go through the list of columns from the message to figure out if any of them are new or have changed their type based