[source-custom python connector, destination-snowflake] Records get extracted and loaded but it shows 4 extracted and 1 loaded in case sync fails after extracting and loading 4 records to destination #51030
Unanswered
Kressaa
asked this question in
Connector Questions
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
Custom Connector
Sync Failed During Error
Relevant Information:
sync summary: {
"status" : "cancelled",
"recordsSynced" : 1,
"bytesSynced" : 923,
"startTime" : 1736496009818,
"endTime" : 1736496094459,
"totalStats" : {
"bytesCommitted" : 923,
"bytesEmitted" : 3692,
"destinationStateMessagesEmitted" : 1,
"destinationWriteEndTime" : 0,
"destinationWriteStartTime" : 1736496009823,
"meanSecondsBeforeSourceStateMessageEmitted" : 11,
"maxSecondsBeforeSourceStateMessageEmitted" : 1,
"maxSecondsBetweenStateMessageEmittedandCommitted" : 47,
"meanSecondsBetweenStateMessageEmittedandCommitted" : 47,
"recordsEmitted" : 4,
"recordsCommitted" : 1,
"replicationEndTime" : 1736496094438,
"replicationStartTime" : 1736496009818,
"sourceReadEndTime" : 0,
"sourceReadStartTime" : 1736496009823,
"sourceStateMessagesEmitted" : 4
},
"streamStats" : [ {
"streamName" : "firststate",
"stats" : {
"bytesCommitted" : 923,
"bytesEmitted" : 3692,
"recordsEmitted" : 4,
"recordsCommitted" : 1
}
} ],
"performanceMetrics" : {
"processFromSource" : {
"elapsedTimeInNanos" : 12563125,
Beta Was this translation helpful? Give feedback.
All reactions