[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
-
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