Hello community, I reported an issue regarding th...
# replication-troubleshooting
l
Hello community, I reported an issue regarding the Connector Builder / Declarative CDK a while ago, and I would heavily appreciate it if someone from the team could take a look, as it severely impacts sync performance. When using
incremental_dependency: true
on parent-child streams, the child stream drops its cursor context after the first sync, forcing the parent stream into an unexpected full refresh loop on subsequent syncs (making them 100x–1000x slower). I just updated the issue with a comprehensive root-cause analysis (assisted by GitHub Copilot and verified against the latest Concurrent CDK source code). I also provided: 1. A functional connector-level workaround using custom components (StateMigration) that anyone can apply today. 2. The exact lines in the CDK core (
substream_partition_router.py
) where the context is being lost. Here is the link to the issue: github.com/airbytehq/airbyte/issues/61567 Could you please help review the proposed architectural fix or provide recommendations to get this merged? Thanks!
🙏 1
f
I'm having a similar issue with some custom connectors in Airbyte Cloud. The connection state gets lost and it keeps retrieving all data from the source, with several issues stemming from this (API rate limits, increased billing).
We are experiencing an intermittent issue where several custom connectors appear to lose their incremental sync state. When this happens, the connectors begin retrieving significantly more data than expected. Expected behavior: The affected streams run hourly and typically ingest only a few hundred new records per sync. Observed behavior: At seemingly random points, the incremental state becomes invalid or is ignored, and the connector starts fetching thousands of records per execution, effectively reprocessing historical data. The issue resolves by updating the connection state. It does not resolve after refreshing data (without deletion). The issue appears to be related to connection state management and/or date cursor handling. Based on our observations: • The problem is intermittent and not reproducible on every sync. • Once it occurs, the saved state appears to point to an incorrect cursor value or is no longer being honored. • Resetting the connection state to a more recent date temporarily mitigates the issue, after which incremental syncs resume behaving normally for a while. • We suspect there may be an issue related to datetime parsing, serialization, or state persistence causing the incremental cursor to become invalid. Impact • Significant increase in API calls. • Unexpected ingestion of historical records. • Increased compute and database load. • Potential duplication and downstream processing overhead.
here are the yaml files for our connectors, we're having issues with the following: • respira_air_gradient.yaml: ◦ Affected stream: Respira_measures_past ◦ Destination: Postgres ◦ Sync frequency: 1 hour • mades_open_data.yaml: ◦ Affected streams: MADES-Open-pm10_data, MADES-Open-pm25_data ◦ Destination: Postgres ◦ Sync frequency: 1 hour