-
Notifications
You must be signed in to change notification settings - Fork 99
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
SNOW-1772187 nultiple columns evolution bug #980
SNOW-1772187 nultiple columns evolution bug #980
Conversation
781f7f4
to
740d52b
Compare
waitForOffset(1); | ||
|
||
// and another record with same schema | ||
service.insert(Collections.singletonList(createKafkaRecord(message, 1, withSchema))); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This insertion works fine. It adds 9 new columns.
rows = describeTable(tableName); | ||
assertThat(rows).hasSize(15); | ||
service.insert(Collections.singletonList(createKafkaRecord(mapRecordJson, 2, false))); | ||
waitForOffset(3); // FAIL |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
However here it fails to ingest data. With error described in Jira
// reinsert record with extra field | ||
service.insert(Collections.singletonList(createKafkaRecord(mapRecordJson, 2, false))); | ||
rows = describeTable(tableName); | ||
assertThat(rows).hasSize(15); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Number of columns is correct. Schema evolution logic altered the table.
Overview
SNOW-1772187
Open the Jira ticket to see a detailed description.
Below test shows the bug.
Pre-review checklist
snowflake.ingestion.method
.Yes
- Added end to end and Unit Tests.No
- Suggest why it is not param protected