2022-04-26 20:03:52 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha 2022-04-26 20:03:52 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/20/0/logs.log 2022-04-26 20:03:52 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha 2022-04-26 20:03:57 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-26 20:03:53 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 20 attempt id: 0 2022-04-26 20:03:53 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.contacts_list_memberships=full_refresh - append, null.workflows=full_refresh - append, null.engagements_calls=full_refresh - append, null.deals=full_refresh - append, null.email_events=full_refresh - append, null.products=full_refresh - append, null.engagements_tasks=full_refresh - append, null.engagements_notes=full_refresh - append, null.forms=full_refresh - append, null.line_items=full_refresh - append, null.tickets=full_refresh - append, null.contact_lists=full_refresh - append, null.ticket_pipelines=full_refresh - append, null.engagements_emails=full_refresh - append, null.owners=full_refresh - append, null.feedback_submissions=full_refresh - append, null.form_submissions=full_refresh - append, null.deal_pipelines=full_refresh - append, null.marketing_emails=full_refresh - append, null.companies=full_refresh - append, null.engagements=full_refresh - append, null.engagements_meetings=full_refresh - append, null.property_history=full_refresh - append, null.quotes=full_refresh - append, null.contacts=full_refresh - append, null.campaigns=full_refresh - append, null.subscription_changes=full_refresh - append} 2022-04-26 20:03:53 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-26 20:03:53 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = destination-snowflake-sync-20-0-zicnh for airbyte/destination-snowflake:0.4.24 2022-04-26 20:03:53 INFO i.a.w.p.KubeProcessFactory(create):116 - destination-snowflake-sync-20-0-zicnh stdoutLocalPort = 9026 2022-04-26 20:03:53 INFO i.a.w.p.KubeProcessFactory(create):119 - destination-snowflake-sync-20-0-zicnh stderrLocalPort = 9027 2022-04-26 20:03:53 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):565 - Creating stdout socket server... 2022-04-26 20:03:53 INFO i.a.w.p.KubePodProcess():503 - Creating pod... 2022-04-26 20:03:53 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):583 - Creating stderr socket server... 2022-04-26 20:03:53 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-26 20:03:53 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):318 - Init container present.. 2022-04-26 20:03:54 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):321 - Init container ready.. 2022-04-26 20:03:54 INFO i.a.w.p.KubePodProcess():528 - Copying files... 2022-04-26 20:03:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-04-26 20:03:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/f3f78d19-1032-475c-9ba6-d1ec99d19c9e/destination_config.json airbyte/destination-snowflake-sync-20-0-zicnh:/config/destination_config.json -c init 2022-04-26 20:03:54 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/bad1519c-a00d-48da-9409-071492d43a7f/destination_catalog.json airbyte/destination-snowflake-sync-20-0-zicnh:/config/destination_catalog.json -c init 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/40abdb9d-2f2d-488b-89fc-63f63cca6caf/FINISHED_UPLOADING airbyte/destination-snowflake-sync-20-0-zicnh:/config/FINISHED_UPLOADING -c init 2022-04-26 20:03:55 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 20:03:56 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 20:03:56 INFO i.a.w.p.KubePodProcess():531 - Waiting until pod is ready... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):574 - Setting stdout... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):586 - Setting stderr... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess():546 - Reading pod IP... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess():548 - Pod IP: 10.0.7.20 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess():551 - Creating stdin socket... 2022-04-26 20:03:57 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = source-hubspot-sync-20-0-chclz for airbyte/source-hubspot:0.1.53 2022-04-26 20:03:57 INFO i.a.w.p.KubeProcessFactory(create):116 - source-hubspot-sync-20-0-chclz stdoutLocalPort = 9028 2022-04-26 20:03:57 INFO i.a.w.p.KubeProcessFactory(create):119 - source-hubspot-sync-20-0-chclz stderrLocalPort = 9029 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):565 - Creating stdout socket server... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess():503 - Creating pod... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):583 - Creating stderr socket server... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-26 20:03:57 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):318 - Init container present.. 2022-04-26 20:03:59 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):321 - Init container ready.. 2022-04-26 20:03:59 INFO i.a.w.p.KubePodProcess():528 - Copying files... 2022-04-26 20:03:59 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: input_state.json 2022-04-26 20:03:59 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/c43fe51f-ad4c-4876-85a4-64a2fcd352d0/input_state.json airbyte/source-hubspot-sync-20-0-chclz:/config/input_state.json -c init 2022-04-26 20:03:59 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/a791575d-dc2c-47f0-aef1-54c81bfda4e2/source_config.json airbyte/source-hubspot-sync-20-0-chclz:/config/source_config.json -c init 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_catalog.json 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/196aa3f6-c7bd-41c6-b54a-43288c1c448a/source_catalog.json airbyte/source-hubspot-sync-20-0-chclz:/config/source_catalog.json -c init 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/e2894918-db50-4a2a-ab08-eb518b43e74f/FINISHED_UPLOADING airbyte/source-hubspot-sync-20-0-chclz:/config/FINISHED_UPLOADING -c init 2022-04-26 20:04:00 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-26 20:04:01 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-26 20:04:01 INFO i.a.w.p.KubePodProcess():531 - Waiting until pod is ready... 2022-04-26 20:04:02 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):574 - Setting stdout... 2022-04-26 20:04:02 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):586 - Setting stderr... 2022-04-26 20:04:02 INFO i.a.w.p.KubePodProcess():546 - Reading pod IP... 2022-04-26 20:04:02 INFO i.a.w.p.KubePodProcess():548 - Pod IP: 10.0.6.17 2022-04-26 20:04:02 INFO i.a.w.p.KubePodProcess():555 - Using null stdin output stream... 2022-04-26 20:04:02 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-26 20:04:02 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-26 20:04:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-26 20:03:57 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-26 20:03:57 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-26 20:03:57 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-26 20:03:57 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):339 - Sentry transaction event: d535d4301fb6466e91ed52ab4e4b8970 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-26 20:04:02 destination > 2022-04-26 20:03:59 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=campaigns, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_nqa_campaigns, outputTableName=_airbyte_raw_campaigns, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=companies, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_dkr_companies, outputTableName=_airbyte_raw_companies, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=contact_lists, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_nrt_contact_lists, outputTableName=_airbyte_raw_contact_lists, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=contacts, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_yom_contacts, outputTableName=_airbyte_raw_contacts, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=contacts_list_memberships, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_xui_contacts_list_memberships, outputTableName=_airbyte_raw_contacts_list_memberships, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=deal_pipelines, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_ymi_deal_pipelines, outputTableName=_airbyte_raw_deal_pipelines, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=deals, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_atv_deals, outputTableName=_airbyte_raw_deals, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=email_events, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_hrb_email_events, outputTableName=_airbyte_raw_email_events, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=engagements, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_jmb_engagements, outputTableName=_airbyte_raw_engagements, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=engagements_calls, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_xhw_engagements_calls, outputTableName=_airbyte_raw_engagements_calls, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=engagements_emails, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_edo_engagements_emails, outputTableName=_airbyte_raw_engagements_emails, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=engagements_meetings, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_qqf_engagements_meetings, outputTableName=_airbyte_raw_engagements_meetings, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=engagements_notes, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_wmb_engagements_notes, outputTableName=_airbyte_raw_engagements_notes, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=engagements_tasks, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_dvv_engagements_tasks, outputTableName=_airbyte_raw_engagements_tasks, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=feedback_submissions, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_pwb_feedback_submissions, outputTableName=_airbyte_raw_feedback_submissions, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=form_submissions, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_rcj_form_submissions, outputTableName=_airbyte_raw_form_submissions, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=forms, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_hdy_forms, outputTableName=_airbyte_raw_forms, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=line_items, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_qig_line_items, outputTableName=_airbyte_raw_line_items, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=marketing_emails, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_yoz_marketing_emails, outputTableName=_airbyte_raw_marketing_emails, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=owners, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_oud_owners, outputTableName=_airbyte_raw_owners, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=products, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_yiq_products, outputTableName=_airbyte_raw_products, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=property_history, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_hky_property_history, outputTableName=_airbyte_raw_property_history, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=quotes, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_akd_quotes, outputTableName=_airbyte_raw_quotes, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=subscription_changes, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_kvq_subscription_changes, outputTableName=_airbyte_raw_subscription_changes, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=ticket_pipelines, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_lyc_ticket_pipelines, outputTableName=_airbyte_raw_ticket_pipelines, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=tickets, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_bke_tickets, outputTableName=_airbyte_raw_tickets, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=workflows, namespace=null, outputSchemaName=HUBSPOT_TEST, tmpTableName=_airbyte_tmp_fdm_workflows, outputTableName=_airbyte_raw_workflows, syncMode=append} 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):114 - Preparing tmp tables in destination started for 27 streams 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream campaigns: tmp table: _airbyte_tmp_nqa_campaigns, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:02 destination > 2022-04-26 20:04:00 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting... 2022-04-26 20:04:02 destination > 2022-04-26 20:04:02 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@fb49fdf 2022-04-26 20:04:02 destination > 2022-04-26 20:04:02 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed. 2022-04-26 20:04:02 destination > 2022-04-26 20:04:02 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:03 destination > 2022-04-26 20:04:03 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream campaigns 2022-04-26 20:04:03 destination > 2022-04-26 20:04:03 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream companies: tmp table: _airbyte_tmp_dkr_companies, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:03 destination > 2022-04-26 20:04:03 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:03 source > Starting syncing SourceHubspot 2022-04-26 20:04:03 source > Syncing stream: campaigns 2022-04-26 20:04:04 destination > 2022-04-26 20:04:04 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream companies 2022-04-26 20:04:04 destination > 2022-04-26 20:04:04 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream contact_lists: tmp table: _airbyte_tmp_nrt_contact_lists, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:04 destination > 2022-04-26 20:04:04 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:05 destination > 2022-04-26 20:04:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream contact_lists 2022-04-26 20:04:05 destination > 2022-04-26 20:04:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream contacts: tmp table: _airbyte_tmp_yom_contacts, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:05 destination > 2022-04-26 20:04:05 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:05 destination > 2022-04-26 20:04:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream contacts 2022-04-26 20:04:05 destination > 2022-04-26 20:04:05 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream contacts_list_memberships: tmp table: _airbyte_tmp_xui_contacts_list_memberships, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:05 destination > 2022-04-26 20:04:05 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:06 destination > 2022-04-26 20:04:06 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream contacts_list_memberships 2022-04-26 20:04:06 destination > 2022-04-26 20:04:06 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream deal_pipelines: tmp table: _airbyte_tmp_ymi_deal_pipelines, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:06 destination > 2022-04-26 20:04:06 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:07 destination > 2022-04-26 20:04:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream deal_pipelines 2022-04-26 20:04:07 destination > 2022-04-26 20:04:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream deals: tmp table: _airbyte_tmp_atv_deals, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:07 destination > 2022-04-26 20:04:07 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:07 destination > 2022-04-26 20:04:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream deals 2022-04-26 20:04:07 destination > 2022-04-26 20:04:07 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream email_events: tmp table: _airbyte_tmp_hrb_email_events, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:08 destination > 2022-04-26 20:04:08 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:09 destination > 2022-04-26 20:04:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream email_events 2022-04-26 20:04:09 destination > 2022-04-26 20:04:09 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream engagements: tmp table: _airbyte_tmp_jmb_engagements, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:09 destination > 2022-04-26 20:04:09 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:10 destination > 2022-04-26 20:04:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream engagements 2022-04-26 20:04:10 destination > 2022-04-26 20:04:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream engagements_calls: tmp table: _airbyte_tmp_xhw_engagements_calls, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:10 destination > 2022-04-26 20:04:10 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:10 destination > 2022-04-26 20:04:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream engagements_calls 2022-04-26 20:04:10 destination > 2022-04-26 20:04:10 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream engagements_emails: tmp table: _airbyte_tmp_edo_engagements_emails, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:11 destination > 2022-04-26 20:04:10 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:11 destination > 2022-04-26 20:04:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream engagements_emails 2022-04-26 20:04:11 destination > 2022-04-26 20:04:11 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream engagements_meetings: tmp table: _airbyte_tmp_qqf_engagements_meetings, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:11 destination > 2022-04-26 20:04:11 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:12 destination > 2022-04-26 20:04:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream engagements_meetings 2022-04-26 20:04:12 destination > 2022-04-26 20:04:12 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream engagements_notes: tmp table: _airbyte_tmp_wmb_engagements_notes, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:12 destination > 2022-04-26 20:04:12 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:14 destination > 2022-04-26 20:04:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream engagements_notes 2022-04-26 20:04:14 destination > 2022-04-26 20:04:14 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream engagements_tasks: tmp table: _airbyte_tmp_dvv_engagements_tasks, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:15 destination > 2022-04-26 20:04:15 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:16 destination > 2022-04-26 20:04:16 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream engagements_tasks 2022-04-26 20:04:16 destination > 2022-04-26 20:04:16 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream feedback_submissions: tmp table: _airbyte_tmp_pwb_feedback_submissions, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:16 destination > 2022-04-26 20:04:16 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:18 destination > 2022-04-26 20:04:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream feedback_submissions 2022-04-26 20:04:18 destination > 2022-04-26 20:04:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream form_submissions: tmp table: _airbyte_tmp_rcj_form_submissions, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:18 destination > 2022-04-26 20:04:18 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:19 destination > 2022-04-26 20:04:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream form_submissions 2022-04-26 20:04:19 destination > 2022-04-26 20:04:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream forms: tmp table: _airbyte_tmp_hdy_forms, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:19 destination > 2022-04-26 20:04:19 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:20 destination > 2022-04-26 20:04:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream forms 2022-04-26 20:04:20 destination > 2022-04-26 20:04:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream line_items: tmp table: _airbyte_tmp_qig_line_items, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:20 destination > 2022-04-26 20:04:20 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:22 destination > 2022-04-26 20:04:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream line_items 2022-04-26 20:04:22 destination > 2022-04-26 20:04:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream marketing_emails: tmp table: _airbyte_tmp_yoz_marketing_emails, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:22 destination > 2022-04-26 20:04:22 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:22 destination > 2022-04-26 20:04:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream marketing_emails 2022-04-26 20:04:22 destination > 2022-04-26 20:04:22 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream owners: tmp table: _airbyte_tmp_oud_owners, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:22 destination > 2022-04-26 20:04:22 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:23 destination > 2022-04-26 20:04:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream owners 2022-04-26 20:04:23 destination > 2022-04-26 20:04:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream products: tmp table: _airbyte_tmp_yiq_products, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:23 destination > 2022-04-26 20:04:23 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:23 destination > 2022-04-26 20:04:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream products 2022-04-26 20:04:23 destination > 2022-04-26 20:04:23 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream property_history: tmp table: _airbyte_tmp_hky_property_history, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:23 destination > 2022-04-26 20:04:23 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:24 destination > 2022-04-26 20:04:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream property_history 2022-04-26 20:04:24 destination > 2022-04-26 20:04:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream quotes: tmp table: _airbyte_tmp_akd_quotes, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:24 destination > 2022-04-26 20:04:24 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:24 destination > 2022-04-26 20:04:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream quotes 2022-04-26 20:04:24 destination > 2022-04-26 20:04:24 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream subscription_changes: tmp table: _airbyte_tmp_kvq_subscription_changes, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:24 destination > 2022-04-26 20:04:24 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:25 destination > 2022-04-26 20:04:25 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream subscription_changes 2022-04-26 20:04:25 destination > 2022-04-26 20:04:25 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream ticket_pipelines: tmp table: _airbyte_tmp_lyc_ticket_pipelines, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:25 destination > 2022-04-26 20:04:25 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:26 destination > 2022-04-26 20:04:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream ticket_pipelines 2022-04-26 20:04:26 destination > 2022-04-26 20:04:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream tickets: tmp table: _airbyte_tmp_bke_tickets, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:26 destination > 2022-04-26 20:04:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:26 destination > 2022-04-26 20:04:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream tickets 2022-04-26 20:04:26 destination > 2022-04-26 20:04:26 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):122 - Preparing staging area in destination started for schema HUBSPOT_TEST stream workflows: tmp table: _airbyte_tmp_fdm_workflows, stage: 2022/04/26/20/333BF4C8-59EC-409F-A322-436D8B468097/ 2022-04-26 20:04:26 destination > 2022-04-26 20:04:26 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:04:27 destination > 2022-04-26 20:04:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing staging area in destination completed for schema HUBSPOT_TEST stream workflows 2022-04-26 20:04:27 destination > 2022-04-26 20:04:27 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing tmp tables in destination completed. 2022-04-26 20:04:27 destination > 2022-04-26 20:04:27 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream campaigns (current state: 0 bytes in 0 buffers) 2022-04-26 20:06:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (487 KB) 2022-04-26 20:07:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 2000 (8 MB) 2022-04-26 20:07:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 3000 (19 MB) 2022-04-26 20:07:21 source > Read 1257 records from campaigns stream 2022-04-26 20:07:21 source > Finished syncing SourceHubspot 2022-04-26 20:07:21 source > SourceHubspot runtimes: 2022-04-26 20:07:21 source > Syncing stream: companies 2022-04-26 20:07:22 destination > 2022-04-26 20:07:22 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream companies (current state: 137 KB in 1 buffers) 2022-04-26 20:07:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 4000 (29 MB) 2022-04-26 20:08:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 5000 (39 MB) 2022-04-26 20:08:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 6000 (49 MB) 2022-04-26 20:08:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 7000 (59 MB) 2022-04-26 20:08:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 8000 (69 MB) 2022-04-26 20:08:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 9000 (79 MB) 2022-04-26 20:08:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 10000 (89 MB) 2022-04-26 20:09:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 11000 (100 MB) 2022-04-26 20:09:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 12000 (110 MB) 2022-04-26 20:09:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 13000 (120 MB) 2022-04-26 20:10:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 14000 (130 MB) 2022-04-26 20:10:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 15000 (140 MB) 2022-04-26 20:10:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 16000 (150 MB) 2022-04-26 20:10:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 17000 (160 MB) 2022-04-26 20:10:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 18000 (171 MB) 2022-04-26 20:10:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 19000 (181 MB) 2022-04-26 20:11:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 20000 (191 MB) 2022-04-26 20:11:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 21000 (201 MB) 2022-04-26 20:11:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 22000 (211 MB) 2022-04-26 20:11:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 23000 (221 MB) 2022-04-26 20:11:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 24000 (231 MB) 2022-04-26 20:11:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 25000 (241 MB) 2022-04-26 20:11:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 26000 (251 MB) 2022-04-26 20:12:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 27000 (261 MB) 2022-04-26 20:12:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 28000 (271 MB) 2022-04-26 20:12:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 29000 (281 MB) 2022-04-26 20:12:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 30000 (291 MB) 2022-04-26 20:12:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 31000 (301 MB) 2022-04-26 20:12:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 32000 (311 MB) 2022-04-26 20:13:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 33000 (321 MB) 2022-04-26 20:13:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 34000 (331 MB) 2022-04-26 20:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 35000 (341 MB) 2022-04-26 20:13:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 36000 (351 MB) 2022-04-26 20:13:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 37000 (361 MB) 2022-04-26 20:13:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 38000 (372 MB) 2022-04-26 20:14:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 39000 (382 MB) 2022-04-26 20:14:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 40000 (393 MB) 2022-04-26 20:14:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 41000 (403 MB) 2022-04-26 20:14:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 42000 (414 MB) 2022-04-26 20:14:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 43000 (424 MB) 2022-04-26 20:14:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 44000 (434 MB) 2022-04-26 20:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 45000 (444 MB) 2022-04-26 20:15:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 46000 (454 MB) 2022-04-26 20:15:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 47000 (464 MB) 2022-04-26 20:15:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 48000 (474 MB) 2022-04-26 20:15:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 49000 (484 MB) 2022-04-26 20:15:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 50000 (494 MB) 2022-04-26 20:15:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 51000 (504 MB) 2022-04-26 20:16:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 52000 (514 MB) 2022-04-26 20:16:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 53000 (524 MB) 2022-04-26 20:16:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 54000 (534 MB) 2022-04-26 20:16:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 55000 (544 MB) 2022-04-26 20:16:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 56000 (554 MB) 2022-04-26 20:16:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 57000 (565 MB) 2022-04-26 20:16:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 58000 (575 MB) 2022-04-26 20:16:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 59000 (585 MB) 2022-04-26 20:17:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 60000 (595 MB) 2022-04-26 20:17:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 61000 (605 MB) 2022-04-26 20:17:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 62000 (615 MB) 2022-04-26 20:17:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 63000 (625 MB) 2022-04-26 20:17:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 64000 (635 MB) 2022-04-26 20:17:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 65000 (646 MB) 2022-04-26 20:18:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 66000 (656 MB) 2022-04-26 20:18:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 67000 (666 MB) 2022-04-26 20:18:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 68000 (676 MB) 2022-04-26 20:18:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 69000 (686 MB) 2022-04-26 20:18:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 70000 (697 MB) 2022-04-26 20:18:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 71000 (707 MB) 2022-04-26 20:19:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 72000 (717 MB) 2022-04-26 20:19:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 73000 (727 MB) 2022-04-26 20:19:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 74000 (737 MB) 2022-04-26 20:19:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 75000 (748 MB) 2022-04-26 20:19:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 76000 (758 MB) 2022-04-26 20:19:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 77000 (768 MB) 2022-04-26 20:20:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 78000 (778 MB) 2022-04-26 20:20:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 79000 (788 MB) 2022-04-26 20:20:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 80000 (798 MB) 2022-04-26 20:20:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 81000 (809 MB) 2022-04-26 20:20:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 82000 (819 MB) 2022-04-26 20:21:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 83000 (829 MB) 2022-04-26 20:21:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 84000 (839 MB) 2022-04-26 20:21:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 85000 (849 MB) 2022-04-26 20:21:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 86000 (859 MB) 2022-04-26 20:21:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 87000 (869 MB) 2022-04-26 20:21:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 88000 (879 MB) 2022-04-26 20:21:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 89000 (889 MB) 2022-04-26 20:22:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 90000 (899 MB) 2022-04-26 20:22:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 91000 (909 MB) 2022-04-26 20:22:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 92000 (919 MB) 2022-04-26 20:22:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 93000 (929 MB) 2022-04-26 20:22:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 94000 (939 MB) 2022-04-26 20:22:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 95000 (949 MB) 2022-04-26 20:22:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 96000 (960 MB) 2022-04-26 20:23:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 97000 (970 MB) 2022-04-26 20:23:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 98000 (980 MB) 2022-04-26 20:23:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 99000 (990 MB) 2022-04-26 20:23:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 100000 (1001 MB) 2022-04-26 20:23:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 101000 (1011 MB) 2022-04-26 20:23:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 102000 (1021 MB) 2022-04-26 20:23:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 103000 (1 GB) 2022-04-26 20:24:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 104000 (1 GB) 2022-04-26 20:24:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 105000 (1 GB) 2022-04-26 20:24:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 106000 (1 GB) 2022-04-26 20:24:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 107000 (1 GB) 2022-04-26 20:24:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 108000 (1 GB) 2022-04-26 20:24:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 109000 (1 GB) 2022-04-26 20:24:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 110000 (1 GB) 2022-04-26 20:25:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 111000 (1 GB) 2022-04-26 20:25:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 112000 (1 GB) 2022-04-26 20:25:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 113000 (1 GB) 2022-04-26 20:25:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 114000 (1 GB) 2022-04-26 20:25:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 115000 (1 GB) 2022-04-26 20:26:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 116000 (1 GB) 2022-04-26 20:26:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 117000 (1 GB) 2022-04-26 20:26:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 118000 (1 GB) 2022-04-26 20:26:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 119000 (1 GB) 2022-04-26 20:26:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 120000 (1 GB) 2022-04-26 20:27:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 121000 (1 GB) 2022-04-26 20:27:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 122000 (1 GB) 2022-04-26 20:27:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 123000 (1 GB) 2022-04-26 20:27:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 124000 (1 GB) 2022-04-26 20:27:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 125000 (1 GB) 2022-04-26 20:27:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 126000 (1 GB) 2022-04-26 20:27:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 127000 (1 GB) 2022-04-26 20:28:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 128000 (1 GB) 2022-04-26 20:28:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 129000 (1 GB) 2022-04-26 20:28:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 130000 (1 GB) 2022-04-26 20:28:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 131000 (1 GB) 2022-04-26 20:28:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 132000 (1 GB) 2022-04-26 20:28:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 133000 (1 GB) 2022-04-26 20:28:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 134000 (1 GB) 2022-04-26 20:28:53 source > Advancing bookmark for companies stream from None to 2022-04-26T20:28:52.252000+00:00 2022-04-26 20:29:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 135000 (1 GB) 2022-04-26 20:29:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 136000 (1 GB) 2022-04-26 20:29:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 137000 (1 GB) 2022-04-26 20:28:57 source > Read 132857 records from companies stream 2022-04-26 20:28:57 source > Finished syncing SourceHubspot 2022-04-26 20:28:57 source > SourceHubspot runtimes: 2022-04-26 20:28:57 source > Syncing stream: contact_lists 2022-04-26 20:28:59 destination > 2022-04-26 20:28:59 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream contact_lists (current state: 73 MB in 2 buffers) 2022-04-26 20:29:02 source > Advancing bookmark for contact_lists stream from None to 2022-04-25T13:18:35.189000+00:00 2022-04-26 20:29:02 source > Read 1574 records from contact_lists stream 2022-04-26 20:29:02 source > Finished syncing SourceHubspot 2022-04-26 20:29:02 source > SourceHubspot runtimes: 2022-04-26 20:29:02 source > Syncing stream: contacts 2022-04-26 20:29:04 destination > 2022-04-26 20:29:04 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream contacts (current state: 78 MB in 3 buffers) 2022-04-26 20:30:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 138000 (1 GB) 2022-04-26 20:30:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 139000 (1 GB) 2022-04-26 20:30:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 140000 (1 GB) 2022-04-26 20:31:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 141000 (1 GB) 2022-04-26 20:31:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 142000 (1 GB) 2022-04-26 20:32:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 143000 (1 GB) 2022-04-26 20:32:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 144000 (1 GB) 2022-04-26 20:32:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 145000 (1 GB) 2022-04-26 20:33:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 146000 (1 GB) 2022-04-26 20:33:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 147000 (1 GB) 2022-04-26 20:33:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 148000 (1 GB) 2022-04-26 20:34:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 149000 (1 GB) 2022-04-26 20:34:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 150000 (1 GB) 2022-04-26 20:35:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 151000 (1 GB) 2022-04-26 20:35:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 152000 (1 GB) 2022-04-26 20:35:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 153000 (1 GB) 2022-04-26 20:36:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 154000 (1 GB) 2022-04-26 20:36:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 155000 (1 GB) 2022-04-26 20:36:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 156000 (1 GB) 2022-04-26 20:37:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 157000 (1 GB) 2022-04-26 20:37:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 158000 (1 GB) 2022-04-26 20:38:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 159000 (2 GB) 2022-04-26 20:38:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 160000 (2 GB) 2022-04-26 20:39:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 161000 (2 GB) 2022-04-26 20:39:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 162000 (2 GB) 2022-04-26 20:39:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 163000 (2 GB) 2022-04-26 20:40:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 164000 (2 GB) 2022-04-26 20:40:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 165000 (2 GB) 2022-04-26 20:40:34 destination > 2022-04-26 20:40:34 INFO i.a.i.d.r.SerializedBufferingStrategy(flushWriter):82 - Flushing buffer of stream contacts (200 MB) 2022-04-26 20:40:34 destination > 2022-04-26 20:40:34 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream contacts (200 MB) to staging 2022-04-26 20:40:34 destination > 2022-04-26 20:40:34 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 9decdf5d-75c1-4fa8-9a45-a2a1a8990f3914640415679939277718.csv.gz (200 MB) 2022-04-26 20:40:39 destination > 2022-04-26 20:40:39 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:40:39 destination > 2022-04-26 20:40:39 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 9decdf5d-75c1-4fa8-9a45-a2a1a8990f3914640415679939277718.csv.gz 2022-04-26 20:40:39 destination > 2022-04-26 20:40:39 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream contacts (current state: 78 MB in 3 buffers) 2022-04-26 20:41:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 166000 (2 GB) 2022-04-26 20:41:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 167000 (2 GB) 2022-04-26 20:41:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 168000 (2 GB) 2022-04-26 20:42:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 169000 (2 GB) 2022-04-26 20:42:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 170000 (2 GB) 2022-04-26 20:42:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 171000 (2 GB) 2022-04-26 20:43:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 172000 (2 GB) 2022-04-26 20:43:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 173000 (2 GB) 2022-04-26 20:44:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 174000 (2 GB) 2022-04-26 20:44:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 175000 (2 GB) 2022-04-26 20:45:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 176000 (2 GB) 2022-04-26 20:45:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 177000 (2 GB) 2022-04-26 20:45:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 178000 (2 GB) 2022-04-26 20:46:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 179000 (2 GB) 2022-04-26 20:46:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 180000 (2 GB) 2022-04-26 20:46:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 181000 (2 GB) 2022-04-26 20:47:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 182000 (2 GB) 2022-04-26 20:47:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 183000 (2 GB) 2022-04-26 20:48:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 184000 (2 GB) 2022-04-26 20:48:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 185000 (2 GB) 2022-04-26 20:49:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 186000 (2 GB) 2022-04-26 20:49:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 187000 (2 GB) 2022-04-26 20:50:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 188000 (2 GB) 2022-04-26 20:50:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 189000 (2 GB) 2022-04-26 20:50:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 190000 (2 GB) 2022-04-26 20:51:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 191000 (2 GB) 2022-04-26 20:51:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 192000 (3 GB) 2022-04-26 20:51:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 193000 (3 GB) 2022-04-26 20:52:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 194000 (3 GB) 2022-04-26 20:52:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 195000 (3 GB) 2022-04-26 20:52:04 destination > 2022-04-26 20:52:04 INFO i.a.i.d.r.SerializedBufferingStrategy(flushWriter):82 - Flushing buffer of stream contacts (200 MB) 2022-04-26 20:52:04 destination > 2022-04-26 20:52:04 INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):155 - Flushing buffer for stream contacts (200 MB) to staging 2022-04-26 20:52:04 destination > 2022-04-26 20:52:04 INFO i.a.i.d.r.BaseSerializedBuffer(flush):123 - Finished writing data to 9a6ede90-99af-4a9b-9589-7a314cf90cfb15899158091733281577.csv.gz (200 MB) 2022-04-26 20:52:09 destination > 2022-04-26 20:52:09 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):106 - closing connection 2022-04-26 20:52:09 destination > 2022-04-26 20:52:09 INFO i.a.i.d.r.FileBuffer(deleteFile):78 - Deleting tempFile data 9a6ede90-99af-4a9b-9589-7a314cf90cfb15899158091733281577.csv.gz 2022-04-26 20:52:09 destination > 2022-04-26 20:52:09 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):55 - Starting a new buffer for stream contacts (current state: 78 MB in 3 buffers) 2022-04-26 20:53:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 196000 (3 GB) 2022-04-26 20:53:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 197000 (3 GB) 2022-04-26 20:53:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 198000 (3 GB) 2022-04-26 20:54:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 199000 (3 GB) 2022-04-26 20:54:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 200000 (3 GB) 2022-04-26 20:55:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 201000 (3 GB) 2022-04-26 20:55:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 202000 (3 GB) 2022-04-26 20:56:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 203000 (3 GB) 2022-04-26 20:56:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 204000 (3 GB) 2022-04-26 20:57:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 205000 (3 GB) 2022-04-26 20:57:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 206000 (3 GB) 2022-04-26 20:57:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 207000 (3 GB) 2022-04-26 20:58:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 208000 (3 GB) 2022-04-26 20:58:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 209000 (3 GB) 2022-04-26 20:59:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 210000 (3 GB) 2022-04-26 20:59:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 211000 (3 GB) 2022-04-26 20:59:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 212000 (3 GB) 2022-04-26 21:00:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 213000 (3 GB) 2022-04-26 21:01:07 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.client_id: is missing but it is required, $.client_secret: is missing but it is required, $.refresh_token: is missing but it is required, $.credentials_title: must be a constant value OAuth Credentials 2022-04-26 21:01:07 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required 2022-04-26 21:01:07 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.method: does not have a value in the enumeration [Standard] 2022-04-26 21:00:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 214000 (3 GB) 2022-04-26 21:01:12 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):191 - Running sync worker cancellation... 2022-04-26 21:01:12 INFO i.a.w.DefaultReplicationWorker(cancel):377 - Cancelling replication worker... 2022-04-26 21:01:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 215000 (3 GB) 2022-04-26 21:01:22 INFO i.a.w.DefaultReplicationWorker(cancel):385 - Cancelling destination... 2022-04-26 21:01:23 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process... 2022-04-26 21:01:23 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling... 2022-04-26 21:01:23 INFO i.a.w.p.KubePodProcess(destroy):640 - (pod: airbyte / destination-snowflake-sync-20-0-zicnh) - Destroying Kube process. 2022-04-26 21:01:23 INFO i.a.w.p.KubePodProcess(close):695 - (pod: airbyte / destination-snowflake-sync-20-0-zicnh) - Closed all resources for pod 2022-04-26 21:01:23 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other. 2022-04-26 21:01:23 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Socket closed. Typically happens when cancelling a job. 2022-04-26 21:01:23 INFO i.a.w.p.KubePodProcess(destroy):646 - (pod: airbyte / destination-snowflake-sync-20-0-zicnh) - Destroyed Kube process. 2022-04-26 21:01:23 INFO i.a.w.p.a.DefaultAirbyteDestination(cancel):132 - Cancelled destination process! 2022-04-26 21:01:23 INFO i.a.w.DefaultReplicationWorker(cancel):392 - Cancelling source... 2022-04-26 21:01:23 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process... 2022-04-26 21:01:23 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling... 2022-04-26 21:01:23 INFO i.a.w.p.KubePodProcess(destroy):640 - (pod: airbyte / source-hubspot-sync-20-0-chclz) - Destroying Kube process. 2022-04-26 21:01:23 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Socket closed. Typically happens when cancelling a job. 2022-04-26 21:01:23 INFO i.a.w.p.KubePodProcess(close):695 - (pod: airbyte / source-hubspot-sync-20-0-chclz) - Closed all resources for pod 2022-04-26 21:01:23 INFO i.a.w.p.KubePodProcess(destroy):646 - (pod: airbyte / source-hubspot-sync-20-0-chclz) - Destroyed Kube process. 2022-04-26 21:01:23 INFO i.a.w.p.a.DefaultAirbyteSource(cancel):149 - Cancelled source process! 2022-04-26 21:01:23 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Interrupting worker thread... 2022-04-26 21:01:23 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Cancelling completable future... 2022-04-26 21:01:23 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled. 2022-04-26 21:01:23 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-26 21:01:23 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-26 21:01:23 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=bfedae7d-25b5-3499-8c7c-97e6e3145347, activityType=Replicate, attempt=1 java.lang.RuntimeException: java.util.concurrent.CancellationException at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:106) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?] at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?] at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?] at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?] at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: java.util.concurrent.CancellationException at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:201) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:53) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?] ... 3 more 2022-04-26 21:01:23 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):54 - Job either timed out or was cancelled. 2022-04-26 21:01:23 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete. 2022-04-26 21:01:23 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. io.airbyte.workers.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:167) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: java.net.SocketException: Socket closed at sun.nio.ch.NioSocketImpl.ensureOpenAndConnected(NioSocketImpl.java:165) ~[?:?] at sun.nio.ch.NioSocketImpl.beginWrite(NioSocketImpl.java:366) ~[?:?] at sun.nio.ch.NioSocketImpl.implWrite(NioSocketImpl.java:411) ~[?:?] at sun.nio.ch.NioSocketImpl.write(NioSocketImpl.java:440) ~[?:?] at sun.nio.ch.NioSocketImpl$2.write(NioSocketImpl.java:826) ~[?:?] at java.net.Socket$SocketOutputStream.write(Socket.java:1035) ~[?:?] at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?] at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?] at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?] at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?] at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?] at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] 2022-04-26 21:01:23 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@4b54d8af[status=cancelled,recordsSynced=215387,bytesSynced=4005240457,startTime=1651003433015,endTime=1651006883193,totalStats=io.airbyte.config.SyncStats@49e93c6a[recordsEmitted=215387,bytesEmitted=4005240457,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@12e1e49a[streamName=companies,stats=io.airbyte.config.SyncStats@474eb705[recordsEmitted=132857,bytesEmitted=1408670912,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@2a328ee3[streamName=campaigns,stats=io.airbyte.config.SyncStats@2ab8fda3[recordsEmitted=1257,bytesEmitted=621001,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@37e0095a[streamName=contact_lists,stats=io.airbyte.config.SyncStats@524763c[recordsEmitted=1574,bytesEmitted=12505286,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@3b5fb5ed[streamName=contacts,stats=io.airbyte.config.SyncStats@56e712c0[recordsEmitted=79699,bytesEmitted=2583443258,stateMessagesEmitted=,recordsCommitted=]]]] 2022-04-26 21:01:23 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-26 21:01:23 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@5df40ade[state={}]