2022-05-11 14:19:25 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-05-11 14:19:25 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/5891/0/logs.log 2022-05-11 14:19:25 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-05-11 14:19:25 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 5891 attempt id: 0 2022-05-11 14:19:25 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {crm_trips.trips=incremental - append_dedup} 2022-05-11 14:19:25 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-05-11 14:19:25 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-clickhouse:0.1.5 exists... 2022-05-11 14:19:25 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-clickhouse:0.1.5 was found locally. 2022-05-11 14:19:25 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 5891 2022-05-11 14:19:25 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/5891/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-clickhouse:0.1.5 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=5891 airbyte/destination-clickhouse:0.1.5 write --config destination_config.json --catalog destination_catalog.json 2022-05-11 14:19:25 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mysql:0.5.11 exists... 2022-05-11 14:19:25 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mysql:0.5.11 was found locally. 2022-05-11 14:19:25 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 5891 2022-05-11 14:19:25 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/5891/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:0.5.11 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=5891 airbyte/source-mysql:0.5.11 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-05-11 14:19:25 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-05-11 14:19:25 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-05-11 14:19:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-05-11 14:19:26 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-05-11 14:19:26 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-11 14:19:26 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-11 14:19:26 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-05-11 14:19:26 source > SLF4J: Class path contains multiple SLF4J bindings. 2022-05-11 14:19:26 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-11 14:19:26 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-11 14:19:26 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-05-11 14:19:26 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-05-11 14:19:26 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-05-11 14:19:28 source > 2022-05-11 14:19:28 INFO i.a.i.s.m.MySqlSource(main):210 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource 2022-05-11 14:19:28 destination > 2022-05-11 14:19:28 INFO i.a.i.d.c.ClickhouseDestination(main):96 - starting destination: class io.airbyte.integrations.destination.clickhouse.ClickhouseDestination 2022-05-11 14:19:28 source > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2022-05-11 14:19:28 source > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-05-11 14:19:28 source > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ 2022-05-11 14:19:28 source > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2022-05-11 14:19:28 destination > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-05-11 14:19:28 destination > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-05-11 14:19:28 destination > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-05-11 14:19:28 destination > 2022-05-11 14:19:28 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-05-11 14:19:28 source > 2022-05-11 14:19:28 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-05-11 14:19:29 source > 2022-05-11 14:19:29 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-05-11 14:19:29 source > 2022-05-11 14:19:29 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-05-11 14:19:29 source > 2022-05-11 14:19:29 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-05-11 14:19:29 destination > 2022-05-11 14:19:29 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-05-11 14:19:29 destination > 2022-05-11 14:19:29 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-05-11 14:19:29 destination > 2022-05-11 14:19:29 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-05-11 14:19:29 destination > 2022-05-11 14:19:29 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-05-11 14:19:29 source > 2022-05-11 14:19:29 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-05-11 14:19:29 source > 2022-05-11 14:19:29 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2022-05-11 14:19:29 source > 2022-05-11 14:19:29 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trips', namespace='crm_trips'}, New Cursor Field: null. Resetting cursor value 2022-05-11 14:19:29 destination > 2022-05-11 14:19:29 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-05-11 14:19:29 destination > 2022-05-11 14:19:29 INFO r.y.c.ClickHouseDriver():49 - Driver registered 2022-05-11 14:19:29 destination > 2022-05-11 14:19:29 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=gwat_dev_new_auroratrips, namespace=crm_trips, outputSchemaName=crm_trips, tmpTableName=_airbyte_tmp_abn_gwat_dev_new_auroratrips, outputTableName=_airbyte_raw_gwat_dev_new_auroratrips, syncMode=append_dedup} 2022-05-11 14:19:30 destination > 2022-05-11 14:19:30 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-05-11 14:19:30 destination > 2022-05-11 14:19:30 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams 2022-05-11 14:19:30 destination > 2022-05-11 14:19:30 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream gwat_dev_new_auroratrips. schema: crm_trips, tmp table name: _airbyte_tmp_abn_gwat_dev_new_auroratrips 2022-05-11 14:19:30 destination > 2022-05-11 14:19:30 WARN r.y.c.ClickhouseJdbcUrlParser(parseUriQueryPart):84 - don't know how to handle parameter pair: 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rate_polls column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rate_polls column source (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rate_polls column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rate_polls column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rate_polls column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rate_polls column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_tags column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_tags column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_tags column enabled (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_tags column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_tags column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_tags column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_tags column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column destination_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column name (type VARCHAR[250]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column requirements (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table visa column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column status (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column is_public (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column division (type CHAR[64]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column destination (type CHAR[64]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column trip_name (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column code (type CHAR[16]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column partner_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column region (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column duration_type (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column max_duration (type BIGINT UNSIGNED[20]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column min_duration (type BIGINT UNSIGNED[20]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column AUD (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column CAD (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column USD (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column GBP (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column EUR (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column NZD (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column created_at (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column new (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column most_popular (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column popularity (type BIGINT[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column min_age (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_trips column max_age (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column destination_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column division_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column status (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column display_on_staging (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column division (type CHAR[64]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column region_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column destination (type CHAR[64]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column city_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column city (type CHAR[64]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column region (type CHAR[128]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column trip_name (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column code (type CHAR[16]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column trip_link (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column banner_img (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column temp_destination (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column origin_currency (type CHAR[3]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column pricing_method (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column exchange_rate_date (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column has_origin_margin (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column use_exchange_rates (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column duration_type (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column partner_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column is_public (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column margin_type_is_fixed (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column staff (type VARCHAR[200]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column global_exclusive (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column submission_date (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column modified_date (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column total_deals (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column accept_deposit (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column max_companion (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column min_companion (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column gworld_invitation (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips column deal_expiry_date (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column exchange_rate_poll_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column currency_from (type CHAR[3]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column currency_to (type CHAR[3]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column rate (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column last_used (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column active (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table exchange_rates column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column cut_off (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column availability_unit (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_configs column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_activity_tags column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_activity_tags column tag_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column title (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column description (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column icon (type CHAR[45]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column included (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column conditions (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions_config column tags (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column inclusions_config_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column description (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column order (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column tags (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column conditions (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column teaser (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column drop_off_time (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column drop_off_location (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column pick_up_time (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table inclusions column pick_up_location (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column title (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column description (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column icon (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on_config column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column title (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column trip_options_config_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column description (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column is_included (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options column supplier_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_types column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_types column name (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_types column icon (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_types column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_types column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_types column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_types column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column name (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column description (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column file_key (type VARCHAR[1000]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column ref (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column ref_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column type (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column mime (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table galleries column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column status_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column date (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column comment (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column tags (type VARCHAR[250]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column intake_capacity (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column promo_id (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column modifier_decrease (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table availabilities column modifier_type_percentage (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips_visas column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips_visas column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips_visas column visa_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips_visas column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips_visas column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips_visas column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trips_visas column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents_categories column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents_categories column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents_categories column category_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents_categories column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents_categories column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents_categories column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents_categories column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column name (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column capacity (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column icon_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sleeping_arrangment column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column title (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column icon (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column description (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_options_config column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column division (type CHAR[64]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column division_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column trip_name (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column code (type CHAR[16]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column has_origin_margin (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column use_exchange_rates (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column region (type CHAR[128]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column city (type CHAR[64]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column status (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column meta_title (type VARCHAR[70]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column meta_description (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column url (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column lat (type DECIMAL[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column lng (type DECIMAL[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column overview (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column details (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column location (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column itinerary_teaser (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column inclusions_count (type BIGINT[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column itineraries_count (type BIGINT[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column prices_count (type BIGINT[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column durations_count (type BIGINT[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table v_technical_validation column availabilities_count (type BIGINT[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_addon column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_addon column itinerary_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_addon column addon_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_addon column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_addon column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_addon column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary_addon column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column title (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column content (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table cheatsheets column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column ref (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column ref_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column amount (type DECIMAL[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column currency (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column exchange_rate_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table trip_prices column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column priority (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column required (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column declaration (type VARCHAR[512]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column active (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column condition (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column exclude (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column validation_message (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column control_type (type VARCHAR[45]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column platform (type VARCHAR[45]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table legal_declarations column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column type (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column value (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualifications column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column ref (type VARCHAR[256]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column ref_id (type VARCHAR[256]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column m_zoom_level (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column m_lat (type DECIMAL[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column m_lng (type DECIMAL[19]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column country (type VARCHAR[128]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column region (type VARCHAR[128]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column city (type VARCHAR[128]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table map_details column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations column duration (type CHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column category_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column description (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column file_name (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column s3_key (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column mime (type CHAR[128]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column size (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 destination > 2022-05-11 14:19:31 WARN r.y.c.ClickhouseJdbcUrlParser(parseUriQueryPart):84 - don't know how to handle parameter pair: 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table documents column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column internal_name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column _cb (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table sources column _lmb (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column ref (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column ref_id (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column suppliers_category_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table confing_supplier_categories column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column sleeping_arr_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column capacity (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column can_share (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column _lmb (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column is_included (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column description (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column single_supplement (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column title (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table rooms column supplier_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column name (type CHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column internal_name (type CHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column secondary_name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column type (type CHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column content (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column summary (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column status (type CHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table divisions column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column table_name (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column field_name (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column record_id (type BIGINT UNSIGNED[20]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column value (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column staff_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table activity_log column action (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column qualification_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column country (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column value (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column _cb (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table qualification_sources column _lmb (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column ref_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column ref (type VARCHAR[20]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column source_id (type BIGINT UNSIGNED[20]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column source_name (type VARCHAR[50]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column version_hash (type VARCHAR[32]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_versions column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column duration_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column availability_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table durations_availabilities column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column title (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column description (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column add_on_config_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column prepaid_availability (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column is_included (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table add_on column supplier_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column trip_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column title (type CHAR[255]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column content (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column priority (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column _ca (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column _cb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column _lma (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column _lmb (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column type_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column parent_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column duration (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column teaser (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column location_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table itinerary column itinerary_type_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 INFO i.a.i.s.m.MySqlSource(getIncrementalIterators):193 - using CDC: false 2022-05-11 14:19:31 source > 2022-05-11 14:19:31 ERROR i.a.i.b.s.SshWrappedSource(read):56 - Exception occurred while getting the delegate read iterator, closing SSH tunnel 2022-05-11 14:19:31 source > java.lang.IllegalStateException: No cursor field specified for stream attempting to do incremental. 2022-05-11 14:19:31 source > at io.airbyte.db.IncrementalUtils.getCursorField(IncrementalUtils.java:14) ~[io.airbyte.airbyte-db-lib-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.createReadIterator(AbstractDbSource.java:216) ~[io.airbyte.airbyte-integrations.connectors-source-relational-db-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getSelectedIterators(AbstractDbSource.java:186) ~[io.airbyte.airbyte-integrations.connectors-source-relational-db-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getIncrementalIterators(AbstractDbSource.java:157) ~[io.airbyte.airbyte-integrations.connectors-source-relational-db-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.mysql.MySqlSource.getIncrementalIterators(MySqlSource.java:194) ~[io.airbyte.airbyte-integrations.connectors-source-mysql-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.mysql.MySqlSource.getIncrementalIterators(MySqlSource.java:46) ~[io.airbyte.airbyte-integrations.connectors-source-mysql-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.read(AbstractDbSource.java:114) ~[io.airbyte.airbyte-integrations.connectors-source-relational-db-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.base.ssh.SshWrappedSource.read(SshWrappedSource.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:153) [io.airbyte.airbyte-integrations.bases-base-java-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.mysql.MySqlSource.main(MySqlSource.java:211) [io.airbyte.airbyte-integrations.connectors-source-mysql-0.36.7-alpha.jar:?] 2022-05-11 14:19:31 source > Exception in thread "main" java.lang.IllegalStateException: No cursor field specified for stream attempting to do incremental. 2022-05-11 14:19:31 source > at io.airbyte.db.IncrementalUtils.getCursorField(IncrementalUtils.java:14) 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.createReadIterator(AbstractDbSource.java:216) 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getSelectedIterators(AbstractDbSource.java:186) 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getIncrementalIterators(AbstractDbSource.java:157) 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.mysql.MySqlSource.getIncrementalIterators(MySqlSource.java:194) 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.mysql.MySqlSource.getIncrementalIterators(MySqlSource.java:46) 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.read(AbstractDbSource.java:114) 2022-05-11 14:19:31 source > at io.airbyte.integrations.base.ssh.SshWrappedSource.read(SshWrappedSource.java:54) 2022-05-11 14:19:31 source > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:153) 2022-05-11 14:19:31 source > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) 2022-05-11 14:19:31 source > at io.airbyte.integrations.source.mysql.MySqlSource.main(MySqlSource.java:211) 2022-05-11 14:19:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 0 (0 bytes) 2022-05-11 14:19:31 destination > 2022-05-11 14:19:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed. 2022-05-11 14:19:31 destination > 2022-05-11 14:19:31 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-05-11 14:19:31 destination > 2022-05-11 14:19:31 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-05-11 14:19:31 destination > 2022-05-11 14:19:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):161 - Finalizing tables in destination started for 1 streams 2022-05-11 14:19:31 destination > 2022-05-11 14:19:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):166 - Finalizing stream gwat_dev_new_auroratrips. schema crm_trips, tmp table _airbyte_tmp_abn_gwat_dev_new_auroratrips, final table _airbyte_raw_gwat_dev_new_auroratrips 2022-05-11 14:19:32 destination > 2022-05-11 14:19:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):179 - Executing finalization of tables. 2022-05-11 14:19:32 destination > 2022-05-11 14:19:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Finalizing tables in destination completed. 2022-05-11 14:19:32 destination > 2022-05-11 14:19:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):184 - Cleaning tmp tables in destination started for 1 streams 2022-05-11 14:19:32 destination > 2022-05-11 14:19:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):188 - Cleaning tmp table in destination started for stream gwat_dev_new_auroratrips. schema crm_trips, tmp table name: _airbyte_tmp_abn_gwat_dev_new_auroratrips 2022-05-11 14:19:32 destination > 2022-05-11 14:19:32 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):193 - Cleaning tmp tables in destination completed. 2022-05-11 14:19:32 destination > 2022-05-11 14:19:32 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-05-11 14:19:32 destination > 2022-05-11 14:19:32 INFO i.a.i.d.c.ClickhouseDestination(main):98 - completed destination: class io.airbyte.integrations.destination.clickhouse.ClickhouseDestination 2022-05-11 14:19:32 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. 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.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] ... 1 more 2022-05-11 14:19:32 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@3c533bf0[status=failed,recordsSynced=0,bytesSynced=0,startTime=1652278765753,endTime=1652278772420,totalStats=io.airbyte.config.SyncStats@675469b6[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-05-11 14:19:32 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-05-11 14:19:32 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@71151659[state={}] 2022-05-11 14:19:32 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-05-11 14:19:32 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@512d94b2[standardSyncSummary=io.airbyte.config.StandardSyncSummary@45071f69[status=failed,recordsSynced=0,bytesSynced=0,startTime=1652278765753,endTime=1652278772420,totalStats=io.airbyte.config.SyncStats@675469b6[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=io.airbyte.config.State@71151659[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@29f9f80d[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@1416d225[stream=io.airbyte.protocol.models.AirbyteStream@29234c11[name=gwat_dev_new_auroratrips,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"_ca":{"type":"number"},"_cb":{"type":"number"},"_lma":{"type":"number"},"_lmb":{"type":"number"},"city":{"type":"string"},"code":{"type":"string"},"staff":{"type":"string"},"region":{"type":"string"},"status":{"type":"string"},"city_id":{"type":"number"},"division":{"type":"string"},"is_public":{"type":"boolean"},"region_id":{"type":"number"},"trip_link":{"type":"string"},"trip_name":{"type":"string"},"banner_img":{"type":"string"},"partner_id":{"type":"number"},"destination":{"type":"string"},"division_id":{"type":"number"},"total_deals":{"type":"number"},"duration_type":{"type":"string"},"max_companion":{"type":"number"},"min_companion":{"type":"number"},"modified_date":{"type":"number"},"accept_deposit":{"type":"number"},"destination_id":{"type":"number"},"pricing_method":{"type":"string"},"_ab_cdc_log_pos":{"type":"number"},"origin_currency":{"type":"string"},"submission_date":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"deal_expiry_date":{"type":"number"},"global_exclusive":{"type":"boolean"},"temp_destination":{"type":"string"},"gworld_invitation":{"type":"boolean"},"has_origin_margin":{"type":"boolean"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"display_on_staging":{"type":"boolean"},"exchange_rate_date":{"type":"number"},"use_exchange_rates":{"type":"number"},"margin_type_is_fixed":{"type":"boolean"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=crm_trips,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@5422e20b[failureOrigin=source,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@32fd5112[additionalProperties={attemptNumber=0, jobId=5891}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1652278771634]]] 2022-05-11 14:19:32 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-05-11 14:19:32 INFO i.a.c.p.ConfigRepository(updateConnectionState):773 - Updating connection f7c9cd28-d109-4fc2-b42d-7c59d1ce086f state: io.airbyte.config.State@60d92398[state={}] 2022-05-11 14:19:32 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/5891/0/logs.log 2022-05-11 14:19:32 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-05-11 14:19:32 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization. 2022-05-11 14:19:32 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-clickhouse:0.1.75 2022-05-11 14:19:32 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-clickhouse:0.1.75 exists... 2022-05-11 14:19:32 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-clickhouse:0.1.75 was found locally. 2022-05-11 14:19:32 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 5891 2022-05-11 14:19:32 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/5891/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.36.1-alpha airbyte/normalization-clickhouse:0.1.75 run --integration-type clickhouse --config destination_config.json --catalog destination_catalog.json 2022-05-11 14:19:32 normalization > Running: transform-config --config destination_config.json --integration-type clickhouse --out /data/5891/0/normalize 2022-05-11 14:19:33 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/5891/0/normalize') 2022-05-11 14:19:33 normalization > transform_clickhouse 2022-05-11 14:19:33 normalization > Running: transform-catalog --integration-type clickhouse --profile-config-dir /data/5891/0/normalize --catalog destination_catalog.json --out /data/5891/0/normalize/models/generated/ --json-column _airbyte_data 2022-05-11 14:19:33 normalization > Processing destination_catalog.json... 2022-05-11 14:19:33 normalization > Generating airbyte_ctes/crm_trips/gwat_dev_new_auroratrips_ab1.sql from gwat_dev_new_auroratrips 2022-05-11 14:19:33 normalization > Generating airbyte_ctes/crm_trips/gwat_dev_new_auroratrips_ab2.sql from gwat_dev_new_auroratrips 2022-05-11 14:19:33 normalization > Generating airbyte_views/crm_trips/gwat_dev_new_auroratrips_stg.sql from gwat_dev_new_auroratrips 2022-05-11 14:19:33 normalization > Generating airbyte_incremental/scd/crm_trips/gwat_dev_new_auroratrips_scd.sql from gwat_dev_new_auroratrips 2022-05-11 14:19:33 normalization > Generating airbyte_incremental/crm_trips/gwat_dev_new_auroratrips.sql from gwat_dev_new_auroratrips 2022-05-11 14:19:33 normalization > detected no config file for ssh, assuming ssh is off. 2022-05-11 14:19:36 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-05-11 14:19:36 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-05-11 14:19:36 normalization > 2022-05-11 14:19:36 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-05-11 14:19:36 normalization > 2022-05-11 14:19:39 normalization > 14:19:39 Running with dbt=1.0.0 2022-05-11 14:19:39 normalization > 14:19:39 Partial parse save file not found. Starting full parse. 2022-05-11 14:19:41 normalization > 14:19:41 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-05-11 14:19:41 normalization > There are 1 unused configuration paths: 2022-05-11 14:19:41 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-05-11 14:19:41 normalization > 2022-05-11 14:19:41 normalization > 14:19:41 Found 5 models, 0 tests, 0 snapshots, 0 analyses, 530 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2022-05-11 14:19:41 normalization > 14:19:41 2022-05-11 14:19:42 normalization > 14:19:42 Concurrency: 1 threads (target='prod') 2022-05-11 14:19:42 normalization > 14:19:42 2022-05-11 14:19:42 normalization > 14:19:42 1 of 3 START view model _airbyte_crm_trips.gwat_dev_new_auroratrips_stg................................................. [RUN] 2022-05-11 14:19:43 normalization > 14:19:43 1 of 3 OK created view model _airbyte_crm_trips.gwat_dev_new_auroratrips_stg............................................ [OK in 0.97s] 2022-05-11 14:19:43 normalization > 14:19:43 2 of 3 START incremental model crm_trips.gwat_dev_new_auroratrips_scd................................................... [RUN] 2022-05-11 14:19:46 normalization > 14:19:46 2 of 3 OK created incremental model crm_trips.gwat_dev_new_auroratrips_scd.............................................. [OK in 3.70s] 2022-05-11 14:19:46 normalization > 14:19:46 3 of 3 START incremental model crm_trips.gwat_dev_new_auroratrips....................................................... [RUN] 2022-05-11 14:19:49 normalization > 14:19:49 3 of 3 OK created incremental model crm_trips.gwat_dev_new_auroratrips.................................................. [OK in 2.55s] 2022-05-11 14:19:49 normalization > 14:19:49 2022-05-11 14:19:49 normalization > 14:19:49 Finished running 1 view model, 2 incremental models in 8.51s. 2022-05-11 14:19:49 normalization > 14:19:49 2022-05-11 14:19:49 normalization > 14:19:49 Completed successfully 2022-05-11 14:19:49 normalization > 14:19:49 2022-05-11 14:19:49 normalization > 14:19:49 Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3 2022-05-11 14:19:49 INFO i.a.w.DefaultNormalizationWorker(run):71 - Normalization executed in 17 seconds. 2022-05-11 14:19:49 INFO i.a.w.DefaultNormalizationWorker(run):77 - Normalization summary: io.airbyte.config.NormalizationSummary@65c2dff[startTime=1652278772508,endTime=1652278789789] 2022-05-11 14:19:49 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-05-11 14:19:49 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...