2022-05-25 08:07:20 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.38.4-alpha 2022-05-25 08:07:20 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/5139/0/logs.log 2022-05-25 08:07:20 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.38.4-alpha 2022-05-25 08:07:20 INFO i.a.w.DefaultReplicationWorker(run):109 - start sync worker. job id: 5139 attempt id: 0 2022-05-25 08:07:20 INFO i.a.w.DefaultReplicationWorker(run):121 - configured sync modes: {elearn.training_sessions=incremental - append_dedup} 2022-05-25 08:07:20 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-05-25 08:07:20 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-bigquery:1.1.6 exists... 2022-05-25 08:07:20 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-bigquery:1.1.6 was found locally. 2022-05-25 08:07:20 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 5139 2022-05-25 08:07:20 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/5139/0 --log-driver none --name destination-bigquery-write-5139-0-prdap --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery:1.1.6 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.38.4-alpha -e WORKER_JOB_ID=5139 airbyte/destination-bigquery:1.1.6 write --config destination_config.json --catalog destination_catalog.json 2022-05-25 08:07:20 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mysql:0.5.11 exists... 2022-05-25 08:07:20 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mysql:0.5.11 was found locally. 2022-05-25 08:07:20 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 5139 2022-05-25 08:07:20 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/5139/0 --log-driver none --name source-mysql-read-5139-0-qvrxw --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.38.4-alpha -e WORKER_JOB_ID=5139 airbyte/source-mysql:0.5.11 read --config source_config.json --catalog source_catalog.json 2022-05-25 08:07:20 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):382 - Destination output thread started. 2022-05-25 08:07:20 INFO i.a.w.DefaultReplicationWorker(run):163 - Waiting for source and destination threads to complete. 2022-05-25 08:07:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):292 - Replication thread started. 2022-05-25 08:07:21 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-05-25 08:07:21 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-25 08:07:21 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-25 08:07:21 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-25 08:07:21 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-05-25 08:07:21 source > SLF4J: Class path contains multiple SLF4J bindings. 2022-05-25 08:07:21 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-25 08:07:21 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-25 08:07:21 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-05-25 08:07:21 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-05-25 08:07:21 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-05-25 08:07:23 destination > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-05-25 08:07:23 source > 2022-05-25 08:07:23 INFO i.a.i.s.m.MySqlSource(main):210 - starting source: class io.airbyte.integrations.source.mysql.MySqlSource 2022-05-25 08:07:23 destination > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-05-25 08:07:23 destination > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE 2022-05-25 08:07:23 destination > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-05-25 08:07:23 source > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json} 2022-05-25 08:07:23 source > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-05-25 08:07:23 source > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ 2022-05-25 08:07:23 source > 2022-05-25 08:07:23 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'} 2022-05-25 08:07:23 destination > 2022-05-25 08:07:23 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-25 08:07:23 destination > 2022-05-25 08:07:23 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-25 08:07:23 destination > 2022-05-25 08:07:23 INFO i.a.i.d.b.BigQueryUtils(getLoadingMethod):303 - Selected loading method is set to: GCS 2022-05-25 08:07:23 source > 2022-05-25 08:07:23 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-25 08:07:23 source > 2022-05-25 08:07:23 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-25 08:07:23 source > 2022-05-25 08:07:23 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-25 08:07:23 source > 2022-05-25 08:07:23 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-25 08:07:24 destination > 2022-05-25 08:07:24 INFO i.a.i.d.s.S3FormatConfigs(getS3FormatConfig):22 - S3 format config: {"format_type":"AVRO","flattening":"No flattening","part_size_mb":"256"} 2022-05-25 08:07:24 destination > 2022-05-25 08:07:24 INFO i.a.i.d.b.BigQueryUtils(isKeepFilesInGcs):319 - All tmp files will be removed from GCS when replication is finished 2022-05-25 08:07:24 source > 2022-05-25 08:07:24 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-05-25 08:07:24 source > 2022-05-25 08:07:24 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2022-05-25 08:07:24 source > 2022-05-25 08:07:24 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='training_sessions', namespace='elearn'}, New Cursor Field: null. Resetting cursor value 2022-05-25 08:07:25 destination > 2022-05-25 08:07:25 INFO i.a.i.d.b.BigQueryDestination(getGcsRecordConsumer):286 - Creating BigQuery staging message consumer with staging ID d11ebe85-c497-4920-b70d-fbff212201fc at 2022-05-25T08:07:24.177Z 2022-05-25 08:07:25 destination > 2022-05-25 08:07:25 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$createWriteConfigs$1):86 - BigQuery write config: BigQueryWriteConfig[streamName=training_sessions, namespace=fr_elearn_airbyte, datasetId=fr_elearn_airbyte, datasetLocation=EU, tmpTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_tmp_ywq_training_sessions}}, targetTableId=GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_raw_training_sessions}}, tableSchema=Schema{fields=[Field{name=_airbyte_ab_id, type=STRING, mode=null, description=null, policyTags=null}, Field{name=_airbyte_emitted_at, type=TIMESTAMP, mode=null, description=null, policyTags=null}, Field{name=_airbyte_data, type=STRING, mode=null, description=null, policyTags=null}]}, syncMode=append_dedup, stagedFiles=[]] 2022-05-25 08:07:25 destination > 2022-05-25 08:07:25 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-05-25 08:07:25 destination > 2022-05-25 08:07:25 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):98 - Preparing tmp tables in destination started for 1 streams 2022-05-25 08:07:25 destination > 2022-05-25 08:07:25 INFO i.a.i.d.b.BigQueryGcsOperations(createSchemaIfNotExists):86 - Creating dataset fr_elearn_airbyte 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table questions_v2 column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table questions_v2 column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table questions_v2 column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column slug (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column reading_time (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column part_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column order (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column published_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column draft_updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table chapters column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_progress column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_progress column learner_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_progress column finished_activities (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_progress column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_progress column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_progress column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column slug (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column order (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table courses column icon_filename (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column name (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column type (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column chapter_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column syllabus_module_id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column position (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column import_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_activities column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column week (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column year (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column learner_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column day_1_time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column day_2_time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column day_3_time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column day_4_time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column day_5_time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column day_6_time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column day_7_time (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table weekly_time_trackers column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_goals column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_goals column goal (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_goals column goal_months (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_goals column duration_per_week (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_goals column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_goals column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_goals column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column type (type VARCHAR[60]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column draft (type BIT[1]) -> JsonSchemaType({type=boolean}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column points (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column media (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column statements (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column faq (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column correction (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column question_id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column author_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column chapter_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column part_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column course_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table question_revisions column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table reading_stats column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table reading_stats column user_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table reading_stats column nb_times (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table reading_stats column nb_seconds (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table reading_stats column chapter_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table reading_stats column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table reading_stats column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column learner_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column status (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column type (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column questions_count (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column score (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column success (type TINYINT UNSIGNED[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column series_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table training_sessions column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_frequencies column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_frequencies column study_plan_goal_id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_frequencies column sessions_per_week (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_frequencies column duration_per_session (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_frequencies column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_frequencies column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table study_plan_frequencies column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table migrations column migration (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table migrations column batch (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column filename (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column chapter_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column type (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column part_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table source_media column course_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table series column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table series column type (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table series column course_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table series column content (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table series column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table series column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table learners column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table learners column study_plan_goal_id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table learners column study_plan_frequency_id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table learners column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table learners column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column status (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column type (type VARCHAR[60]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column points (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column media (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column statements (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column faq (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column correction (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column question_id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column author_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column chapter_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column part_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_questions column course_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table readiness_score column learner_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table readiness_score column score (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table readiness_score column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table readiness_score column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table failed_jobs column id (type BIGINT UNSIGNED[20]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table failed_jobs column connection (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table failed_jobs column queue (type TEXT[65535]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table failed_jobs column payload (type LONGTEXT[2147483647]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table failed_jobs column exception (type LONGTEXT[2147483647]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table failed_jobs column failed_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column type (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column starts_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column ends_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column url (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_streams column series_url (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_stream_playlists column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_stream_playlists column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_stream_playlists column url (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_stream_playlists column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_stream_playlists column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table live_stream_playlists column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column name (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column slug (type VARCHAR[255]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column course_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column order (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table parts column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_series column id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_series column type (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_series column course_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_series column content (type JSON[1073741824]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_series column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table archived_series column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column id (type CHAR[36]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column name (type VARCHAR[100]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column course_id (type INT UNSIGNED[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column position (type TINYINT[3]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column import_id (type INT[10]) -> JsonSchemaType({type=number}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column created_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column updated_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):138 - Table syllabus_modules column deleted_at (type TIMESTAMP[19]) -> JsonSchemaType({type=string}) 2022-05-25 08:07:25 source > 2022-05-25 08:07:25 INFO i.a.i.s.m.MySqlSource(getIncrementalIterators):193 - using CDC: false 2022-05-25 08:07:26 source > 2022-05-25 08:07:25 ERROR i.a.i.b.s.SshWrappedSource(read):56 - Exception occurred while getting the delegate read iterator, closing SSH tunnel 2022-05-25 08:07:26 source > java.lang.IllegalStateException: No cursor field specified for stream attempting to do incremental. 2022-05-25 08:07:26 source > at io.airbyte.db.IncrementalUtils.getCursorField(IncrementalUtils.java:14) ~[io.airbyte.airbyte-db-lib-0.36.7-alpha.jar:?] 2022-05-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 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-25 08:07:26 source > Exception in thread "main" java.lang.IllegalStateException: No cursor field specified for stream attempting to do incremental. 2022-05-25 08:07:26 source > at io.airbyte.db.IncrementalUtils.getCursorField(IncrementalUtils.java:14) 2022-05-25 08:07:26 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.createReadIterator(AbstractDbSource.java:216) 2022-05-25 08:07:26 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getSelectedIterators(AbstractDbSource.java:186) 2022-05-25 08:07:26 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.getIncrementalIterators(AbstractDbSource.java:157) 2022-05-25 08:07:26 source > at io.airbyte.integrations.source.mysql.MySqlSource.getIncrementalIterators(MySqlSource.java:194) 2022-05-25 08:07:26 source > at io.airbyte.integrations.source.mysql.MySqlSource.getIncrementalIterators(MySqlSource.java:46) 2022-05-25 08:07:26 source > at io.airbyte.integrations.source.relationaldb.AbstractDbSource.read(AbstractDbSource.java:114) 2022-05-25 08:07:26 source > at io.airbyte.integrations.base.ssh.SshWrappedSource.read(SshWrappedSource.java:54) 2022-05-25 08:07:26 source > at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:153) 2022-05-25 08:07:26 source > at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) 2022-05-25 08:07:26 source > at io.airbyte.integrations.source.mysql.MySqlSource.main(MySqlSource.java:211) 2022-05-25 08:07:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$6):334 - Source has no more messages, closing connection. 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BigQueryGcsOperations(createTmpTableIfNotExists):94 - Creating tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_tmp_ywq_training_sessions}} 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BigQueryUtils(createPartitionedTable):131 - Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_tmp_ywq_training_sessions}} 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BigQueryGcsOperations(createStageIfNotExists):101 - Creating staging path for stream training_sessions (dataset fr_elearn_airbyte): prod/fr_elearn_airbyte_training_sessions/2022/05/25/08/d11ebe85-c497-4920-b70d-fbff212201fc/ 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):97 - Storage Object airbyte-prod/prod/fr_elearn_airbyte_training_sessions/2022/05/25/08/d11ebe85-c497-4920-b70d-fbff212201fc/ does not exist in bucket; creating... 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.s.S3StorageOperations(createBucketObjectIfNotExists):99 - Storage Object airbyte-prod/prod/fr_elearn_airbyte_training_sessions/2022/05/25/08/d11ebe85-c497-4920-b70d-fbff212201fc/ has been created in bucket. 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onStartFunction$3):107 - Preparing tmp tables in destination completed. 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):92 - Flushing all 0 current buffers (0 bytes in total) 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):137 - Copying into tables in destination started for 1 streams 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BigQueryGcsOperations(copyIntoTmpTableFromStage):122 - Uploading records from staging files to tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_tmp_ywq_training_sessions}} (dataset fr_elearn_airbyte): [] 2022-05-25 08:07:27 destination > 2022-05-25 08:07:27 INFO i.a.i.d.b.BigQueryGcsOperations(copyIntoTargetTable):162 - Copying data from tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_tmp_ywq_training_sessions}} to target table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_raw_training_sessions}} (dataset fr_elearn_airbyte, sync mode append_dedup) 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.b.u.AbstractBigQueryUploader(copyTable):185 - successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_tmp_ywq_training_sessions}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_raw_training_sessions}} 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):156 - Finalizing tables in destination completed 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):159 - Cleaning up destination started for 1 streams 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.b.BigQueryGcsOperations(dropTableIfExists):172 - Deleting tmp table GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=fr_elearn_airbyte, tableId=_airbyte_tmp_ywq_training_sessions}} (dataset fr_elearn_airbyte) 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.b.BigQueryGcsOperations(dropStageIfExists):183 - Cleaning up staging path for stream training_sessions (dataset fr_elearn_airbyte): prod/fr_elearn_airbyte_training_sessions 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.g.GcsStorageOperations(cleanUpObjects):43 - Deleting object prod/fr_elearn_airbyte_training_sessions/2022/05/25/08/d11ebe85-c497-4920-b70d-fbff212201fc/ 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.s.S3StorageOperations(cleanUpBucketObject):268 - Storage bucket prod/fr_elearn_airbyte_training_sessions has been cleaned-up (1 objects were deleted)... 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.d.b.BigQueryStagingConsumerFactory(lambda$onCloseFunction$5):164 - Cleaning up destination completed. 2022-05-25 08:07:31 destination > 2022-05-25 08:07:31 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-05-25 08:07:31 ERROR i.a.w.DefaultReplicationWorker(run):174 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source cannot be stopped! 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:167) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:59) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.4-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.38.4-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:131) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:59) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.38.4-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source cannot be stopped! at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:338) ~[io.airbyte-airbyte-workers-0.38.4-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 Caused by: 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.38.4-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:336) ~[io.airbyte-airbyte-workers-0.38.4-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-25 08:07:31 INFO i.a.w.DefaultReplicationWorker(run):233 - sync summary: io.airbyte.config.ReplicationAttemptSummary@38190c77[status=failed,recordsSynced=0,bytesSynced=0,startTime=1653466040662,endTime=1653466051552,totalStats=io.airbyte.config.SyncStats@11f62a61[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-05-25 08:07:31 INFO i.a.w.DefaultReplicationWorker(run):262 - Source did not output any state messages 2022-05-25 08:07:31 WARN i.a.w.DefaultReplicationWorker(run):273 - State capture: No state retained. 2022-05-25 08:07:31 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-05-25 08:07:31 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@70b4f01f[standardSyncSummary=io.airbyte.config.StandardSyncSummary@35b6606d[status=failed,recordsSynced=0,bytesSynced=0,startTime=1653466040662,endTime=1653466051552,totalStats=io.airbyte.config.SyncStats@11f62a61[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@2b3f0257[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@44914bc[stream=io.airbyte.protocol.models.AirbyteStream@532a2822[name=training_sessions,jsonSchema={"type":"object","properties":{"id":{"type":"string"},"type":{"type":"number"},"score":{"type":"number"},"status":{"type":"number"},"success":{"type":"number"},"series_id":{"type":"number"},"created_at":{"type":"string"},"learner_id":{"type":"number"},"updated_at":{"type":"string"},"_ab_cdc_log_pos":{"type":"number"},"questions_count":{"type":"number"},"_ab_cdc_log_file":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=fr_elearn_airbyte,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@55999f22[failureOrigin=source,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source cannot be stopped!,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@6e7027c[additionalProperties={attemptNumber=0, jobId=5139}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source cannot be stopped! 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 cannot be stopped! at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:338) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more Caused by: 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) at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:336) ... 4 more ,retryable=,timestamp=1653466046219]]] 2022-05-25 08:07:31 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-05-25 08:07:31 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/5139/0/logs.log 2022-05-25 08:07:31 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.38.4-alpha 2022-05-25 08:07:31 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization. 2022-05-25 08:07:31 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.2.0 2022-05-25 08:07:31 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.2.0 exists... 2022-05-25 08:07:31 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.2.0 was found locally. 2022-05-25 08:07:31 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 5139 2022-05-25 08:07:31 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/5139/0/normalize --log-driver none --name normalization-normalize-5139-0-jxeuy --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.38.4-alpha airbyte/normalization:0.2.0 run --integration-type bigquery --config destination_config.json --catalog destination_catalog.json 2022-05-25 08:07:32 normalization > Running: transform-config --config destination_config.json --integration-type bigquery --out /data/5139/0/normalize 2022-05-25 08:07:32 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/5139/0/normalize') 2022-05-25 08:07:32 normalization > transform_bigquery 2022-05-25 08:07:32 normalization > Running: transform-catalog --integration-type bigquery --profile-config-dir /data/5139/0/normalize --catalog destination_catalog.json --out /data/5139/0/normalize/models/generated/ --json-column _airbyte_data 2022-05-25 08:07:33 normalization > Processing destination_catalog.json... 2022-05-25 08:07:33 normalization > Generating airbyte_ctes/fr_elearn_airbyte/training_sessions_ab1.sql from training_sessions 2022-05-25 08:07:33 normalization > Generating airbyte_ctes/fr_elearn_airbyte/training_sessions_ab2.sql from training_sessions 2022-05-25 08:07:33 normalization > Generating airbyte_views/fr_elearn_airbyte/training_sessions_stg.sql from training_sessions 2022-05-25 08:07:33 normalization > Generating airbyte_incremental/scd/fr_elearn_airbyte/training_sessions_scd.sql from training_sessions 2022-05-25 08:07:33 normalization > Generating airbyte_incremental/fr_elearn_airbyte/training_sessions.sql from training_sessions 2022-05-25 08:07:33 normalization > detected no config file for ssh, assuming ssh is off. 2022-05-25 08:07:36 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-05-25 08:07:36 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-05-25 08:07:36 normalization > 2022-05-25 08:07:36 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-05-25 08:07:36 normalization > 2022-05-25 08:07:39 normalization > 08:07:39 Running with dbt=1.0.0 2022-05-25 08:07:39 normalization > 08:07:39 Partial parse save file not found. Starting full parse. 2022-05-25 08:07:41 normalization > 08:07:41 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-05-25 08:07:41 normalization > There are 1 unused configuration paths: 2022-05-25 08:07:41 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-05-25 08:07:41 normalization > 2022-05-25 08:07:41 normalization > 08:07:41 Found 5 models, 0 tests, 0 snapshots, 0 analyses, 544 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2022-05-25 08:07:41 normalization > 08:07:41 2022-05-25 08:07:42 normalization > 08:07:42 Concurrency: 8 threads (target='prod') 2022-05-25 08:07:42 normalization > 08:07:42 2022-05-25 08:07:42 normalization > 08:07:42 1 of 3 START view model _airbyte_fr_elearn_airbyte.training_sessions_stg................................................ [RUN] 2022-05-25 08:07:43 normalization > 08:07:43 1 of 3 OK created view model _airbyte_fr_elearn_airbyte.training_sessions_stg........................................... [OK in 0.81s] 2022-05-25 08:07:43 normalization > 08:07:43 2 of 3 START incremental model fr_elearn_airbyte.training_sessions_scd.................................................. [RUN] 2022-05-25 08:07:43 normalization > 08:07:43 08:07:43 + `data-265818`.fr_elearn_airbyte.`training_sessions_scd`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-05-25 08:07:46 normalization > 08:07:46 2 of 3 OK created incremental model fr_elearn_airbyte.training_sessions_scd............................................. [CREATE TABLE (0.0 rows, 0 processed) in 3.15s] 2022-05-25 08:07:46 normalization > 08:07:46 3 of 3 START incremental model fr_elearn_airbyte.training_sessions...................................................... [RUN] 2022-05-25 08:07:46 normalization > 08:07:46 08:07:46 + `data-265818`.fr_elearn_airbyte.`training_sessions`._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-05-25 08:07:50 normalization > 08:07:50 3 of 3 OK created incremental model fr_elearn_airbyte.training_sessions................................................. [CREATE TABLE (0.0 rows, 0 processed) in 4.06s] 2022-05-25 08:07:50 normalization > 08:07:50 2022-05-25 08:07:50 normalization > 08:07:50 Finished running 1 view model, 2 incremental models in 9.16s. 2022-05-25 08:07:50 normalization > 08:07:50 2022-05-25 08:07:50 normalization > 08:07:50 Completed successfully 2022-05-25 08:07:50 normalization > 08:07:50 2022-05-25 08:07:50 normalization > 08:07:50 Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3 2022-05-25 08:07:51 INFO i.a.w.DefaultNormalizationWorker(run):71 - Normalization executed in 19 seconds. 2022-05-25 08:07:51 INFO i.a.w.DefaultNormalizationWorker(run):77 - Normalization summary: io.airbyte.config.NormalizationSummary@54820b73[startTime=1653466051660,endTime=1653466071454] 2022-05-25 08:07:51 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling... 2022-05-25 08:07:51 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating... 2022-05-25 08:07:51 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.credential: is not defined in the schema and the schema does not allow additional properties, $.part_size_mb: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.gcs_bucket_path: is not defined in the schema and the schema does not allow additional properties, $.keep_files_in_gcs-bucket: is not defined in the schema and the schema does not allow additional properties, $.method: must be a constant value Standard 2022-05-25 08:07:51 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.credential.hmac_key_access_id: object found, string expected, $.credential.hmac_key_secret: object found, string expected