In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.

Bug report

For bug reports, provide this information, please:

What Debezium connector do you use and what version?

2.4.0

What is the connector configuration?

(a bit long)

2024-03-26 18:38:48 source > INFO pool-7-thread-1 o.a.k.c.s.FileOffsetBackingStore(start):63 Starting FileOffsetBackingStore with file /tmp/cdc-state-offset17390316876795578091/offset.dat
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(start):136 Starting MySqlConnectorTask with configuration:"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(start):136 Starting MySqlConnectorTask with configuration:
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    connector.class = io.debezium.connector.mysql.MySqlConnector"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    connector.class = io.debezium.connector.mysql.MySqlConnector
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    snapshot.locking.mode = none"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    snapshot.locking.mode = none
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    max.queue.size = 8192"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    max.queue.size = 8192
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    include.schema.changes = false"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    include.schema.changes = false
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    schema.history.internal.store.only.captured.databases.ddl = true"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    schema.history.internal.store.only.captured.databases.ddl = true
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    schema.history.internal.file.filename = /tmp/cdc-db-history16452139674924282602/dbhistory.dat"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    schema.history.internal.file.filename = /tmp/cdc-db-history16452139674924282602/dbhistory.dat
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    topic.prefix = dispatch"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    topic.prefix = dispatch
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    binary.handling.mode = base64"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    binary.handling.mode = base64
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.storage.file.filename = /tmp/cdc-state-offset17390316876795578091/offset.dat"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.storage.file.filename = /tmp/cdc-state-offset17390316876795578091/offset.dat
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    decimal.handling.mode = string"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    decimal.handling.mode = string
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    converters = boolean, datetime"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    converters = boolean, datetime
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    errors.retry.delay.initial.ms = 299"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    errors.retry.delay.initial.ms = 299
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    datetime.type = io.airbyte.integrations.source.mysql.cdc.MySQLDateTimeConverter"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    datetime.type = io.airbyte.integrations.source.mysql.cdc.MySQLDateTimeConverter
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    value.converter = org.apache.kafka.connect.json.JsonConverter"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    value.converter = org.apache.kafka.connect.json.JsonConverter
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    key.converter = org.apache.kafka.connect.json.JsonConverter"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    key.converter = org.apache.kafka.connect.json.JsonConverter
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.user = snowflake_agent"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.user = snowflake_agent
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.dbname = dispatch"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.dbname = dispatch
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.server.id = 5783"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.server.id = 5783
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    max.queue.size.in.bytes = 268435456"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    max.queue.size.in.bytes = 268435456
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    boolean.type = io.airbyte.integrations.source.mysql.cdc.CustomMySQLTinyIntOneToBooleanConverter"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    boolean.type = io.airbyte.integrations.source.mysql.cdc.CustomMySQLTinyIntOneToBooleanConverter
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    errors.retry.delay.max.ms = 300"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    errors.retry.delay.max.ms = 300
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.flush.timeout.ms = 5000"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.flush.timeout.ms = 5000
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    heartbeat.interval.ms = 10000"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    heartbeat.interval.ms = 10000
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    column.include.list = \\Qdispatch.ref_region\\E\\.(\\Qname\\E|\\Qstate\\E|\\Qactive\\E|\\Qlocale\\E|\\QtopLat\\E|\\Qcountry\\E|\\QleftLon\\E|\\Qprivate\\E|\\QregionId\\E|\\QrightLon\\E|\\Qstandard\\E|\\QtimeZone\\E|\\QbottomLat\\E|\\QcenterLat\\E|\\QcenterLon\\E|\\QregionCode\\E|\\QdistanceUnit\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\QisManagedRegion\\E|\\QowningCompanyId\\E|\\Qtimezone_offset\\E|\\Q_ab_cdc_log_file\\E|\\Qrelease_untracked\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QphoneNumberCountryCode\\E),\\Qdispatch.ims_auction\\E\\.(\\Qid\\E|\\Qactive\\E|\\QregionId\\E|\\QcompanyId\\E|\\QauctionDate\\E|\\QtrackChanges\\E|\\QfreezeChanges\\E|\\Q_ab_cdc_cursor\\E|\\QauctionEndDate\\E|\\Q_ab_cdc_log_pos\\E|\\QpubliclyVisible\\E|\\QsaleChannelType\\E|\\Q_ab_cdc_log_file\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QpublishedToJoyride\\E|\\QexternalOnlineAuctionId\\E),\\Qdispatch.ims_fee_event_type\\E\\.(\\Qname\\E|\\Qenumcode\\E|\\QreceiptType\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QlastModifiedDate\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ppi_ppi_vehicle\\E\\.(\\Qid\\E|\\Qvin\\E|\\Qrepo\\E|\\Qnotes\\E|\\QbodyId\\E|\\Qdriver\\E|\\QmakeId\\E|\\Qstatus\\E|\\QcolorId\\E|\\Qlicense\\E|\\QmodelId\\E|\\QnoPlate\\E|\\QtowDate\\E|\\QdriverId\\E|\\QregionId\\E|\\QvehicleId\\E|\\QlienHolder\\E|\\QppiCompany\\E|\\QreportDate\\E|\\QrequestedBy\\E|\\QvehicleYear\\E|\\QlicenseState\\E|\\QpropertyName\\E|\\QvehicleOwner\\E|\\QtowOriginCity\\E|\\Q_ab_cdc_cursor\\E|\\QnonStandardVin\\E|\\QtowOriginAddr1\\E|\\QtowOriginAddr2\\E|\\QtowOriginAddr3\\E|\\QtowOriginState\\E|\\Q_ab_cdc_log_pos\\E|\\QlienHolderPhone\\E|\\Q_ab_cdc_log_file\\E|\\QtowOriginZipcode\\E|\\QworkStationToken\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QtowDestinationCity\\E|\\QtowDestinationAddr1\\E|\\QtowDestinationAddr2\\E|\\QtowDestinationAddr3\\E|\\QtowDestinationState\\E|\\QlawEnforcementAgency\\E|\\QtotalFraudProbability\\E|\\QtowDestinationZipcode\\E|\\QimpoundReferenceNumber\\E|\\QppiCompanyRepresentative\\E|\\QunknownRepFraudProbability\\E|\\QtooSoonReportFraudProbability\\E|\\QtooManyReportsFraudProbability\\E|\\QunknownCompanyFraudProbability\\E|\\QnotGeocodedAddressFraudProbability\\E|\\QunapprovedWorkstationFraudProbability\\E),\\Qdispatch.ppi_ppi_tow_company\\E\\.(\\Qid\\E|\\Qname\\E|\\QregionId\\E|\\QphoneNumber\\E|\\QlastKnownAddr\\E|\\QlastKnownCity\\E|\\Q_ab_cdc_cursor\\E|\\QlastReportDate\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QlastKnownStateId\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QlastKnownRepresentative\\E),\\Qdispatch.ims_fee\\E\\.(\\Qid\\E|\\Qcode\\E|\\Qname\\E|\\Qactive\\E|\\QregionId\\E|\\QpriceType\\E|\\QreceiptRole\\E|\\Q_ab_cdc_cursor\\E|\\QmaxManualCount\\E|\\QwaiverCategory\\E|\\Q_ab_cdc_log_pos\\E|\\QaccountingGroup\\E|\\QfeeTypeEnumCode\\E|\\QnegativeAllowed\\E|\\Q_ab_cdc_log_file\\E|\\QlastModifiedDate\\E|\\QnegativeRequired\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QfeeCategoryEnumCode\\E|\\QfeeEventTypeEnumCode\\E),\\Qdispatch.ref_lot\\E\\.(\\Qid\\E|\\Qcode\\E|\\Qname\\E|\\Qphone\\E|\\Qactive\\E|\\QzoneId\\E|\\QlotType\\E|\\QcompanyId\\E|\\QextraInfo\\E|\\QlocationId\\E|\\QserviceAddr\\E|\\QserviceCity\\E|\\QaccrueStorage\\E|\\QregionDefault\\E|\\Q_ab_cdc_cursor\\E|\\QtwoStepRelease\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QimpoundLicenseNumber\\E|\\QcashierSupervisorEmail\\E|\\QexcludeFromClosestDispatch\\E),\\Qdispatch.ads_tow\\E\\.(\\Qnotes\\E|\\QtowId\\E|\\QbeatId\\E|\\QholdId\\E|\\QzoneId\\E|\\Qversion\\E|\\QdrNumber\\E|\\QreasonId\\E|\\QregionId\\E|\\Qexpedited\\E|\\QtowStatus\\E|\\QvehicleId\\E|\\QcometTowId\\E|\\QcreateUser\\E|\\Qcreatedate\\E|\\QcustomerId\\E|\\QisPractice\\E|\\Qupdatedate\\E|\\QbadgeNumber\\E|\\QequipmentId\\E|\\QlatestEtaId\\E|\\QnotesDriver\\E|\\QphoneNumber\\E|\\QimsVehicleId\\E|\\Qresponsetime\\E|\\QspecialEvent\\E|\\QdriverShiftId\\E|\\QdynamicField1\\E|\\QdynamicField2\\E|\\QdynamicField3\\E|\\QdynamicField4\\E|\\Q_ab_cdc_cursor\\E|\\QprocessingInfo\\E|\\Q_ab_cdc_log_pos\\E|\\QcurrentDriverId\\E|\\QimsSubmitStatus\\E|\\QisCreatedByCity\\E|\\QsecondVehicleId\\E|\\Q_ab_cdc_log_file\\E|\\QimsSubmitMessage\\E|\\QisStandardOrigin\\E|\\QoriginLocationId\\E|\\QresponseBaseTime\\E|\\QfollowUpAlertTime\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QextensionRequestId\\E|\\QexternalProperties\\E|\\QisFlatbedRequested\\E|\\QfollowUpAlertMessage\\E|\\QdestinationLocationId\\E|\\QrequestedTowCompanyId\\E|\\QresponseTimeDeltaSecs\\E|\\QautodispatchFailReason\\E|\\QcalculatedDestinationId\\E|\\QdistanceAcceptedToOrigin\\E|\\QdriverShiftRedispatchedId\\E),\\Qdispatch.ims_fee_group\\E\\.(\\Qid\\E|\\Qname\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QlastModifiedDate\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ims_auction_vehicle\\E\\.(\\Qid\\E|\\Qstatus\\E|\\Qsequence\\E|\\QauctionId\\E|\\QvehicleId\\E|\\QauctionFee\\E|\\QcreateDate\\E|\\QreservedPrice\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QextraChargeTypeId\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QauctionFeeDescription\\E),\\Qdispatch.ims_hold\\E\\.(\\Qid\\E|\\QsetBy\\E|\\QdateTo\\E|\\QisVoid\\E|\\QsetTime\\E|\\QdateFrom\\E|\\QremovedBy\\E|\\QvehicleId\\E|\\QholdTypeId\\E|\\QreleasedBy\\E|\\QvoidReason\\E|\\QholdDetails\\E|\\QisAutomatic\\E|\\QremovedTime\\E|\\QrequestedBy\\E|\\QholdAgencyId\\E|\\QdynamicField1\\E|\\QdynamicField2\\E|\\QholdForUnitId\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QlastModifiedDate\\E|\\QrequestedByPhone\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QreleaseInstructions\\E|\\QscheduledReviewDate\\E),\\Qdispatch.ims_fee_category\\E\\.(\\Qname\\E|\\Qenumcode\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QlastModifiedDate\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ads_vehicle\\E\\.(\\Qvin\\E|\\QbodyId\\E|\\QmakeId\\E|\\QcolorId\\E|\\Qlicense\\E|\\QmodelId\\E|\\QnoPlate\\E|\\QstateId\\E|\\QcustomId\\E|\\QvehicleId\\E|\\Qcreatedate\\E|\\Qupdatedate\\E|\\QvehicleYear\\E|\\QdynamicField1\\E|\\QdynamicField2\\E|\\QdynamicField3\\E|\\QdynamicField4\\E|\\Q_ab_cdc_cursor\\E|\\QlicenseTagYear\\E|\\Q_ab_cdc_log_pos\\E|\\QlicenseTagMonth\\E|\\Q_ab_cdc_log_file\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ppi_ppi_file\\E\\.(\\Qid\\E|\\QattachmentId\\E|\\QppiVehicleId\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QregistrationDate\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ims_access_pass\\E\\.(\\Qid\\E|\\QlotId\\E|\\QisVoid\\E|\\QregionId\\E|\\QviewOnly\\E|\\QcontactId\\E|\\QvehicleId\\E|\\QariesUserId\\E|\\QdateCreated\\E|\\Qdescription\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\QpropertyRemoval\\E|\\Q_ab_cdc_log_file\\E|\\QinsuranceAdjuster\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QregistrationDocuments\\E|\\QpersonalIdentification\\E),\\Qdispatch.ads_round_robin_company_turn\\E\\.(\\Qid\\E|\\QtowId\\E|\\QusedSlot\\E|\\QtowCompanyId\\E|\\QturnDateTime\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\QturnDescription\\E|\\Q_ab_cdc_log_file\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QroundRobinCompanySequenceId\\E),\\Qdispatch.ims_vehicle\\E\\.(\\Qid\\E|\\Qbid\\E|\\Qvin\\E|\\QbeatId\\E|\\QbodyId\\E|\\QlienId\\E|\\QmakeId\\E|\\Qweight\\E|\\QzoneId\\E|\\QcolorId\\E|\\Qlicense\\E|\\QmodelId\\E|\\QnoPlate\\E|\\QtruckId\\E|\\Qversion\\E|\\QbidderId\\E|\\QbuyerFee\\E|\\QengineId\\E|\\Qodometer\\E|\\QreasonId\\E|\\QregionId\\E|\\QsaleDate\\E|\\QsaleType\\E|\\QsoldToId\\E|\\QaccountId\\E|\\QimpoundId\\E|\\QinTowDate\\E|\\QkeyStatus\\E|\\QofficerId\\E|\\QsalePrice\\E|\\QstartCode\\E|\\QdriverName\\E|\\QonsiteDate\\E|\\QreleasedOn\\E|\\QsearchDate\\E|\\QclearedDate\\E|\\QdroppedDate\\E|\\QequipmentId\\E|\\QlicenseDtmf\\E|\\QlicenseType\\E|\\QofficerName\\E|\\QplatformFee\\E|\\QreleaseDate\\E|\\QtitleNumber\\E|\\QvehicleYear\\E|\\QvinReversed\\E|\\QacceptedDate\\E|\\QadsVehicleId\\E|\\QcurrentLotId\\E|\\QdriveTrainId\\E|\\QnumCylinders\\E|\\QpoliceCaseId\\E|\\QreleasedById\\E|\\QresponseDate\\E|\\QspecialEvent\\E|\\QalternativeId\\E|\\QcancelledDate\\E|\\QdepositAmount\\E|\\QdiscrepancyId\\E|\\QfullTextField\\E|\\QimpoundStatus\\E|\\QrequestedById\\E|\\QrequestedDate\\E|\\QtowAwayZoneId\\E|\\QtowOperatorId\\E|\\QtowOriginCity\\E|\\Q_ab_cdc_cursor\\E|\\QdispatchedDate\\E|\\QlicenseStateId\\E|\\QlicenseTagYear\\E|\\QrepeatOffender\\E|\\QtowOriginAddr1\\E|\\QtowOriginAddr2\\E|\\QtowOriginAddr3\\E|\\QtowOriginState\\E|\\QtransmissionId\\E|\\Q_ab_cdc_log_pos\\E|\\QexternalSaleTax\\E|\\QfirstStoredDate\\E|\\QidFullTextField\\E|\\QimportVehicleId\\E|\\QlicenseReversed\\E|\\QlicenseTagMonth\\E|\\QrequestedByName\\E|\\QsaleChannelType\\E|\\QvehicleContents\\E|\\QvehicleDriverId\\E|\\Q_ab_cdc_log_file\\E|\\QisNonStandardVin\\E|\\QisRepeatOffender\\E|\\QlastModifiedDate\\E|\\QpatrolUnitNumber\\E|\\QpoliceCitationId\\E|\\QrequestedByPhone\\E|\\QtowDynamicField1\\E|\\QtowDynamicField2\\E|\\QtowDynamicField3\\E|\\QtowDynamicField4\\E|\\QtowOriginZipcode\\E|\\QignoreDiscrepancy\\E|\\QvehicleConditions\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QbillableKilometers\\E|\\QclearTruckOdometer\\E|\\QexternalStorageTax\\E|\\QforceOnlinePayment\\E|\\QinTowTruckOdometer\\E|\\QtowDestinationCity\\E|\\QtowReferenceNumber\\E|\\QonSiteTruckOdometer\\E|\\QreleaseAuthorizedOn\\E|\\QtowDestinationAddr1\\E|\\QtowDestinationAddr2\\E|\\QtowDestinationAddr3\\E|\\QtowDestinationState\\E|\\QvehicleClassEnumCode\\E|\\QvehicleDynamicField1\\E|\\QvehicleDynamicField2\\E|\\QvehicleDynamicField3\\E|\\QvehicleDynamicField4\\E|\\QacceptedTruckOdometer\\E|\\QreleaseAuthorizedById\\E|\\QreleaseAuthorizedFrom\\E|\\QtowDestinationZipcode\\E|\\QimpoundReferenceNumber\\E|\\QauctionExternalProvider\\E|\\QcurrentImpoundOperatorId\\E|\\QlastHourStorageFeeReason\\E|\\QreleaseAuthorizedThrough\\E|\\QreleaseAuthorizationChangeReason\\E),\\Qdispatch.ims_fee_event\\E\\.(\\Qid\\E|\\QholdId\\E|\\QuserId\\E|\\QwaiverId\\E|\\QstorageId\\E|\\QvehicleId\\E|\\QtransferId\\E|\\QaccessPassId\\E|\\QfeeEventDate\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QimpoundOperatorId\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QfeeEventTypeEnumCode\\E|\\QwaiverResponsiblePartyId\\E),\\Qdispatch.ims_fee_price\\E\\.(\\Qid\\E|\\QfeeId\\E|\\Qlotid\\E|\\Qprice\\E|\\QtaxRate\\E|\\QbillingPrice\\E|\\QfeeScheduleId\\E|\\Q_ab_cdc_cursor\\E|\\QbillingTaxRate\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QlastModifiedDate\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ims_fee_item\\E\\.(\\Qid\\E|\\QfeeId\\E|\\QtaxRate\\E|\\QunitTax\\E|\\QtotalTax\\E|\\QpriceType\\E|\\Qpricedate\\E|\\QunitPrice\\E|\\QfeeEventId\\E|\\QtotalPrice\\E|\\QunitsCount\\E|\\QcreatedDate\\E|\\Q_ab_cdc_cursor\\E|\\QbillingTaxRate\\E|\\QunitBillingTax\\E|\\Q_ab_cdc_log_pos\\E|\\QpostedReceiptId\\E|\\QtotalBillingTax\\E|\\Q_ab_cdc_log_file\\E|\\QlastModifiedDate\\E|\\QtotalPricePretax\\E|\\QunitBillingPrice\\E|\\QtotalBillingPrice\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E|\\QtotalBillingPricePretax\\E),\\Qdispatch.ads_round_robin_company_sequence\\E\\.(\\Qid\\E|\\Qactive\\E|\\QzoneId\\E|\\QequipmentId\\E|\\QlastUsedSlot\\E|\\QroundRobinKey\\E|\\QstartDateTime\\E|\\Q_ab_cdc_cursor\\E|\\QroundRobinPath\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\QroundRobinParams\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ads_hold\\E\\.(\\QsetBy\\E|\\QholdId\\E|\\Qcomment\\E|\\Qcreatedate\\E|\\QholdTypeId\\E|\\Qupdatedate\\E|\\QholdAgencyId\\E|\\QdynamicField1\\E|\\QdynamicField2\\E|\\QholdForUnitId\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at\\E),\\Qdispatch.ref_lot_region\\E\\.(\\QlotId\\E|\\QregionId\\E|\\Q_ab_cdc_cursor\\E|\\Q_ab_cdc_log_pos\\E|\\Q_ab_cdc_log_file\\E|\\Q_ab_cdc_deleted_at\\E|\\Q_ab_cdc_updated_at
E)"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    column.include.list = \Qdispatch.ref_region\E\.(\Qname\E|\Qstate\E|\Qactive\E|\Qlocale\E|\QtopLat\E|\Qcountry\E|\QleftLon\E|\Qprivate\E|\QregionId\E|\QrightLon\E|\Qstandard\E|\QtimeZone\E|\QbottomLat\E|\QcenterLat\E|\QcenterLon\E|\QregionCode\E|\QdistanceUnit\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\QisManagedRegion\E|\QowningCompanyId\E|\Qtimezone_offset\E|\Q_ab_cdc_log_file\E|\Qrelease_untracked\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QphoneNumberCountryCode\E),\Qdispatch.ims_auction\E\.(\Qid\E|\Qactive\E|\QregionId\E|\QcompanyId\E|\QauctionDate\E|\QtrackChanges\E|\QfreezeChanges\E|\Q_ab_cdc_cursor\E|\QauctionEndDate\E|\Q_ab_cdc_log_pos\E|\QpubliclyVisible\E|\QsaleChannelType\E|\Q_ab_cdc_log_file\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QpublishedToJoyride\E|\QexternalOnlineAuctionId\E),\Qdispatch.ims_fee_event_type\E\.(\Qname\E|\Qenumcode\E|\QreceiptType\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QlastModifiedDate\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ppi_ppi_vehicle\E\.(\Qid\E|\Qvin\E|\Qrepo\E|\Qnotes\E|\QbodyId\E|\Qdriver\E|\QmakeId\E|\Qstatus\E|\QcolorId\E|\Qlicense\E|\QmodelId\E|\QnoPlate\E|\QtowDate\E|\QdriverId\E|\QregionId\E|\QvehicleId\E|\QlienHolder\E|\QppiCompany\E|\QreportDate\E|\QrequestedBy\E|\QvehicleYear\E|\QlicenseState\E|\QpropertyName\E|\QvehicleOwner\E|\QtowOriginCity\E|\Q_ab_cdc_cursor\E|\QnonStandardVin\E|\QtowOriginAddr1\E|\QtowOriginAddr2\E|\QtowOriginAddr3\E|\QtowOriginState\E|\Q_ab_cdc_log_pos\E|\QlienHolderPhone\E|\Q_ab_cdc_log_file\E|\QtowOriginZipcode\E|\QworkStationToken\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QtowDestinationCity\E|\QtowDestinationAddr1\E|\QtowDestinationAddr2\E|\QtowDestinationAddr3\E|\QtowDestinationState\E|\QlawEnforcementAgency\E|\QtotalFraudProbability\E|\QtowDestinationZipcode\E|\QimpoundReferenceNumber\E|\QppiCompanyRepresentative\E|\QunknownRepFraudProbability\E|\QtooSoonReportFraudProbability\E|\QtooManyReportsFraudProbability\E|\QunknownCompanyFraudProbability\E|\QnotGeocodedAddressFraudProbability\E|\QunapprovedWorkstationFraudProbability\E),\Qdispatch.ppi_ppi_tow_company\E\.(\Qid\E|\Qname\E|\QregionId\E|\QphoneNumber\E|\QlastKnownAddr\E|\QlastKnownCity\E|\Q_ab_cdc_cursor\E|\QlastReportDate\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QlastKnownStateId\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QlastKnownRepresentative\E),\Qdispatch.ims_fee\E\.(\Qid\E|\Qcode\E|\Qname\E|\Qactive\E|\QregionId\E|\QpriceType\E|\QreceiptRole\E|\Q_ab_cdc_cursor\E|\QmaxManualCount\E|\QwaiverCategory\E|\Q_ab_cdc_log_pos\E|\QaccountingGroup\E|\QfeeTypeEnumCode\E|\QnegativeAllowed\E|\Q_ab_cdc_log_file\E|\QlastModifiedDate\E|\QnegativeRequired\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QfeeCategoryEnumCode\E|\QfeeEventTypeEnumCode\E),\Qdispatch.ref_lot\E\.(\Qid\E|\Qcode\E|\Qname\E|\Qphone\E|\Qactive\E|\QzoneId\E|\QlotType\E|\QcompanyId\E|\QextraInfo\E|\QlocationId\E|\QserviceAddr\E|\QserviceCity\E|\QaccrueStorage\E|\QregionDefault\E|\Q_ab_cdc_cursor\E|\QtwoStepRelease\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QimpoundLicenseNumber\E|\QcashierSupervisorEmail\E|\QexcludeFromClosestDispatch\E),\Qdispatch.ads_tow\E\.(\Qnotes\E|\QtowId\E|\QbeatId\E|\QholdId\E|\QzoneId\E|\Qversion\E|\QdrNumber\E|\QreasonId\E|\QregionId\E|\Qexpedited\E|\QtowStatus\E|\QvehicleId\E|\QcometTowId\E|\QcreateUser\E|\Qcreatedate\E|\QcustomerId\E|\QisPractice\E|\Qupdatedate\E|\QbadgeNumber\E|\QequipmentId\E|\QlatestEtaId\E|\QnotesDriver\E|\QphoneNumber\E|\QimsVehicleId\E|\Qresponsetime\E|\QspecialEvent\E|\QdriverShiftId\E|\QdynamicField1\E|\QdynamicField2\E|\QdynamicField3\E|\QdynamicField4\E|\Q_ab_cdc_cursor\E|\QprocessingInfo\E|\Q_ab_cdc_log_pos\E|\QcurrentDriverId\E|\QimsSubmitStatus\E|\QisCreatedByCity\E|\QsecondVehicleId\E|\Q_ab_cdc_log_file\E|\QimsSubmitMessage\E|\QisStandardOrigin\E|\QoriginLocationId\E|\QresponseBaseTime\E|\QfollowUpAlertTime\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QextensionRequestId\E|\QexternalProperties\E|\QisFlatbedRequested\E|\QfollowUpAlertMessage\E|\QdestinationLocationId\E|\QrequestedTowCompanyId\E|\QresponseTimeDeltaSecs\E|\QautodispatchFailReason\E|\QcalculatedDestinationId\E|\QdistanceAcceptedToOrigin\E|\QdriverShiftRedispatchedId\E),\Qdispatch.ims_fee_group\E\.(\Qid\E|\Qname\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QlastModifiedDate\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ims_auction_vehicle\E\.(\Qid\E|\Qstatus\E|\Qsequence\E|\QauctionId\E|\QvehicleId\E|\QauctionFee\E|\QcreateDate\E|\QreservedPrice\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QextraChargeTypeId\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QauctionFeeDescription\E),\Qdispatch.ims_hold\E\.(\Qid\E|\QsetBy\E|\QdateTo\E|\QisVoid\E|\QsetTime\E|\QdateFrom\E|\QremovedBy\E|\QvehicleId\E|\QholdTypeId\E|\QreleasedBy\E|\QvoidReason\E|\QholdDetails\E|\QisAutomatic\E|\QremovedTime\E|\QrequestedBy\E|\QholdAgencyId\E|\QdynamicField1\E|\QdynamicField2\E|\QholdForUnitId\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QlastModifiedDate\E|\QrequestedByPhone\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QreleaseInstructions\E|\QscheduledReviewDate\E),\Qdispatch.ims_fee_category\E\.(\Qname\E|\Qenumcode\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QlastModifiedDate\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ads_vehicle\E\.(\Qvin\E|\QbodyId\E|\QmakeId\E|\QcolorId\E|\Qlicense\E|\QmodelId\E|\QnoPlate\E|\QstateId\E|\QcustomId\E|\QvehicleId\E|\Qcreatedate\E|\Qupdatedate\E|\QvehicleYear\E|\QdynamicField1\E|\QdynamicField2\E|\QdynamicField3\E|\QdynamicField4\E|\Q_ab_cdc_cursor\E|\QlicenseTagYear\E|\Q_ab_cdc_log_pos\E|\QlicenseTagMonth\E|\Q_ab_cdc_log_file\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ppi_ppi_file\E\.(\Qid\E|\QattachmentId\E|\QppiVehicleId\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QregistrationDate\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ims_access_pass\E\.(\Qid\E|\QlotId\E|\QisVoid\E|\QregionId\E|\QviewOnly\E|\QcontactId\E|\QvehicleId\E|\QariesUserId\E|\QdateCreated\E|\Qdescription\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\QpropertyRemoval\E|\Q_ab_cdc_log_file\E|\QinsuranceAdjuster\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QregistrationDocuments\E|\QpersonalIdentification\E),\Qdispatch.ads_round_robin_company_turn\E\.(\Qid\E|\QtowId\E|\QusedSlot\E|\QtowCompanyId\E|\QturnDateTime\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\QturnDescription\E|\Q_ab_cdc_log_file\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QroundRobinCompanySequenceId\E),\Qdispatch.ims_vehicle\E\.(\Qid\E|\Qbid\E|\Qvin\E|\QbeatId\E|\QbodyId\E|\QlienId\E|\QmakeId\E|\Qweight\E|\QzoneId\E|\QcolorId\E|\Qlicense\E|\QmodelId\E|\QnoPlate\E|\QtruckId\E|\Qversion\E|\QbidderId\E|\QbuyerFee\E|\QengineId\E|\Qodometer\E|\QreasonId\E|\QregionId\E|\QsaleDate\E|\QsaleType\E|\QsoldToId\E|\QaccountId\E|\QimpoundId\E|\QinTowDate\E|\QkeyStatus\E|\QofficerId\E|\QsalePrice\E|\QstartCode\E|\QdriverName\E|\QonsiteDate\E|\QreleasedOn\E|\QsearchDate\E|\QclearedDate\E|\QdroppedDate\E|\QequipmentId\E|\QlicenseDtmf\E|\QlicenseType\E|\QofficerName\E|\QplatformFee\E|\QreleaseDate\E|\QtitleNumber\E|\QvehicleYear\E|\QvinReversed\E|\QacceptedDate\E|\QadsVehicleId\E|\QcurrentLotId\E|\QdriveTrainId\E|\QnumCylinders\E|\QpoliceCaseId\E|\QreleasedById\E|\QresponseDate\E|\QspecialEvent\E|\QalternativeId\E|\QcancelledDate\E|\QdepositAmount\E|\QdiscrepancyId\E|\QfullTextField\E|\QimpoundStatus\E|\QrequestedById\E|\QrequestedDate\E|\QtowAwayZoneId\E|\QtowOperatorId\E|\QtowOriginCity\E|\Q_ab_cdc_cursor\E|\QdispatchedDate\E|\QlicenseStateId\E|\QlicenseTagYear\E|\QrepeatOffender\E|\QtowOriginAddr1\E|\QtowOriginAddr2\E|\QtowOriginAddr3\E|\QtowOriginState\E|\QtransmissionId\E|\Q_ab_cdc_log_pos\E|\QexternalSaleTax\E|\QfirstStoredDate\E|\QidFullTextField\E|\QimportVehicleId\E|\QlicenseReversed\E|\QlicenseTagMonth\E|\QrequestedByName\E|\QsaleChannelType\E|\QvehicleContents\E|\QvehicleDriverId\E|\Q_ab_cdc_log_file\E|\QisNonStandardVin\E|\QisRepeatOffender\E|\QlastModifiedDate\E|\QpatrolUnitNumber\E|\QpoliceCitationId\E|\QrequestedByPhone\E|\QtowDynamicField1\E|\QtowDynamicField2\E|\QtowDynamicField3\E|\QtowDynamicField4\E|\QtowOriginZipcode\E|\QignoreDiscrepancy\E|\QvehicleConditions\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QbillableKilometers\E|\QclearTruckOdometer\E|\QexternalStorageTax\E|\QforceOnlinePayment\E|\QinTowTruckOdometer\E|\QtowDestinationCity\E|\QtowReferenceNumber\E|\QonSiteTruckOdometer\E|\QreleaseAuthorizedOn\E|\QtowDestinationAddr1\E|\QtowDestinationAddr2\E|\QtowDestinationAddr3\E|\QtowDestinationState\E|\QvehicleClassEnumCode\E|\QvehicleDynamicField1\E|\QvehicleDynamicField2\E|\QvehicleDynamicField3\E|\QvehicleDynamicField4\E|\QacceptedTruckOdometer\E|\QreleaseAuthorizedById\E|\QreleaseAuthorizedFrom\E|\QtowDestinationZipcode\E|\QimpoundReferenceNumber\E|\QauctionExternalProvider\E|\QcurrentImpoundOperatorId\E|\QlastHourStorageFeeReason\E|\QreleaseAuthorizedThrough\E|\QreleaseAuthorizationChangeReason\E),\Qdispatch.ims_fee_event\E\.(\Qid\E|\QholdId\E|\QuserId\E|\QwaiverId\E|\QstorageId\E|\QvehicleId\E|\QtransferId\E|\QaccessPassId\E|\QfeeEventDate\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QimpoundOperatorId\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QfeeEventTypeEnumCode\E|\QwaiverResponsiblePartyId\E),\Qdispatch.ims_fee_price\E\.(\Qid\E|\QfeeId\E|\Qlotid\E|\Qprice\E|\QtaxRate\E|\QbillingPrice\E|\QfeeScheduleId\E|\Q_ab_cdc_cursor\E|\QbillingTaxRate\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QlastModifiedDate\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ims_fee_item\E\.(\Qid\E|\QfeeId\E|\QtaxRate\E|\QunitTax\E|\QtotalTax\E|\QpriceType\E|\Qpricedate\E|\QunitPrice\E|\QfeeEventId\E|\QtotalPrice\E|\QunitsCount\E|\QcreatedDate\E|\Q_ab_cdc_cursor\E|\QbillingTaxRate\E|\QunitBillingTax\E|\Q_ab_cdc_log_pos\E|\QpostedReceiptId\E|\QtotalBillingTax\E|\Q_ab_cdc_log_file\E|\QlastModifiedDate\E|\QtotalPricePretax\E|\QunitBillingPrice\E|\QtotalBillingPrice\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E|\QtotalBillingPricePretax\E),\Qdispatch.ads_round_robin_company_sequence\E\.(\Qid\E|\Qactive\E|\QzoneId\E|\QequipmentId\E|\QlastUsedSlot\E|\QroundRobinKey\E|\QstartDateTime\E|\Q_ab_cdc_cursor\E|\QroundRobinPath\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\QroundRobinParams\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ads_hold\E\.(\QsetBy\E|\QholdId\E|\Qcomment\E|\Qcreatedate\E|\QholdTypeId\E|\Qupdatedate\E|\QholdAgencyId\E|\QdynamicField1\E|\QdynamicField2\E|\QholdForUnitId\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E),\Qdispatch.ref_lot_region\E\.(\QlotId\E|\QregionId\E|\Q_ab_cdc_cursor\E|\Q_ab_cdc_log_pos\E|\Q_ab_cdc_log_file\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_updated_at\E)
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.port = 3306"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.port = 3306
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.flush.interval.ms = 1000"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    offset.flush.interval.ms = 1000
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    key.converter.schemas.enable = false"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    key.converter.schemas.enable = false
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.ssl.mode = REQUIRED"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.ssl.mode = REQUIRED
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    schema.history.internal = io.debezium.storage.file.history.FileSchemaHistory"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    schema.history.internal = io.debezium.storage.file.history.FileSchemaHistory
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    errors.max.retries = 0"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    errors.max.retries = 0
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.hostname = prod-aurora-east-cluster.cluster-cv58neyhh56r.us-gov-east-1.rds.amazonaws.com"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.hostname = prod-aurora-east-cluster.cluster-cv58neyhh56r.us-gov-east-1.rds.amazonaws.com
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.password = ********"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.password = ********
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    value.converter.schemas.enable = false"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    value.converter.schemas.enable = false
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    name = dispatch"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    name = dispatch
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    max.batch.size = 2048"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    max.batch.size = 2048
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    table.include.list = \\Qdispatch.ref_region\\E,\\Qdispatch.ims_auction\\E,\\Qdispatch.ims_fee_event_type\\E,\\Qdispatch.ppi_ppi_vehicle\\E,\\Qdispatch.ppi_ppi_tow_company\\E,\\Qdispatch.ims_fee\\E,\\Qdispatch.ref_lot\\E,\\Qdispatch.ads_tow\\E,\\Qdispatch.ims_fee_group\\E,\\Qdispatch.ims_auction_vehicle\\E,\\Qdispatch.ims_hold\\E,\\Qdispatch.ims_fee_category\\E,\\Qdispatch.ads_vehicle\\E,\\Qdispatch.ppi_ppi_file\\E,\\Qdispatch.ims_access_pass\\E,\\Qdispatch.ads_round_robin_company_turn\\E,\\Qdispatch.ims_vehicle\\E,\\Qdispatch.ims_fee_event\\E,\\Qdispatch.ims_fee_price\\E,\\Qdispatch.ims_fee_item\\E,\\Qdispatch.ads_round_robin_company_sequence\\E,\\Qdispatch.ads_hold\\E,\\Qdispatch.ref_lot_region
E"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    table.include.list = \Qdispatch.ref_region\E,\Qdispatch.ims_auction\E,\Qdispatch.ims_fee_event_type\E,\Qdispatch.ppi_ppi_vehicle\E,\Qdispatch.ppi_ppi_tow_company\E,\Qdispatch.ims_fee\E,\Qdispatch.ref_lot\E,\Qdispatch.ads_tow\E,\Qdispatch.ims_fee_group\E,\Qdispatch.ims_auction_vehicle\E,\Qdispatch.ims_hold\E,\Qdispatch.ims_fee_category\E,\Qdispatch.ads_vehicle\E,\Qdispatch.ppi_ppi_file\E,\Qdispatch.ims_access_pass\E,\Qdispatch.ads_round_robin_company_turn\E,\Qdispatch.ims_vehicle\E,\Qdispatch.ims_fee_event\E,\Qdispatch.ims_fee_price\E,\Qdispatch.ims_fee_item\E,\Qdispatch.ads_round_robin_company_sequence\E,\Qdispatch.ads_hold\E,\Qdispatch.ref_lot_region\E
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    snapshot.mode = when_needed"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    snapshot.mode = when_needed
2024-03-26 18:38:48 source > {"type":"LOG","log":{"level":"INFO","message":"INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.include.list = dispatch"}}
2024-03-26 18:38:48 source > INFO pool-7-thread-1 i.d.c.c.BaseSourceTask(lambda$start$0):138    database.include.list = dispatch

What is the captured database version and mode of depoyment?

(E.g. on-premises, with a specific cloud provider, etc.)

<Your answer>

What behaviour do you expect?

<Your answer>

What behaviour do you see?

Log error, failing with reason "extraneous input 'END' expecting {<eof>, '-'}"

Detailed logs below:
 
 
DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`reportwriter`@`%` PROCEDURE `sp_ds_DAL_TX_Impoundment`(IN pDateFrom datetime, IN pDateTo datetime)\nBEGIN\n\n    SET @goliveDate = '2023-05-02 02:00:00';\n    set @pRegion = 'DAL-TX';\n-- set @pDateFrom = '2023-02-01 00:00:00';\n-- set @pDateTo = '2023-03-10 00:00:00';\n    set @pDateFrom = pDateFrom;\n    set @pDateTo = pDateTo;\n\n    set @contractAmount = 21.03;\n\nwith\nTemp1 as\n(\n    select l.code                                                            as lotCode\n         , fi.Id                                                             AS FeeItemID\n         , fi.unitBillingPrice                                               as billingPrice\n         , eq.equipmentClass\n         , a.customerCode\n         , v.impoundStatus\n         , tc.companyCode                                                    AS impoundCompany\n         , b.companyCode                                                     AS towOperator\n         , v.id                                                              AS vehicleId\n         , re.reasoncode \n         , v.towReferenceNumber\n\n         , fn_CalculateTimeZoneOffset(regionCode, v.clearedDate, 'DISPLAY')  AS towDate\n         , fn_CalculateTimeZoneOffset(regionCode, v.releaseDate, 'DISPLAY')  AS releaseDate\n         , fn_CalculateTimeZoneOffset(regionCode, fi.createdDate, 'DISPLAY') AS feeDate\n\n         , f.code\n         , fi.totalBillingPricePretax\n\n    from ims_vehicle v\n             join ref_region r\n                  on v.regionId = r.regionId\n\n             INNER JOIN ims_fee_event fe ON v.id = fe.vehicleId\n             INNER JOIN ims_fee_item fi ON fe.id = fi.feeEventId\n             INNER JOIN ims_fee f ON fi.feeId = f.id\n             INNER JOIN ims_fee_category fc ON f.feeCategoryEnumCode = fc.enumcode\n\n             INNER JOIN ref_customer a ON v.accountId = a.customerId\n             INNER JOIN ref_reason re ON v.reasonId = re.reasonId\n             INNER JOIN ref_tow_company tc ON v.currentImpoundOperatorId = tc.towCompanyId\n\n             JOIN ref_tow_company b ON v.towOperatorId = b.towCompanyId\n             left join ref_lot l on v.currentLotId = l.id\n             join ref_equipment eq\n                  on v.equipmentId = eq.id\n\n    where r.regionCode = @pRegion\n      and v.releaseDate >= @pDateFrom\n      and v.releaseDate < @pDateTo\n      and v.clearedDate >= @goliveDate\n      and b.companyCode != 'ART-DAL-TX'\n      and v.impoundStatus = 'RELEASED'\n)\n\n    select lotCode\n         , Temp1.vehicleId         as \"Vehicle ID\"\n         , towReferenceNumber      as \"Tow Reference Number\"\n         , equipmentClass          as \"Class\"\n         , impoundStatus           as \"Status\"\n         , customerCode            as \"Customer\"\n         , impoundCompany          as \"Impound Company\"\n         , towOperator             as \"Tow Operator\"\n         , towDate                 as \"Tow Date\"\n         , releaseDate             as \"Release Date\"\n         , billingPrice            as \"Auto Pound Authorized Fee\"\n\n         , billingPrice - @contractAmount   as \"rev threshold\"\n         \n-- ,DATEDIFF(s.timeTo, s.timeFrom) as \"Storage Days\"\n         , null                    as \"Storage Days\"\n         , null                    as timeFrom\n         , null                    as timeTo\n         , billingPrice            as \"Authorized Impoundment Fee\"\n\n         , (billingPrice - @contractAmount)/2 + @contractAmount as \"rev share amount\"\n\n    from Temp1\n\n    where code in ('ImpoundmentFee')\n      and lotCode like '%PEAKA%';\n    \nEND'\nextraneous input 'END' expecting {<EOF>, ''}\n\tat io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) ~[debezium-ddl-parser-2.4.0.Final.jar:2.4.0.Final]\n\tat org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) ~[antlr4-runtime-4.10.1.jar:4.10.1]\n\tat org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:543) ~[antlr4-runtime-4.10.1.jar:4.10.1]\n\tat org.antlr.v4.runtime.DefaultErrorStrategy.reportUnwantedToken(DefaultErrorStrategy.java:377) ~[antlr4-runtime-4.10.1.jar:4.10.1]\n\tat org.antlr.v4.runtime.DefaultErrorStrategy.singleTokenDeletion(DefaultErrorStrategy.java:548) ~[antlr4-runtime-4.10.1.jar:4.10.1]\n\tat org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:266) ~[antlr4-runtime-4.10.1.jar:4.10.1]\n\tat io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:993) ~[debezium-ddl-parser-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:74) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:46) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:78) ~[debezium-ddl-parser-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:199) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:593) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$15(MySqlStreamingChangeEventSource.java:901) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:375) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]\n\t... 6 more\n","stack_trace":"io.debezium.DebeziumException: Error processing binlog event\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:395)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$27(MySqlStreamingChangeEventSource.java:930)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1246)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1072)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:631)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`reportwriter`@`%` PROCEDURE `sp_ds_DAL_TX_Impoundment`(IN pDateFrom datetime, IN pDateTo datetime)\nBEGIN\n\n    SET @goliveDate = '2023-05-02 02:00:00';\n    set @pRegion = 'DAL-TX';\n- set @pDateFrom = '2023-02-01 00:00:00';\n-- set @pDateTo = '2023-03-10 00:00:00';\n    set @pDateFrom = pDateFrom;\n    set @pDateTo = pDateTo;\n\n    set @contractAmount = 21.03;\n\nwith\nTemp1 as\n(\n    select l.code                                                            as lotCode\n         , fi.Id                                                             AS FeeItemID\n         , fi.unitBillingPrice                                               as billingPrice\n         , eq.equipmentClass\n         , a.customerCode\n         , v.impoundStatus\n         , tc.companyCode                                                    AS impoundCompany\n         , b.companyCode                                                     AS towOperator\n         , v.id                                                              AS vehicleId\n         , re.reasoncode \n         , v.towReferenceNumber\n\n         , fn_CalculateTimeZoneOffset(regionCode, v.clearedDate, 'DISPLAY')  AS towDate\n         , fn_CalculateTimeZoneOffset(regionCode, v.releaseDate, 'DISPLAY')  AS releaseDate\n         , fn_CalculateTimeZoneOffset(regionCode, fi.createdDate, 'DISPLAY') AS feeDate\n\n         , f.code\n         , fi.totalBillingPricePretax\n\n    from ims_vehicle v\n             join ref_region r\n                  on v.regionId = r.regionId\n\n             INNER JOIN ims_fee_event fe ON v.id = fe.vehicleId\n             INNER JOIN ims_fee_item fi ON fe.id = fi.feeEventId\n             INNER JOIN ims_fee f ON fi.feeId = f.id\n             INNER JOIN ims_fee_category fc ON f.feeCategoryEnumCode = fc.enumcode\n\n             INNER JOIN ref_customer a ON v.accountId = a.customerId\n             INNER JOIN ref_reason re ON v.reasonId = re.reasonId\n             INNER JOIN ref_tow_company tc ON v.currentImpoundOperatorId = tc.towCompanyId\n\n             JOIN ref_tow_company b ON v.towOperatorId = b.towCompanyId\n             left join ref_lot l on v.currentLotId = l.id\n             join ref_equipment eq\n                  on v.equipmentId = eq.id\n\n    where r.regionCode = @pRegion\n      and v.releaseDate >= @pDateFrom\n      and v.releaseDate < @pDateTo\n      and v.clearedDate >= @goliveDate\n      and b.companyCode != 'ART-DAL-TX'\n      and v.impoundStatus = 'RELEASED'\n)\n\n    select lotCode\n         , Temp1.vehicleId         as \"Vehicle ID\"\n         , towReferenceNumber      as \"Tow Reference Number\"\n         , equipmentClass          as \"Class\"\n         , impoundStatus           as \"Status\"\n         , customerCode            as \"Customer\"\n         , impoundCompany          as \"Impound Company\"\n         , towOperator             as \"Tow Operator\"\n         , towDate                 as \"Tow Date\"\n         , releaseDate             as \"Release Date\"\n         , billingPrice            as \"Auto Pound Authorized Fee\"\n\n         , billingPrice - @contractAmount   as \"rev threshold\"\n         \n-- ,DATEDIFF(s.timeTo, s.timeFrom) as \"Storage Days\"\n         , null                    as \"Storage Days\"\n         , null                    as timeFrom\n         , null                    as timeTo\n         , billingPrice            as \"Authorized Impoundment Fee\"\n\n         , (billingPrice - @contractAmount)/2 + @contractAmount as \"rev share amount\"\n\n    from Temp1\n\n    where code in ('ImpoundmentFee')\n      and lotCode like '%PEAKA%';\n    \nEND'\nextraneous input 'END' expecting {<EOF>, '-'}\n\tat io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)\n\tat org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)\n\tat org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:543)\n\tat org.antlr.v4.runtime.DefaultErrorStrategy.reportUnwantedToken(DefaultErrorStrategy.java:377)\n\tat org.antlr.v4.runtime.DefaultErrorStrategy.singleTokenDeletion(DefaultErrorStrategy.java:548)\n\tat org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:266)\n\tat io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:993)\n\tat io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:74)\n\tat io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:46)\n\tat io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:78)\n\tat io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213)\n\tat io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:199)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:593)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$15(MySqlStreamingChangeEventSource.java:901)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:375)\n\t... 6 more\n"}}

Do you see the same behaviour using the latest relesead Debezium version?

(Ideally, also verify with latest Alpha/Beta/CR version)

airbyte depends on 2.4.0, and this is an error from a client's database, so there is no easy way for us to verify.

Do you have the connector logs, ideally from start till finish?

(You might be asked later to provide DEBUG/TRACE level log)

<Your answer>

How to reproduce the issue using our tutorial deployment?

<Your answer>

Feature request or enhancement

For feature requests or enhancements, provide this information, please:

Which use case/requirement will be addressed by the proposed feature?

<Your answer>

Implementation ideas (optional)

<Your answer>