Prompt
Why is Airbyte failing on schema changes?
Latest observation
Airbyte usually “fails on schema changes” for one of a few common reasons:
1) The source schema changed in a way Airbyte doesn’t auto-handle
Examples:
- A new column was added
- A column was removed
- A column changed type
- Nested JSON structure changed
- A primary key / cursor field changed
Some connectors can detect schema drift and refresh automatically; others require a manual refresh schema or a full reset/re-sync.
2) Destination compatibility issues
Even if the source accepts the change, the destination may not:
- Snowflake/Postgres/BigQuery may reject type changes
- Adding columns may be fine, but dropping/renaming columns can break replication
- Destination tables may have constraints or incompatible types
3) Incremental sync assumptions broke
If the sync is incremental, schema changes can cause issues when:
- The cursor field disappeared or changed type
- Records emitted by the source no longer match the saved stream schema
- The connector is using an old catalog/saved schema
4) The connector is behind or buggy
Some Airbyte connectors are more fragile with schema evolution than others, especially for:
- Custom connectors
- Older source/destination versions
- CDC-based pipelines
- Semi-structured data sources
5) Sync configuration requires manual intervention
Depending on the setup, you may need to:
- Refresh source schema
- Update the stream in the connection
- Reset the stream
- Recreate the connection
- Upgrade the connector version
What to check first
-
Look at the sync logs for the exact error
The message usually tells you whether it’s:- schema mismatch
- invalid type cast
- missing field
- destination rejection
-
Compare source schema vs Airbyte catalog
- Did the source add/rename/remove fields?
- Did field types change?
-
Check whether the destination supports the change
- Especially for type changes and nested fields
-
Try refreshing the schema
- In the Airbyte UI, refresh the source schema for the connection
- Save/update the connection and rerun
-
If needed, reset the affected stream
- This is often required when fields are removed or types changed
Common fixes
- New columns added: refresh schema, then sync
- Column type changed: adjust source data or destination mapping; often requires reset
- Column renamed/removed: create a new stream or reset/rebuild the sync
- Nested JSON changed: flatten upstream or use a compatible destination type
- Stale catalog: re-discover schema and update connection
If you paste the exact Airbyte error log or tell me:
- source connector
- destination
- type of schema change
- whether it’s incremental or full refresh
…I can pinpoint the likely cause and the right fix.