2022-04-07 08:45:39 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-07 08:45:39 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/36/2/logs.log
2022-04-07 08:45:39 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-07 08:45:39 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 36 attempt id: 2
2022-04-07 08:45:39 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {sarvagram_lms.guest_user=full_refresh - overwrite, sarvagram_lms.cd_case_history=full_refresh - overwrite}
2022-04-07 08:45:39 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-07 08:45:40 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mysql:0.1.18 exists...
2022-04-07 08:45:40 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mysql:0.1.18 was found locally.
2022-04-07 08:45:40 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 36
2022-04-07 08:45:40 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/36/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.18 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=36 airbyte/destination-mysql:0.1.18 write --config destination_config.json --catalog destination_catalog.json
2022-04-07 08:45:40 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mysql:0.5.6 exists...
2022-04-07 08:45:40 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mysql:0.5.6 was found locally.
2022-04-07 08:45:40 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 36
2022-04-07 08:45:40 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/36/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mysql:0.5.6 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=36 airbyte/source-mysql:0.5.6 read --config source_config.json --catalog source_catalog.json
2022-04-07 08:45:40 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-07 08:45:40 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-07 08:45:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-07 08:45:40 source > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-07 08:45:40 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-07 08:45:40 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-07 08:45:40 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-07 08:45:40 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-07 08:45:40 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-07 08:45:40 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-07 08:45:40 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-07 08:45:41 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-07 08:45:41 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-07 08:45:42 source > 2022-04-07 08:45:42 INFO i.a.i.s.m.MySqlSource(main):206 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-04-07 08:45:42 destination > 2022-04-07 08:45:42 INFO i.a.i.d.m.MySQLDestination(main):125 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json}
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 6e4a0a32eaeb4d16a1f25ba6c6d2427f
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'}
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: b2d510fd243146c28e16486aec3d9e5b
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:43 source > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:43 destination > 2022-04-07 08:45:43 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-07 08:45:44 source > 2022-04-07 08:45:44 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-07 08:45:44 source > 2022-04-07 08:45:44 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-04-07 08:45:44 source > 2022-04-07 08:45:44 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='guest_user', namespace='sarvagram_lms'}, New Cursor Field: null. Resetting cursor value
2022-04-07 08:45:44 source > 2022-04-07 08:45:44 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='cd_case_history', namespace='sarvagram_lms'}, New Cursor Field: null. Resetting cursor value
2022-04-07 08:45:44 destination > 2022-04-07 08:45:44 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-07 08:45:44 destination > 2022-04-07 08:45:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=cd_case_history, namespace=airbyte_schema, outputSchemaName=airbyte_schema, tmpTableName=_airbyte_tmp_rtt_cd_case_history, outputTableName=_airbyte_raw_cd_case_history, syncMode=overwrite}
2022-04-07 08:45:44 destination > 2022-04-07 08:45:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=guest_user, namespace=airbyte_schema, outputSchemaName=airbyte_schema, tmpTableName=_airbyte_tmp_fml_guest_user, outputTableName=_airbyte_raw_guest_user, syncMode=overwrite}
2022-04-07 08:45:44 destination > 2022-04-07 08:45:44 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-07 08:45:44 destination > 2022-04-07 08:45:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 2 streams
2022-04-07 08:45:44 destination > 2022-04-07 08:45:44 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream cd_case_history. schema: airbyte_schema, tmp table name: _airbyte_tmp_rtt_cd_case_history
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document column doc_code (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document column doc_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column branches_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column brand_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column cat_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column emi (type DECIMAL[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column lead_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column prod_attr_req_json (type VARCHAR[5000]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column product_option (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column sub_cat_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column user_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table cd_case_history column vendor_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column end_use (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column product_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column product_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_end_use_master column product_code (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table leadintegrationlog column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table leadintegrationlog column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table leadintegrationlog column lead_req_json (type TEXT[65535]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table leadintegrationlog column lead_resp_json (type TEXT[65535]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table leadintegrationlog column lead_Id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column document_req_json (type TEXT[65535]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table sms_logs column document_resp_json (type TEXT[65535]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column expire_at (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column is_used (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column otp (type VARCHAR[6]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column lead_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table otp_master column mobile_number (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column add_line1 (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column add_line2 (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column age (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column alternate_no (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column area (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 destination > 2022-04-07 08:45:45 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream guest_user. schema: airbyte_schema, tmp table name: _airbyte_tmp_fml_guest_user
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column branch (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column city_town_village (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column created_user_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column crop (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column customer_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column dob (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column district (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column dwara_lead_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column education_status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column employee_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column end_use (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column entity_type (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column existing_cust (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column farm_service (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column franchisee_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column gender (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column is_lead_created_by_franchisee (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column is_others (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column is_this_whatsapp_no1 (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column is_this_whatsapp_no2 (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column isUserActive (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column isUserCallCentre (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column label (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column land_area (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column lead_created_by_excelupload (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column lead_created_date (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column lead_followup_date (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column lead_generator (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column lead_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column marital_status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column mobile_no1 (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column mobile_no2 (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column other_remark (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column pincode (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column pincode_autofetch_state (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column product_required_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column product_selection (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column product_type (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column rejection_remark (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column req_loan_amount (type DOUBLE[22]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column state (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column type_of_interaction (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column updated_user_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column user_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column user_role (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column village_master_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 destination > 2022-04-07 08:45:45 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed.
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column product_campaign (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column remarks (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column campaign_medium (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_dts column reference_code (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column location (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column mobile_number (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table guest_user column pincode (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column document_path (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column file_Name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column lead_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column sub_type (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table kyc_document_upload_details column type (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column campaign_desc (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column campaign_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column campaign_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column end_dt (type DATE[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column entry_dt (type DATE[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column start_dt (type DATE[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table product_campaign column update_dt (type DATE[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column created_user_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column crop (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column customer_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column district (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column document_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column duration (type DOUBLE[22]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column employee_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column estimated_area (type DOUBLE[22]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column from_date (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column from_time (type TIME[8]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column implement (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column kyc_doc_upload_path (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column lead_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column mobile_no (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column rate (type DOUBLE[22]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column select_kyc_doc (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column serial_number (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column service_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column state (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column status_updation_date (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column tehsil (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column to_date (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column to_time (type TIME[8]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column units (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column updated_user_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_farm_order_dts column village (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column add_line1 (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column add_line2 (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column age (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column alternate_no (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column area (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column branch (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column city_town_village (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column created_user_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column crop (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column customer_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column dob (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column district (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column education_status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column employee_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column end_use (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column entity_type (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column existing_cust (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column farm_service (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column gender (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column is_lead_created_by_franchisee (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column is_this_whatsapp_no1 (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column is_this_whatsapp_no2 (type BIT[1]) -> Json type io.airbyte.protocol.models.JsonSchemaType@514cd540
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column label (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column land_area (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column lead_created_date (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column lead_followup_date (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column lead_generator (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column lead_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column marital_status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column mobile_no1 (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column mobile_no2 (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column other_remark (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column pincode (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column pincode_autofetch_state (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column product_required_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column product_selection (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column product_type (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column rejection_remark (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column remarks (type LONGTEXT[2147483647]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column req_loan_amount (type DOUBLE[22]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column state (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column type_of_interaction (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column updated_user_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column user_name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column user_role (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lead_exception_dts column village_master_id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_lead_generators column lead_id (type VARCHAR[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lms_lead_generators column lead_generator (type VARCHAR[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table income_sources column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table income_sources column name (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column id (type BIGINT[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column entry_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column entry_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column ipadd (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column updt_by (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column updt_dt (type DATETIME[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column branches_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column brand_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column cat_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column emi (type DECIMAL[19]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column lead_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column prod_attr_req_json (type VARCHAR[5000]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column product_option (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column status (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column sub_cat_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column user_id (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column vendor_id (type INT[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@3effd4f3
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table lending_product_details column skucode (type VARCHAR[255]) -> Json type io.airbyte.protocol.models.JsonSchemaType@15f8701f
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.m.MySqlSource(getIncrementalIterators):189 - using CDC: false
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: cd_case_history
2022-04-07 08:45:45 source > 2022-04-07 08:45:45 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: guest_user
2022-04-07 08:45:46 source > 2022-04-07 08:45:46 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):124 - Closing database connection pool.
2022-04-07 08:45:46 source > 2022-04-07 08:45:46 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):126 - Closed database connection pool.
2022-04-07 08:45:46 source > 2022-04-07 08:45:46 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-07 08:45:46 source > 2022-04-07 08:45:46 INFO i.a.i.s.m.MySqlSource(main):208 - completed source: class io.airbyte.integrations.source.mysql.MySqlSource
2022-04-07 08:45:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 363 (101 KB)
2022-04-07 08:45:46 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 448804 bytes
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing cd_case_history: 210 records
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing guest_user: 153 records
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 2 streams
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream cd_case_history. schema airbyte_schema, tmp table _airbyte_tmp_rtt_cd_case_history, final table _airbyte_raw_cd_case_history
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream guest_user. schema airbyte_schema, tmp table _airbyte_tmp_fml_guest_user, final table _airbyte_raw_guest_user
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables.
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed.
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 2 streams
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream cd_case_history. schema airbyte_schema, tmp table name: _airbyte_tmp_rtt_cd_case_history
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream guest_user. schema airbyte_schema, tmp table name: _airbyte_tmp_fml_guest_user
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed.
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-07 08:45:46 destination > 2022-04-07 08:45:46 INFO i.a.i.d.m.MySQLDestination(main):127 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-07 08:45:46 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-04-07 08:45:46 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@1d28cf2b[status=completed,recordsSynced=363,bytesSynced=103956,startTime=1649321139997,endTime=1649321146603,totalStats=io.airbyte.config.SyncStats@1d344fad[recordsEmitted=363,bytesEmitted=103956,stateMessagesEmitted=0,recordsCommitted=363],streamStats=[io.airbyte.config.StreamSyncStats@1c7ed4fb[streamName=cd_case_history,stats=io.airbyte.config.SyncStats@4444725[recordsEmitted=210,bytesEmitted=91515,stateMessagesEmitted=<null>,recordsCommitted=210]], io.airbyte.config.StreamSyncStats@5fce9111[streamName=guest_user,stats=io.airbyte.config.SyncStats@60b8f462[recordsEmitted=153,bytesEmitted=12441,stateMessagesEmitted=<null>,recordsCommitted=153]]]]
2022-04-07 08:45:46 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-07 08:45:46 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained.
2022-04-07 08:45:46 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-07 08:45:46 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@610f2a2e[standardSyncSummary=io.airbyte.config.StandardSyncSummary@77a3b9b8[status=completed,recordsSynced=363,bytesSynced=103956,startTime=1649321139997,endTime=1649321146603,totalStats=io.airbyte.config.SyncStats@1d344fad[recordsEmitted=363,bytesEmitted=103956,stateMessagesEmitted=0,recordsCommitted=363],streamStats=[io.airbyte.config.StreamSyncStats@1c7ed4fb[streamName=cd_case_history,stats=io.airbyte.config.SyncStats@4444725[recordsEmitted=210,bytesEmitted=91515,stateMessagesEmitted=<null>,recordsCommitted=210]], io.airbyte.config.StreamSyncStats@5fce9111[streamName=guest_user,stats=io.airbyte.config.SyncStats@60b8f462[recordsEmitted=153,bytesEmitted=12441,stateMessagesEmitted=<null>,recordsCommitted=153]]]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@19e9f205[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2680c066[stream=io.airbyte.protocol.models.AirbyteStream@3ec6d0c2[name=cd_case_history,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"emi":{"type":"number"},"ipadd":{"type":"string"},"cat_id":{"type":"number"},"status":{"type":"string"},"lead_id":{"type":"string"},"updt_by":{"type":"string"},"updt_dt":{"type":"string"},"user_id":{"type":"string"},"brand_id":{"type":"number"},"entry_by":{"type":"string"},"entry_dt":{"type":"string"},"vendor_id":{"type":"number"},"sub_cat_id":{"type":"number"},"branches_id":{"type":"string"},"product_option":{"type":"string"},"prod_attr_req_json":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=airbyte_schema,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5442d0db[stream=io.airbyte.protocol.models.AirbyteStream@2ed798c[name=guest_user,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"name":{"type":"string"},"ipadd":{"type":"string"},"pincode":{"type":"string"},"updt_by":{"type":"string"},"updt_dt":{"type":"string"},"entry_by":{"type":"string"},"entry_dt":{"type":"string"},"location":{"type":"string"},"mobile_number":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=airbyte_schema,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-04-07 08:45:46 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-07 08:45:46 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/36/2/logs.log
2022-04-07 08:45:46 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-07 08:45:46 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-04-07 08:45:46 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-mysql:0.1.74
2022-04-07 08:45:46 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-mysql:0.1.74 exists...
2022-04-07 08:45:46 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-mysql:0.1.74 was found locally.
2022-04-07 08:45:46 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 36
2022-04-07 08:45:46 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/36/2/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.35.65-alpha airbyte/normalization-mysql:0.1.74 run --integration-type mysql --config destination_config.json --catalog destination_catalog.json
2022-04-07 08:45:47 normalization > Running: transform-config --config destination_config.json --integration-type mysql --out /data/36/2/normalize
2022-04-07 08:45:47 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.mysql: 'mysql'>, out='/data/36/2/normalize')
2022-04-07 08:45:47 normalization > transform_mysql
2022-04-07 08:45:47 normalization > Running: transform-catalog --integration-type mysql --profile-config-dir /data/36/2/normalize --catalog destination_catalog.json --out /data/36/2/normalize/models/generated/ --json-column _airbyte_data
2022-04-07 08:45:47 normalization > Processing destination_catalog.json...
2022-04-07 08:45:47 normalization >   Generating airbyte_ctes/airbyte_schema/cd_case_history_ab1.sql from cd_case_history
2022-04-07 08:45:47 normalization >   Generating airbyte_ctes/airbyte_schema/cd_case_history_ab2.sql from cd_case_history
2022-04-07 08:45:47 normalization >   Generating airbyte_ctes/airbyte_schema/cd_case_history_ab3.sql from cd_case_history
2022-04-07 08:45:47 normalization >   Generating airbyte_tables/airbyte_schema/cd_case_history.sql from cd_case_history
2022-04-07 08:45:47 normalization >   Generating airbyte_ctes/airbyte_schema/guest_user_ab1.sql from guest_user
2022-04-07 08:45:47 normalization >   Generating airbyte_ctes/airbyte_schema/guest_user_ab2.sql from guest_user
2022-04-07 08:45:47 normalization >   Generating airbyte_ctes/airbyte_schema/guest_user_ab3.sql from guest_user
2022-04-07 08:45:47 normalization >   Generating airbyte_tables/airbyte_schema/guest_user.sql from guest_user
2022-04-07 08:45:47 normalization > detected no config file for ssh, assuming ssh is off.
2022-04-07 08:45:48 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):158 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 3 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-07 08:45:48 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-07 08:45:48 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-07 08:45:48 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=dd9766b7-609d-3d40-8eea-c022deeb12f6, activityType=Normalize, attempt=1
java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:71) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at jdk.internal.reflect.GeneratedMethodAccessor191.invoke(Unknown Source) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.temporal.serviceclient.CheckedExceptionWrapper.wrap(CheckedExceptionWrapper.java:56) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInternal.wrap(WorkflowInternal.java:448) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.activity.Activity.wrap(Activity.java:51) ~[temporal-sdk-1.8.1.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:135) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:97) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 13 more
Caused by: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:129) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:97) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 13 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 1 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]