Sync from HubSpot to MySQL fails - needs a LOB

[vijaybridgeme]

Enviroment

• Airbyte version: 0.32.0-alpha
• OS Version / Instance: macOS
• Deployment: Docker
• Source Connector and version: Hubspot 0.1.24
• Destination Connector and version: MySQL 0.4.9
• Severity: High
• Step where error happened: Run connection

Current Behavior

Synching the connection fails with this error. Row size too large. The maximum row size for the used table type, not counting BLOBs, is 65535.

Expected Behavior

Sync should not fail.

Logs

LOG

2021-11-15 22:33:24 INFO () WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.32.0-alpha
2021-11-15 22:33:24 INFO () TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.32.0-alpha
2021-11-15 22:33:24 WARN () Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available...
2021-11-15 22:33:24 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2021-11-15 22:33:24 INFO () Databases(createPostgresDatabaseWithRetry):58 - Database available!
2021-11-15 22:33:24 INFO () DefaultReplicationWorker(run):82 - start sync worker. job id: 61 attempt id: 2
2021-11-15 22:33:24 INFO () DefaultReplicationWorker(run):91 - configured sync modes: {null.deals=full_refresh - append, null.contacts=full_refresh - append}
2021-11-15 22:33:24 INFO () DefaultAirbyteDestination(start):64 - Running destination...
2021-11-15 22:33:24 INFO () LineGobbler(voidCall):82 - Checking if airbyte/destination-mysql:0.1.13 exists...
2021-11-15 22:33:24 INFO () LineGobbler(voidCall):82 - airbyte/destination-mysql:0.1.13 was found locally.
2021-11-15 22:33:24 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/61/2 --network host --log-driver none airbyte/destination-mysql:0.1.13 write --config destination_config.json --catalog destination_catalog.json
2021-11-15 22:33:24 INFO () LineGobbler(voidCall):82 - Checking if airbyte/source-hubspot:0.1.24 exists...
2021-11-15 22:33:24 INFO () LineGobbler(voidCall):82 - airbyte/source-hubspot:0.1.24 was found locally.
2021-11-15 22:33:24 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/61/2 --network host --log-driver none airbyte/source-hubspot:0.1.24 read --config source_config.json --catalog source_catalog.json --state input_state.json
2021-11-15 22:33:24 INFO () DefaultReplicationWorker(run):119 - Waiting for source thread to join.
2021-11-15 22:33:24 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):226 - Destination output thread started.
2021-11-15 22:33:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):190 - Replication thread started.
�[35mdestination�[0m - 2021-11-15 22:33:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:25 �[32mINFO�[m i.a.i.d.m.MySQLDestination(main):108 - {} - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
�[35mdestination�[0m - 2021-11-15 22:33:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:25 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):76 - {} - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
�[35mdestination�[0m - 2021-11-15 22:33:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:25 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):115 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
�[35mdestination�[0m - 2021-11-15 22:33:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:25 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):80 - {} - Command: WRITE
�[35mdestination�[0m - 2021-11-15 22:33:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:25 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):81 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[33mWARN�[m 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
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[33mWARN�[m 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
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[33mWARN�[m 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
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[33mWARN�[m 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
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[32mINFO�[m i.a.i.b.s.SshTunnel(getInstance):170 - {} - Starting connection with method: NO_TUNNEL
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=hs_test2_contacts, namespace=null, outputSchemaName=gateway_test_2021_08_05, tmpTableName=_airbyte_tmp_pyz_hs_test2_contacts, outputTableName=_airbyte_raw_hs_test2_contacts, syncMode=append}
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=hs_test2_deals, namespace=null, outputSchemaName=gateway_test_2021_08_05, tmpTableName=_airbyte_tmp_njt_hs_test2_deals, outputTableName=_airbyte_raw_hs_test2_deals, syncMode=append}
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(startTracked):123 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):119 - {} - Preparing tmp tables in destination started for 2 streams
�[35mdestination�[0m - 2021-11-15 22:33:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:26 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - {} - Preparing tmp table in destination started for stream hs_test2_contacts. schema: gateway_test_2021_08_05, tmp table name: _airbyte_tmp_pyz_hs_test2_contacts
2021-11-15 22:33:27 INFO () DefaultReplicationWorker(run):121 - Source thread complete.
2021-11-15 22:33:27 INFO () DefaultReplicationWorker(run):122 - Waiting for destination thread to join.
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):123 - {} - Preparing tmp table in destination started for stream hs_test2_deals. schema: gateway_test_2021_08_05, tmp table name: _airbyte_tmp_njt_hs_test2_deals
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):129 - {} - Preparing tables in destination completed.
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - {} - Airbyte message consumer: succeeded.
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(close):192 - {} - executing on success close procedure.
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):156 - {} - Finalizing tables in destination started for 2 streams
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):161 - {} - Finalizing stream hs_test2_contacts. schema gateway_test_2021_08_05, tmp table _airbyte_tmp_pyz_hs_test2_contacts, final table _airbyte_raw_hs_test2_contacts
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):161 - {} - Finalizing stream hs_test2_deals. schema gateway_test_2021_08_05, tmp table _airbyte_tmp_njt_hs_test2_deals, final table _airbyte_raw_hs_test2_deals
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):174 - {} - Executing finalization of tables.
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):176 - {} - Finalizing tables in destination completed.
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):179 - {} - Cleaning tmp tables in destination started for 2 streams
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - {} - Cleaning tmp table in destination started for stream hs_test2_contacts. schema gateway_test_2021_08_05, tmp table name: _airbyte_tmp_pyz_hs_test2_contacts
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - {} - Cleaning tmp table in destination started for stream hs_test2_deals. schema gateway_test_2021_08_05, tmp table name: _airbyte_tmp_njt_hs_test2_deals
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):188 - {} - Cleaning tmp tables in destination completed.
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):133 - {} - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
�[35mdestination�[0m - 2021-11-15 22:33:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):61 - 2021-11-15 22:33:27 �[32mINFO�[m i.a.i.d.m.MySQLDestination(main):110 - {} - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2021-11-15 22:33:27 INFO () DefaultReplicationWorker(run):124 - Destination thread complete.
2021-11-15 22:33:27 INFO () DefaultReplicationWorker(run):152 - sync summary: io.airbyte.config.ReplicationAttemptSummary@12dbc92b[status=completed,recordsSynced=3,bytesSynced=21239,startTime=1637015604325,endTime=1637015607516]
2021-11-15 22:33:27 INFO () DefaultReplicationWorker(run):161 - Source did not output any state messages
2021-11-15 22:33:27 WARN () DefaultReplicationWorker(run):169 - State capture: No new state, falling back on input state: io.airbyte.config.State@2e75b5f4[state={}]
2021-11-15 22:33:27 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling...
2021-11-15 22:33:27 INFO () ReplicationActivityImpl(replicate):121 - sync summary: io.airbyte.config.StandardSyncOutput@507b4e05[standardSyncSummary=io.airbyte.config.StandardSyncSummary@6cc51200[status=completed,recordsSynced=3,bytesSynced=21239,startTime=1637015604325,endTime=1637015607516],state=io.airbyte.config.State@2e75b5f4[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@180a4642[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5e349472[stream=io.airbyte.protocol.models.AirbyteStream@5435f2d7[name=hs_test2_contacts,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","string"]},"archived":{"type":["null","boolean"]},"createdAt":{"type":["null","string"],"format":"date-time"},"updatedAt":{"type":["null","string"],"format":"date-time"},"properties":{"type":"object","properties":{"fax":{"type":["null","string"]},"zip":{"type":["null","string"]},"city":{"type":["null","string"]},"email":{"type":["null","string"]},"phone":{"type":["null","string"]},"state":{"type":["null","string"]},"degree":{"type":["null","string"]},"gender":{"type":["null","string"]},"school":{"type":["null","string"]},"address":{"type":["null","string"]},"company":{"type":["null","string"]},"country":{"type":["null","string"]},"ip_city":{"type":["null","string"]},"message":{"type":["null","string"]},"website":{"type":["null","string"]},"industry":{"type":["null","string"]},"ip_state":{"type":["null","string"]},"jobtitle":{"type":["null","string"]},"lastname":{"type":["null","string"]},"closedate":{"type":["null","string"],"format":"date-time"},"firstname":{"type":["null","string"]},"ip_latlon":{"type":["null","string"]},"num_notes":{"type":["null","number"]},"seniority":{"type":["null","string"]},"createdate":{"type":["null","string"],"format":"date-time"},"hs_persona":{"type":["null","string"]},"ip_country":{"type":["null","string"]},"ip_zipcode":{"type":["null","string"]},"salutation":{"type":["null","string"]},"start_date":{"type":["null","string"]},"work_email":{"type":["null","string"]},"hs_language":{"type":["null","string"]},"hs_pipeline":{"type":["null","string"]},"mobilephone":{"type":["null","string"]},"company_size":{"type":["null","string"]},"hs_object_id":{"type":["null","number"]},"hs_testpurge":{"type":["null","string"]},"hubspotscore":{"type":["null","number"]},"job_function":{"type":["null","string"]},"numemployees":{"type":["null","string"]},"annualrevenue":{"type":["null","string"]},"date_of_birth":{"type":["null","string"]},"days_to_close":{"type":["null","number"]},"hs_createdate":{"type":["null","string"],"format":"date-time"},"hs_email_open":{"type":["null","number"]},"hs_is_contact":{"type":["null","boolean"]},"ip_state_code":{"type":["null","string"]},"total_revenue":{"type":["null","number"]},"twitterhandle":{"type":["null","string"]},"field_of_study":{"type":["null","string"]},"hs_buying_role":{"type":["null","string"]},"hs_email_click":{"type":["null","number"]},"hs_ip_timezone":{"type":["null","string"]},"hs_is_unworked":{"type":["null","boolean"]},"hs_lead_status":{"type":["null","string"]},"hs_legal_basis":{"type":["null","string"]},"lifecyclestage":{"type":["null","string"]},"marital_status":{"type":["null","string"]},"graduation_date":{"type":["null","string"]},"hs_all_team_ids":{"type":["null","string"]},"hs_email_bounce":{"type":["null","number"]},"hs_email_domain":{"type":["null","string"]},"hs_email_optout":{"type":["null","boolean"]},"hs_testrollback":{"type":["null","string"]},"hs_time_in_lead":{"type":["null","number"]},"hubspot_team_id":{"type":["null","string"]},"ip_country_code":{"type":["null","string"]},"military_status":{"type":["null","string"]},"hs_all_owner_ids":{"type":["null","string"]},"hs_email_replied":{"type":["null","number"]},"hs_latest_source":{"type":["null","string"]},"hs_time_in_other":{"type":["null","number"]},"hubspot_owner_id":{"type":["null","string"]},"lastmodifieddate":{"type":["null","string"],"format":"date-time"},"hs_count_is_worked":{"type":["null","number"]},"hs_email_delivered":{"type":["null","number"]},"hs_google_click_id":{"type":["null","string"]},"notes_last_updated":{"type":["null","string"],"format":"date-time"},"recent_deal_amount":{"type":["null","number"]},"associatedcompanyid":{"type":["null","number"]},"hs_all_contact_vids":{"type":["null","string"]},"hs_analytics_source":{"type":["null","string"]},"hs_date_exited_lead":{"type":["null","string"],"format":"date-time"},"hs_lastmodifieddate":{"type":["null","string"],"format":"date-time"},"hs_time_in_customer":{"type":["null","number"]},"num_contacted_notes":{"type":["null","number"]},"relationship_status":{"type":["null","string"]},"hs_additional_emails":{"type":["null","string"]},"hs_analytics_revenue":{"type":["null","number"]},"hs_count_is_unworked":{"type":["null","number"]},"hs_date_entered_lead":{"type":["null","string"],"format":"date-time"},"hs_date_exited_other":{"type":["null","string"],"format":"date-time"},"hs_email_bad_address":{"type":["null","boolean"]},"hs_email_quarantined":{"type":["null","boolean"]},"hs_facebook_click_id":{"type":["null","string"]},"hs_merged_object_ids":{"type":["null","string"]},"notes_last_contacted":{"type":["null","string"],"format":"date-time"},"num_associated_deals":{"type":["null","number"]},"first_conversion_date":{"type":["null","string"],"format":"date-time"},"hs_analytics_last_url":{"type":["null","string"]},"hs_created_by_user_id":{"type":["null","number"]},"hs_date_entered_other":{"type":["null","string"],"format":"date-time"},"hs_time_in_evangelist":{"type":["null","number"]},"hs_time_in_subscriber":{"type":["null","number"]},"hs_updated_by_user_id":{"type":["null","number"]},"num_conversion_events":{"type":["null","number"]},"hs_analytics_first_url":{"type":["null","string"]},"hs_email_is_ineligible":{"type":["null","boolean"]},"hs_facebook_ad_clicked":{"type":["null","boolean"]},"hs_time_in_opportunity":{"type":["null","number"]},"hs_unique_creation_key":{"type":["null","string"]},"recent_conversion_date":{"type":["null","string"],"format":"date-time"},"recent_deal_close_date":{"type":["null","string"],"format":"date-time"},"first_deal_created_date":{"type":["null","string"],"format":"date-time"},"hs_analytics_num_visits":{"type":["null","number"]},"hs_date_exited_customer":{"type":["null","string"],"format":"date-time"},"hs_email_last_open_date":{"type":["null","string"],"format":"date-time"},"hs_email_last_send_date":{"type":["null","string"],"format":"date-time"},"hs_latest_source_data_1":{"type":["null","string"]},"hs_latest_source_data_2":{"type":["null","string"]},"webinareventlastupdated":{"type":["null","number"]},"hs_date_entered_customer":{"type":["null","string"],"format":"date-time"},"hs_email_first_open_date":{"type":["null","string"],"format":"date-time"},"hs_email_first_send_date":{"type":["null","string"],"format":"date-time"},"hs_email_last_click_date":{"type":["null","string"],"format":"date-time"},"hs_email_last_email_name":{"type":["null","string"]},"hs_email_last_reply_date":{"type":["null","string"],"format":"date-time"},"hs_email_optout_22856586":{"type":["null","string"]},"hs_email_optout_23214812":{"type":["null","string"]},"hs_sequences_is_enrolled":{"type":["null","boolean"]},"notes_next_activity_date":{"type":["null","string"],"format":"date-time"},"hs_avatar_filemanager_key":{"type":["null","string"]},"hs_calculated_merged_vids":{"type":["null","string"]},"hs_date_exited_evangelist":{"type":["null","string"],"format":"date-time"},"hs_date_exited_subscriber":{"type":["null","string"],"format":"date-time"},"hs_email_first_click_date":{"type":["null","string"],"format":"date-time"},"hs_email_first_reply_date":{"type":["null","string"],"format":"date-time"},"hs_user_ids_of_all_owners":{"type":["null","string"]},"hs_all_accessible_team_ids":{"type":["null","string"]},"hs_analytics_last_referrer":{"type":["null","string"]},"hs_analytics_source_data_1":{"type":["null","string"]},"hs_analytics_source_data_2":{"type":["null","string"]},"hs_calculated_phone_number":{"type":["null","string"]},"hs_date_entered_evangelist":{"type":["null","string"],"format":"date-time"},"hs_date_entered_subscriber":{"type":["null","string"],"format":"date-time"},"hs_date_exited_opportunity":{"type":["null","string"],"format":"date-time"},"hs_document_last_revisited":{"type":["null","string"],"format":"date-time"},"hs_emailconfirmationstatus":{"type":["null","string"]},"hs_has_active_subscription":{"type":["null","number"]},"hs_latest_meeting_activity":{"type":["null","string"],"format":"date-time"},"hs_sales_email_last_opened":{"type":["null","string"],"format":"date-time"},"hubspot_owner_assigneddate":{"type":["null","string"],"format":"date-time"},"first_conversion_event_name":{"type":["null","string"]},"hs_analytics_first_referrer":{"type":["null","string"]},"hs_analytics_last_timestamp":{"type":["null","string"],"format":"date-time"},"hs_analytics_num_page_views":{"type":["null","number"]},"hs_calculated_mobile_number":{"type":["null","string"]},"hs_content_membership_notes":{"type":["null","string"]},"hs_created_by_conversations":{"type":["null","boolean"]},"hs_date_entered_opportunity":{"type":["null","string"],"format":"date-time"},"hs_email_hard_bounce_reason":{"type":["null","string"]},"hs_email_quarantined_reason":{"type":["null","string"]},"hs_last_sales_activity_date":{"type":["null","string"],"format":"date-time"},"hs_latest_sequence_enrolled":{"type":["null","number"]},"hs_lifecyclestage_lead_date":{"type":["null","string"],"format":"date-time"},"hs_sa_first_engagement_date":{"type":["null","string"],"format":"date-time"},"hs_sales_email_last_clicked":{"type":["null","string"],"format":"date-time"},"hs_sales_email_last_replied":{"type":["null","string"],"format":"date-time"},"hs_sequences_enrolled_count":{"type":["null","number"]},"hs_time_to_first_engagement":{"type":["null","number"]},"associatedcompanylastupdated":{"type":["null","number"]},"hs_analytics_first_timestamp":{"type":["null","string"],"format":"date-time"},"hs_content_membership_status":{"type":["null","string"]},"hs_lifecyclestage_other_date":{"type":["null","string"],"format":"date-time"},"hs_sa_first_engagement_descr":{"type":["null","string"]},"num_unique_conversion_events":{"type":["null","number"]},"recent_conversion_event_name":{"type":["null","string"]},"surveymonkeyeventlastupdated":{"type":["null","number"]},"hs_first_engagement_object_id":{"type":["null","number"]},"hs_latest_sequence_ended_date":{"type":["null","string"],"format":"date-time"},"hs_time_in_salesqualifiedlead":{"type":["null","number"]},"hs_calculated_form_submissions":{"type":["null","string"]},"hs_conversations_visitor_email":{"type":["null","string"]},"engagements_last_meeting_booked":{"type":["null","string"],"format":"date-time"},"hs_analytics_average_page_views":{"type":["null","number"]},"hs_lifecyclestage_customer_date":{"type":["null","string"],"format":"date-time"},"hs_email_hard_bounce_reason_enum":{"type":["null","string"]},"hs_last_sales_activity_timestamp":{"type":["null","string"],"format":"date-time"},"hs_latest_sequence_enrolled_date":{"type":["null","string"],"format":"date-time"},"hs_latest_sequence_finished_date":{"type":["null","string"],"format":"date-time"},"hs_analytics_last_visit_timestamp":{"type":["null","string"],"format":"date-time"},"hs_date_exited_salesqualifiedlead":{"type":["null","string"],"format":"date-time"},"hs_first_subscription_create_date":{"type":["null","string"],"format":"date-time"},"hs_lifecyclestage_evangelist_date":{"type":["null","string"],"format":"date-time"},"hs_lifecyclestage_subscriber_date":{"type":["null","string"],"format":"date-time"},"hs_time_in_marketingqualifiedlead":{"type":["null","number"]},"hs_analytics_first_visit_timestamp":{"type":["null","string"],"format":"date-time"},"hs_analytics_num_event_completions":{"type":["null","number"]},"hs_date_entered_salesqualifiedlead":{"type":["null","string"],"format":"date-time"},"hs_latest_sequence_unenrolled_date":{"type":["null","string"],"format":"date-time"},"hs_latest_subscription_create_date":{"type":["null","string"],"format":"date-time"},"hs_lifecyclestage_opportunity_date":{"type":["null","string"],"format":"date-time"},"hs_sa_first_engagement_object_type":{"type":["null","string"]},"hs_content_membership_registered_at":{"type":["null","string"],"format":"date-time"},"hs_calculated_phone_number_area_code":{"type":["null","string"]},"hs_email_customer_quarantined_reason":{"type":["null","string"]},"hs_email_sends_since_last_engagement":{"type":["null","number"]},"hs_sequences_actively_enrolled_count":{"type":["null","number"]},"hs_content_membership_email_confirmed":{"type":["null","boolean"]},"hs_date_exited_marketingqualifiedlead":{"type":["null","string"],"format":"date-time"},"hs_searchable_calculated_phone_number":{"type":["null","string"]},"engagements_last_meeting_booked_medium":{"type":["null","string"]},"engagements_last_meeting_booked_source":{"type":["null","string"]},"hs_calculated_phone_number_region_code":{"type":["null","string"]},"hs_date_entered_marketingqualifiedlead":{"type":["null","string"],"format":"date-time"},"hs_searchable_calculated_mobile_number":{"type":["null","string"]},"hs_calculated_phone_number_country_code":{"type":["null","string"]},"engagements_last_meeting_booked_campaign":{"type":["null","string"]},"hs_lifecyclestage_salesqualifiedlead_date":{"type":["null","string"],"format":"date-time"},"hs_user_ids_of_all_notification_followers":{"type":["null","string"]},"hs_analytics_last_touch_converting_campaign":{"type":["null","string"]},"hs_user_ids_of_all_notification_unfollowers":{"type":["null","string"]},"hs_analytics_first_touch_converting_campaign":{"type":["null","string"]},"hs_lifecyclestage_marketingqualifiedlead_date":{"type":["null","string"],"format":"date-time"},"hs_content_membership_registration_email_sent_at":{"type":["null","string"],"format":"date-time"},"hs_content_membership_registration_domain_sent_to":{"type":["null","string"]},"hs_searchable_calculated_international_phone_number":{"type":["null","string"]},"hs_searchable_calculated_international_mobile_number":{"type":["null","string"]}}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[updatedAt],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1024bf43[stream=io.airbyte.protocol.models.AirbyteStream@5ad6d353[name=hs_test2_deals,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","string"]},"archived":{"type":["null","boolean"]},"contacts":{"type":["null","array"],"items":{"type":["null","string"]}},"companies":{"type":["null","array"],"items":{"type":["null","integer"]}},"createdAt":{"type":["null","string"]},"dealstage":{"type":["null","object"],"properties":{"value":{"type":["null","string"]},"versions":{"type":["null","array"],"items":{"type":["null","object"]}},"timestamp":{"type":["null","integer"]}}},"updatedAt":{"type":["null","string"]},"properties":{"type":"object","properties":{"amount":{"type":["null","number"]},"hs_acv":{"type":["null","number"]},"hs_arr":{"type":["null","number"]},"hs_mrr":{"type":["null","number"]},"hs_tcv":{"type":["null","number"]},"dealname":{"type":["null","string"]},"dealtype":{"type":["null","string"]},"pipeline":{"type":["null","string"]},"closedate":{"type":["null","string"],"format":"date-time"},"dealstage":{"type":["null","string"]},"num_notes":{"type":["null","number"]},"createdate":{"type":["null","string"],"format":"date-time"},"description":{"type":["null","string"]},"hs_priority":{"type":["null","string"]},"hs_is_closed":{"type":["null","boolean"]},"hs_next_step":{"type":["null","string"]},"hs_object_id":{"type":["null","number"]},"days_to_close":{"type":["null","number"]},"hs_createdate":{"type":["null","string"],"format":"date-time"},"hs_all_team_ids":{"type":["null","string"]},"hubspot_team_id":{"type":["null","string"]},"hs_all_owner_ids":{"type":["null","string"]},"hs_closed_amount":{"type":["null","number"]},"hs_is_closed_won":{"type":["null","boolean"]},"hubspot_owner_id":{"type":["null","string"]},"closed_won_reason":{"type":["null","string"]},"closed_lost_reason":{"type":["null","string"]},"hs_forecast_amount":{"type":["null","number"]},"notes_last_updated":{"type":["null","string"],"format":"date-time"},"hs_analytics_source":{"type":["null","string"]},"hs_lastmodifieddate":{"type":["null","string"],"format":"date-time"},"hs_predicted_amount":{"type":["null","number"]},"hs_projected_amount":{"type":["null","number"]},"num_contacted_notes":{"type":["null","number"]},"hs_merged_object_ids":{"type":["null","string"]},"hs_time_in_closedwon":{"type":["null","number"]},"notes_last_contacted":{"type":["null","string"],"format":"date-time"},"hs_created_by_user_id":{"type":["null","number"]},"hs_time_in_closedlost":{"type":["null","number"]},"hs_updated_by_user_id":{"type":["null","number"]},"hs_likelihood_to_close":{"type":["null","number"]},"hs_num_target_accounts":{"type":["null","number"]},"hs_unique_creation_key":{"type":["null","string"]},"amount_in_home_currency":{"type":["null","number"]},"hs_forecast_probability":{"type":["null","number"]},"hs_time_in_contractsent":{"type":["null","number"]},"num_associated_contacts":{"type":["null","number"]},"hs_date_exited_closedwon":{"type":["null","string"],"format":"date-time"},"notes_next_activity_date":{"type":["null","string"],"format":"date-time"},"hs_date_entered_closedwon":{"type":["null","string"],"format":"date-time"},"hs_date_exited_closedlost":{"type":["null","string"],"format":"date-time"},"hs_deal_stage_probability":{"type":["null","number"]},"hs_time_in_qualifiedtobuy":{"type":["null","number"]},"hs_user_ids_of_all_owners":{"type":["null","string"]},"hs_all_accessible_team_ids":{"type":["null","string"]},"hs_analytics_source_data_1":{"type":["null","string"]},"hs_analytics_source_data_2":{"type":["null","string"]},"hs_date_entered_closedlost":{"type":["null","string"],"format":"date-time"},"hs_latest_meeting_activity":{"type":["null","string"],"format":"date-time"},"hubspot_owner_assigneddate":{"type":["null","string"],"format":"date-time"},"hs_date_exited_contractsent":{"type":["null","string"],"format":"date-time"},"hs_manual_forecast_category":{"type":["null","string"]},"hs_sales_email_last_replied":{"type":["null","string"],"format":"date-time"},"hs_date_entered_contractsent":{"type":["null","string"],"format":"date-time"},"hs_date_exited_qualifiedtobuy":{"type":["null","string"],"format":"date-time"},"hs_date_entered_qualifiedtobuy":{"type":["null","string"],"format":"date-time"},"engagements_last_meeting_booked":{"type":["null","string"],"format":"date-time"},"hs_time_in_appointmentscheduled":{"type":["null","number"]},"hs_deal_stage_probability_shadow":{"type":["null","number"]},"hs_time_in_decisionmakerboughtin":{"type":["null","number"]},"hs_time_in_presentationscheduled":{"type":["null","number"]},"hs_all_assigned_business_unit_ids":{"type":["null","string"]},"hs_closed_amount_in_home_currency":{"type":["null","number"]},"hs_date_exited_appointmentscheduled":{"type":["null","string"],"format":"date-time"},"hs_date_entered_appointmentscheduled":{"type":["null","string"],"format":"date-time"},"hs_date_exited_decisionmakerboughtin":{"type":["null","string"],"format":"date-time"},"hs_date_exited_presentationscheduled":{"type":["null","string"],"format":"date-time"},"hs_predicted_amount_in_home_currency":{"type":["null","number"]},"hs_projected_amount_in_home_currency":{"type":["null","number"]},"hs_date_entered_decisionmakerboughtin":{"type":["null","string"],"format":"date-time"},"hs_date_entered_presentationscheduled":{"type":["null","string"],"format":"date-time"},"hs_deal_amount_calculation_preference":{"type":["null","string"]},"engagements_last_meeting_booked_medium":{"type":["null","string"]},"engagements_last_meeting_booked_source":{"type":["null","string"]},"engagements_last_meeting_booked_campaign":{"type":["null","string"]},"hs_user_ids_of_all_notification_followers":{"type":["null","string"]},"hs_user_ids_of_all_notification_unfollowers":{"type":["null","string"]},"hs_line_item_global_term_hs_discount_percentage":{"type":["null","string"]},"hs_line_item_global_term_recurringbillingfrequency":{"type":["null","string"]},"hs_line_item_global_term_hs_recurring_billing_period":{"type":["null","string"]},"hs_line_item_global_term_hs_discount_percentage_enabled":{"type":["null","boolean"]},"hs_line_item_global_term_hs_recurring_billing_start_date":{"type":["null","string"]},"hs_line_item_global_term_recurringbillingfrequency_enabled":{"type":["null","boolean"]},"hs_line_item_global_term_hs_recurring_billing_period_enabled":{"type":["null","boolean"]},"hs_line_item_global_term_hs_recurring_billing_start_date_enabled":{"type":["null","boolean"]}}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[updatedAt],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[updatedAt],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}]]
2021-11-15 22:33:27 INFO () ConfigRepository(updateConnectionState):500 - Updating connection b41a9892-a610-4c7b-aa4f-477deac66540 state: io.airbyte.config.State@6e08d46d[state={}]
2021-11-15 22:33:27 INFO () DatabaseConfigPersistence(updateConfigRecord):258 - Updating STANDARD_SYNC_STATE record b41a9892-a610-4c7b-aa4f-477deac66540
2021-11-15 22:33:27 INFO () TemporalAttemptExecution(get):116 - Executing worker wrapper. Airbyte version: 0.32.0-alpha
2021-11-15 22:33:27 WARN () Databases(createPostgresDatabaseWithRetry):41 - Waiting for database to become available...
2021-11-15 22:33:27 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2021-11-15 22:33:27 INFO () Databases(createPostgresDatabaseWithRetry):58 - Database available!
2021-11-15 22:33:27 INFO () DefaultNormalizationWorker(run):46 - Running normalization.
2021-11-15 22:33:27 INFO () DefaultNormalizationRunner(runProcess):114 - Running with normalization version: airbyte/normalization-mysql:0.1.59
2021-11-15 22:33:27 INFO () LineGobbler(voidCall):82 - Checking if airbyte/normalization-mysql:0.1.59 exists...
2021-11-15 22:33:27 INFO () LineGobbler(voidCall):82 - airbyte/normalization-mysql:0.1.59 was found locally.
2021-11-15 22:33:27 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/61/2/normalize --network host --log-driver none airbyte/normalization-mysql:0.1.59 run --integration-type mysql --config destination_config.json --catalog destination_catalog.json
�[32mnormalization�[0m - 2021-11-15 22:33:27 INFO () LineGobbler(voidCall):82 - Running: transform-config --config destination_config.json --integration-type mysql --out /data/61/2/normalize
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Namespace(config='destination_config.json', integration_type=<DestinationType.mysql: 'mysql'>, out='/data/61/2/normalize')
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - transform_mysql
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Running: transform-catalog --integration-type mysql --profile-config-dir /data/61/2/normalize --catalog destination_catalog.json --out /data/61/2/normalize/models/generated/ --json-column _airbyte_data
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Processing destination_catalog.json...
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_lifecyclestage_marketingqualifiedlead_date (#45) to hs_lifecyclestage_mar_ingqualifiedlead_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_lifecyclestage_marketingqualifiedlead_date (#45) to hs_lifecyclestage_mar_ingqualifiedlead_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_email_sent_at (#48) to hs_content_membership_tration_email_sent_at (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_email_sent_at (#48) to hs_content_membership_tration_email_sent_at (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_domain_sent_to (#49) to hs_content_membership_ration_domain_sent_to (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_domain_sent_to (#49) to hs_content_membership_ration_domain_sent_to (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_phone_number (#51) to hs_searchable_calcula_national_phone_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_phone_number (#51) to hs_searchable_calcula_national_phone_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_mobile_number (#52) to hs_searchable_calcula_ational_mobile_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_mobile_number (#52) to hs_searchable_calcula_ational_mobile_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage (#47) to hs_line_item_global_t_s_discount_percentage (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage (#47) to hs_line_item_global_t_s_discount_percentage (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency (#50) to hs_line_item_global_t_rringbillingfrequency (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency (#50) to hs_line_item_global_t_rringbillingfrequency (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period (#52) to hs_line_item_global_t_urring_billing_period (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period (#52) to hs_line_item_global_t_urring_billing_period (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage_enabled (#55) to hs_line_item_global_t_nt_percentage_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage_enabled (#55) to hs_line_item_global_t_nt_percentage_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date (#56) to hs_line_item_global_t_ng_billing_start_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date (#56) to hs_line_item_global_t_ng_billing_start_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency_enabled (#58) to hs_line_item_global_t_lingfrequency_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency_enabled (#58) to hs_line_item_global_t_lingfrequency_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period_enabled (#60) to hs_line_item_global_t_illing_period_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period_enabled (#60) to hs_line_item_global_t_illing_period_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date_enabled (#64) to hs_line_item_global_t_ng_start_date_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date_enabled (#64) to hs_line_item_global_t_ng_start_date_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_contacts_ab1.sql from hs_test2_contacts
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_contacts_ab2.sql from hs_test2_contacts
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_contacts_ab3.sql from hs_test2_contacts
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_incremental/gateway_test_2021_08_05/hs_test2_contacts.sql from hs_test2_contacts
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_ab1.sql from hs_test2_deals
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_ab2.sql from hs_test2_deals
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_ab3.sql from hs_test2_deals
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_incremental/gateway_test_2021_08_05/hs_test2_deals.sql from hs_test2_deals
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_lifecyclestage_marketingqualifiedlead_date (#45) to hs_lifecyclestage_mar_ingqualifiedlead_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_lifecyclestage_marketingqualifiedlead_date (#45) to hs_lifecyclestage_mar_ingqualifiedlead_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_email_sent_at (#48) to hs_content_membership_tration_email_sent_at (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_email_sent_at (#48) to hs_content_membership_tration_email_sent_at (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_domain_sent_to (#49) to hs_content_membership_ration_domain_sent_to (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_content_membership_registration_domain_sent_to (#49) to hs_content_membership_ration_domain_sent_to (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_phone_number (#51) to hs_searchable_calcula_national_phone_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_phone_number (#51) to hs_searchable_calcula_national_phone_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_mobile_number (#52) to hs_searchable_calcula_ational_mobile_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_searchable_calculated_international_mobile_number (#52) to hs_searchable_calcula_ational_mobile_number (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_contacts_properties_ab1.sql from hs_test2_contacts/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_contacts_properties_ab2.sql from hs_test2_contacts/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_contacts_properties_ab3.sql from hs_test2_contacts/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_incremental/gateway_test_2021_08_05/hs_test2_contacts_properties.sql from hs_test2_contacts/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Ignoring stream 'contacts' from hs_test2_deals/contacts because properties list is empty
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Ignoring stream 'companies' from hs_test2_deals/companies because properties list is empty
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_dealstage_ab1.sql from hs_test2_deals/dealstage
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_dealstage_ab2.sql from hs_test2_deals/dealstage
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_dealstage_ab3.sql from hs_test2_deals/dealstage
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_incremental/gateway_test_2021_08_05/hs_test2_deals_dealstage.sql from hs_test2_deals/dealstage
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage (#47) to hs_line_item_global_t_s_discount_percentage (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage (#47) to hs_line_item_global_t_s_discount_percentage (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency (#50) to hs_line_item_global_t_rringbillingfrequency (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency (#50) to hs_line_item_global_t_rringbillingfrequency (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period (#52) to hs_line_item_global_t_urring_billing_period (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period (#52) to hs_line_item_global_t_urring_billing_period (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage_enabled (#55) to hs_line_item_global_t_nt_percentage_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_discount_percentage_enabled (#55) to hs_line_item_global_t_nt_percentage_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date (#56) to hs_line_item_global_t_ng_billing_start_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date (#56) to hs_line_item_global_t_ng_billing_start_date (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency_enabled (#58) to hs_line_item_global_t_lingfrequency_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_recurringbillingfrequency_enabled (#58) to hs_line_item_global_t_lingfrequency_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period_enabled (#60) to hs_line_item_global_t_illing_period_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_period_enabled (#60) to hs_line_item_global_t_illing_period_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date_enabled (#64) to hs_line_item_global_t_ng_start_date_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - Truncating hs_line_item_global_term_hs_recurring_billing_start_date_enabled (#64) to hs_line_item_global_t_ng_start_date_enabled (#44)
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_properties_ab1.sql from hs_test2_deals/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_properties_ab2.sql from hs_test2_deals/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_ctes/gateway_test_2021_08_05/hs_test2_deals_properties_ab3.sql from hs_test2_deals/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 -   Generating airbyte_incremental/gateway_test_2021_08_05/hs_test2_deals_properties.sql from hs_test2_deals/properties
�[32mnormalization�[0m - 2021-11-15 22:33:28 INFO () LineGobbler(voidCall):82 - detected no config file for ssh, assuming ssh is off.
�[32mnormalization�[0m - 2021-11-15 22:33:29 INFO () LineGobbler(voidCall):82 - Running with dbt=0.19.0
�[32mnormalization�[0m - 2021-11-15 22:33:31 INFO () LineGobbler(voidCall):82 - [�[33mWARNING�[0m]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
�[32mnormalization�[0m - 2021-11-15 22:33:31 INFO () LineGobbler(voidCall):82 - There are 2 unused configuration paths:
�[32mnormalization�[0m - 2021-11-15 22:33:31 INFO () LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_views
�[32mnormalization�[0m - 2021-11-15 22:33:31 INFO () LineGobbler(voidCall):82 - - models.airbyte_utils.generated.airbyte_tables
�[32mnormalization�[0m - 2021-11-15 22:33:31 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - Found 20 models, 0 tests, 0 snapshots, 0 analyses, 440 macros, 0 operations, 0 seed files, 2 sources, 0 exposures
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - 22:33:32 | Concurrency: 1 threads (target='prod')
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - 22:33:32 | 
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - 22:33:32 | 1 of 5 START table model gateway_test_2021_08_05.hs_test2_deals.............................................. [RUN]
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - 22:33:32 | 1 of 5 OK created table model gateway_test_2021_08_05.hs_test2_deals......................................... [�[32mUnknown cursor state/status 0�[0m in 0.14s]
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - 22:33:32 | 2 of 5 START table model gateway_test_2021_08_05.hs_test2_contacts........................................... [RUN]
�[32mnormalization�[0m - 2021-11-15 22:33:32 INFO () LineGobbler(voidCall):82 - 22:33:32 | 2 of 5 OK created table model gateway_test_2021_08_05.hs_test2_contacts...................................... [�[32mUnknown cursor state/status 9�[0m in 0.11s]
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | 3 of 5 START table model gateway_test_2021_08_05.hs_test2_deals_dealstage.................................... [RUN]
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | 3 of 5 OK created table model gateway_test_2021_08_05.hs_test2_deals_dealstage............................... [�[32mUnknown cursor state/status 0�[0m in 0.13s]
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | 4 of 5 START table model gateway_test_2021_08_05.hs_test2_deals_properties................................... [RUN]
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | 4 of 5 ERROR creating table model gateway_test_2021_08_05.hs_test2_deals_properties.......................... [�[31mERROR�[0m in 0.12s]
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | 5 of 5 START table model gateway_test_2021_08_05.hs_test2_contacts_properties................................ [RUN]
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | 5 of 5 ERROR creating table model gateway_test_2021_08_05.hs_test2_contacts_properties....................... [�[31mERROR�[0m in 0.19s]
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | 
�[32mnormalization�[0m - 2021-11-15 22:33:33 INFO () LineGobbler(voidCall):82 - 22:33:33 | Finished running 5 table models in 1.77s.
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - �[31mCompleted with 2 errors and 0 warnings:�[0m
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - �[33mDatabase Error in model hs_test2_deals_properties (models/generated/airbyte_incremental/gateway_test_2021_08_05/hs_test2_deals_properties.sql)�[0m
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 -   1118 (42000): Row size too large. The maximum row size for the used table type, not counting BLOBs, is 65535. This includes storage overhead, check the manual. You have to change some columns to TEXT or BLOBs
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 -   compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/gateway_test_2021_08_05/hs_test2_deals_properties.sql
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - �[33mDatabase Error in model hs_test2_contacts_properties (models/generated/airbyte_incremental/gateway_test_2021_08_05/hs_test2_contacts_properties.sql)�[0m
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 -   1118 (42000): Row size too large. The maximum row size for the used table type, not counting BLOBs, is 65535. This includes storage overhead, check the manual. You have to change some columns to TEXT or BLOBs
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 -   compiled SQL at ../build/run/airbyte_utils/models/generated/airbyte_incremental/gateway_test_2021_08_05/hs_test2_contacts_properties.sql
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - 
�[32mnormalization�[0m - 2021-11-15 22:33:34 INFO () LineGobbler(voidCall):82 - Done. PASS=3 WARN=0 ERROR=2 SKIP=0 TOTAL=5
2021-11-15 22:33:34 INFO () TemporalAttemptExecution(lambda$getWorkerThread$2):170 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:57) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	... 3 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:142) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:832) [?:?]
2021-11-15 22:33:34 INFO () TemporalAttemptExecution(get):137 - Stopping cancellation check scheduling...
2021-11-15 22:33:34 WARN () POJOActivityTaskHandler$POJOActivityImplementation(execute):243 - Activity failure. ActivityId=f67266d1-e2e7-3d93-9355-a855582dae1f, activityType=Normalize, attempt=1
java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2063) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:135) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:100) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:564) ~[?:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:277) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:216) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:181) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:192) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:154) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:73) ~[temporal-sdk-1.0.4.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630) [?:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:57) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
	... 1 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:142) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:167) ~[io.airbyte-airbyte-workers-0.32.0-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:832) [?:?]

Steps to Reproduce

1. Connect HubSpot to MySQL
2. Run sync
3. Sync fails: Row size too large. The maximum row size for the used table type, not counting BLOBs, is 65535.

Are you willing to submit a PR?

No

[sherifnada]

I believe this means we should use LONGTEXT on the mysql destination to address cases like this

[keu]

This ticket needs to be reproduced first:

• create connection Hubspot + MySQL
• do sync
• if there are no errors check the schema of destination tables

my guess LONGTEXT won't help since *TEXT and BLOB columns are stored separately. The cause could be related to actual number of columns (the fix might require denormalization of streams/tables)

[htrueman]

Succeeded to reproduce the bug logs.txt.
Going to try to change the field type. If this won't help, then going to denormalize the table.