2022-04-06 20:24:05 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.64-alpha 2022-04-06 20:24:05 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/10/0/logs.log 2022-04-06 20:24:05 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.64-alpha 2022-04-06 20:24:05 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword example - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-06 20:24:05 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword existingJavaType - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-04-06 20:24:05 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 10 attempt id: 0 2022-04-06 20:24:05 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {example_com_inc.countries=full_refresh - append, example_com_inc.partners=full_refresh - append, example_com_inc.stage_transitions=full_refresh - append, example_com_inc.observations_library=full_refresh - append, example_com_inc.crops=full_refresh - append, example_com_inc.trial_varieties=full_refresh - append, example_com_inc.trial_types=full_refresh - append, example_com_inc.crop_varieties=full_refresh - append, example_com_inc.crop_variety_stages=full_refresh - append, example_com_inc.agroclimatic_regions=full_refresh - append, example_com_inc.seasons=full_refresh - append, example_com_inc.stages=full_refresh - append, example_com_inc.users=full_refresh - append, example_com_inc.breeders=full_refresh - append, example_com_inc.trait_categories=full_refresh - append, example_com_inc.observation_comments_history=full_refresh - append, example_com_inc.country_transitions=full_refresh - append, example_com_inc.derived_observations=full_refresh - append, example_com_inc.required_data_entry=full_refresh - append, example_com_inc.climate=full_refresh - append, example_com_inc.crop_categories=full_refresh - append, example_com_inc.observations=full_refresh - append, example_com_inc.organization_types=full_refresh - append, example_com_inc.trial_customers=full_refresh - append, example_com_inc.variety_types=full_refresh - append, example_com_inc.observation_comments=full_refresh - append, example_com_inc.site_weather=full_refresh - append, example_com_inc.plots=full_refresh - append, example_com_inc.data_entry_permissions=full_refresh - append, example_com_inc.observation_groups=full_refresh - append, example_com_inc.administrative_regions=full_refresh - append, example_com_inc.trials=full_refresh - append, example_com_inc.observation_definitions=full_refresh - append, example_com_inc.trial_sites=full_refresh - append, example_com_inc.dimensions=full_refresh - append, example_com_inc.trial_owners=full_refresh - append, example_com_inc.customers=full_refresh - append, example_com_inc.trait_observations=full_refresh - append, example_com_inc.trial_varieties_stage=full_refresh - append, example_com_inc.assigned_staff=full_refresh - append, example_com_inc.observations_history=full_refresh - append, example_com_inc.observations_crosstab=full_refresh - append, example_com_inc.visits=full_refresh - append, example_com_inc.scheduled_applications=full_refresh - append, example_com_inc.sites=full_refresh - append} 2022-04-06 20:24:05 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-06 20:24:05 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.15 exists... 2022-04-06 20:24:05 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.15 was found locally. 2022-04-06 20:24:05 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 10 2022-04-06 20:24:05 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/10/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.15 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.64-alpha -e WORKER_JOB_ID=10 airbyte/destination-postgres:0.3.15 write --config destination_config.json --catalog destination_catalog.json 2022-04-06 20:24:05 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-bigquery:0.1.6 exists... 2022-04-06 20:24:06 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-bigquery:0.1.6 was found locally. 2022-04-06 20:24:06 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 10 2022-04-06 20:24:06 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/10/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-bigquery:0.1.6 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.64-alpha -e WORKER_JOB_ID=10 airbyte/source-bigquery:0.1.6 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-04-06 20:24:06 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-06 20:24:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-06 20:24:06 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-06 20:24:06 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-06 20:24:06 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-06 20:24:06 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-06 20:24:06 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-06 20:24:06 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-06 20:24:06 source > 2022-04-06 20:24:06 INFO i.a.i.s.b.BigQuerySource(main):174 - starting source: class io.airbyte.integrations.source.bigquery.BigQuerySource 2022-04-06 20:24:06 destination > 2022-04-06 20:24:06 INFO i.a.i.d.p.PostgresDestination(main):77 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-04-06 20:24:06 source > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2022-04-06 20:24:06 source > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.source.bigquery.BigQuerySource 2022-04-06 20:24:06 source > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: READ 2022-04-06 20:24:06 source > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2022-04-06 20:24:06 destination > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-06 20:24:06 destination > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: 97562d3b86cb46b6a7233629d998fcd6 2022-04-06 20:24:06 destination > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-04-06 20:24:06 destination > 2022-04-06 20:24:06 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE 2022-04-06 20:24:06 destination > 2022-04-06 20:24:06 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-06 20:24:06 source > 2022-04-06 20:24:06 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-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.CdcStateManager():26 - Initialized CDC state with: null 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='site_weather', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='agroclimatic_regions', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trial_sites', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='assigned_staff', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trials', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='countries', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='crop_variety_stages', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observations_crosstab', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='sites', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observation_comments', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='administrative_regions', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='climate', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='dimensions', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='breeders', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='visits', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observations_library', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trait_categories', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trial_varieties', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='required_data_entry', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='scheduled_applications', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='stages', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='data_entry_permissions', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observations', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='plots', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observation_groups', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='seasons', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trial_varieties_stage', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='crop_varieties', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observation_definitions', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='derived_observations', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='organization_types', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trial_types', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='users', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='country_transitions', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='crop_categories', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='variety_types', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trial_customers', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observations_history', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trial_owners', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='customers', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='crops', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='stage_transitions', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='observation_comments_history', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='partners', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 source > 2022-04-06 20:24:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='trait_observations', namespace='example_com_inc'}, New Cursor Field: null. Resetting cursor value 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 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-06 20:24:07 destination > 2022-04-06 20:24:07 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-06 20:24:07 destination > 2022-04-06 20:24:07 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-06 20:24:07 destination > 2022-04-06 20:24:07 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-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=administrative_regions, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_yuu_administrative_regions, outputTableName=_airbyte_raw_administrative_regions, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=agroclimatic_regions, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_krj_agroclimatic_regions, outputTableName=_airbyte_raw_agroclimatic_regions, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=assigned_staff, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_did_assigned_staff, outputTableName=_airbyte_raw_assigned_staff, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=breeders, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_wad_breeders, outputTableName=_airbyte_raw_breeders, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=climate, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_vhb_climate, outputTableName=_airbyte_raw_climate, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=countries, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ego_countries, outputTableName=_airbyte_raw_countries, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=country_transitions, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ixn_country_transitions, outputTableName=_airbyte_raw_country_transitions, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=crop_categories, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_kog_crop_categories, outputTableName=_airbyte_raw_crop_categories, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=crop_varieties, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_yqq_crop_varieties, outputTableName=_airbyte_raw_crop_varieties, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=crop_variety_stages, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_caa_crop_variety_stages, outputTableName=_airbyte_raw_crop_variety_stages, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=crops, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_qen_crops, outputTableName=_airbyte_raw_crops, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=customers, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ndr_customers, outputTableName=_airbyte_raw_customers, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=data_entry_permissions, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_syf_data_entry_permissions, outputTableName=_airbyte_raw_data_entry_permissions, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=derived_observations, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_jid_derived_observations, outputTableName=_airbyte_raw_derived_observations, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=dimensions, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_vog_dimensions, outputTableName=_airbyte_raw_dimensions, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observation_comments, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_yfs_observation_comments, outputTableName=_airbyte_raw_observation_comments, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observation_comments_history, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_utg_observation_comments_history, outputTableName=_airbyte_raw_observation_comments_history, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observation_definitions, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_zxe_observation_definitions, outputTableName=_airbyte_raw_observation_definitions, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observation_groups, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_noc_observation_groups, outputTableName=_airbyte_raw_observation_groups, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observations, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_jre_observations, outputTableName=_airbyte_raw_observations, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observations_crosstab, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ysl_observations_crosstab, outputTableName=_airbyte_raw_observations_crosstab, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observations_history, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_kve_observations_history, outputTableName=_airbyte_raw_observations_history, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=observations_library, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_qif_observations_library, outputTableName=_airbyte_raw_observations_library, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=organization_types, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ama_organization_types, outputTableName=_airbyte_raw_organization_types, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=partners, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_cck_partners, outputTableName=_airbyte_raw_partners, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=plots, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_xiq_plots, outputTableName=_airbyte_raw_plots, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=required_data_entry, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ljc_required_data_entry, outputTableName=_airbyte_raw_required_data_entry, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=scheduled_applications, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_jix_scheduled_applications, outputTableName=_airbyte_raw_scheduled_applications, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=seasons, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_rna_seasons, outputTableName=_airbyte_raw_seasons, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=site_weather, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_jfa_site_weather, outputTableName=_airbyte_raw_site_weather, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=sites, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_hhu_sites, outputTableName=_airbyte_raw_sites, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=stage_transitions, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_xcv_stage_transitions, outputTableName=_airbyte_raw_stage_transitions, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=stages, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ebx_stages, outputTableName=_airbyte_raw_stages, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trait_categories, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_oqq_trait_categories, outputTableName=_airbyte_raw_trait_categories, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trait_observations, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_xpx_trait_observations, outputTableName=_airbyte_raw_trait_observations, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trial_customers, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_wfe_trial_customers, outputTableName=_airbyte_raw_trial_customers, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trial_owners, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_siw_trial_owners, outputTableName=_airbyte_raw_trial_owners, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trial_sites, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_lbt_trial_sites, outputTableName=_airbyte_raw_trial_sites, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trial_types, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_qtk_trial_types, outputTableName=_airbyte_raw_trial_types, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trial_varieties, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_ryl_trial_varieties, outputTableName=_airbyte_raw_trial_varieties, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trial_varieties_stage, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_fus_trial_varieties_stage, outputTableName=_airbyte_raw_trial_varieties_stage, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=trials, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_bgv_trials, outputTableName=_airbyte_raw_trials, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=users, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_bwr_users, outputTableName=_airbyte_raw_users, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=variety_types, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_zem_variety_types, outputTableName=_airbyte_raw_variety_types, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=visits, namespace=null, outputSchemaName=quicktrials_airbyte, tmpTableName=_airbyte_tmp_awb_visits, outputTableName=_airbyte_raw_visits, syncMode=append} 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 45 streams 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream administrative_regions. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_yuu_administrative_regions 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream agroclimatic_regions. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_krj_agroclimatic_regions 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream assigned_staff. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_did_assigned_staff 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream breeders. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_wad_breeders 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream climate. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_vhb_climate 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream countries. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ego_countries 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream country_transitions. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ixn_country_transitions 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream crop_categories. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_kog_crop_categories 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream crop_varieties. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_yqq_crop_varieties 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream crop_variety_stages. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_caa_crop_variety_stages 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream crops. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_qen_crops 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream customers. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ndr_customers 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream data_entry_permissions. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_syf_data_entry_permissions 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream derived_observations. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_jid_derived_observations 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream dimensions. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_vog_dimensions 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observation_comments. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_yfs_observation_comments 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observation_comments_history. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_utg_observation_comments_history 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observation_definitions. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_zxe_observation_definitions 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observation_groups. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_noc_observation_groups 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observations. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_jre_observations 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observations_crosstab. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ysl_observations_crosstab 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observations_history. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_kve_observations_history 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream observations_library. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_qif_observations_library 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream organization_types. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ama_organization_types 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream partners. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_cck_partners 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream plots. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_xiq_plots 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream required_data_entry. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ljc_required_data_entry 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream scheduled_applications. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_jix_scheduled_applications 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream seasons. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_rna_seasons 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream site_weather. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_jfa_site_weather 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream sites. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_hhu_sites 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream stage_transitions. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_xcv_stage_transitions 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream stages. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ebx_stages 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trait_categories. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_oqq_trait_categories 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trait_observations. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_xpx_trait_observations 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trial_customers. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_wfe_trial_customers 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trial_owners. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_siw_trial_owners 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trial_sites. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_lbt_trial_sites 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trial_types. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_qtk_trial_types 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trial_varieties. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_ryl_trial_varieties 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trial_varieties_stage. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_fus_trial_varieties_stage 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream trials. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_bgv_trials 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream users. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_bwr_users 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream variety_types. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_zem_variety_types 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream visits. schema: quicktrials_airbyte, tmp table name: _airbyte_tmp_awb_visits 2022-04-06 20:24:07 destination > 2022-04-06 20:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed. 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: administrative_regions 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: agroclimatic_regions 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: assigned_staff 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: breeders 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: climate 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: countries 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: country_transitions 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: crop_categories 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: crop_varieties 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: crop_variety_stages 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: crops 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: customers 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: data_entry_permissions 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: derived_observations 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: dimensions 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observation_comments 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observation_comments_history 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observation_definitions 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observation_groups 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observations 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observations_crosstab 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observations_history 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: observations_library 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: organization_types 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: partners 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: plots 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: required_data_entry 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: scheduled_applications 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: seasons 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: site_weather 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: sites 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: stage_transitions 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: stages 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trait_categories 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trait_observations 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trial_customers 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trial_owners 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trial_sites 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trial_types 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trial_varieties 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trial_varieties_stage 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: trials 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: users 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: variety_types 2022-04-06 20:24:14 source > 2022-04-06 20:24:14 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: visits 2022-04-06 20:24:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):301 - Records read: 1000 (75 KB) 2022-04-06 20:24:31 source > 2022-04-06 20:24:31 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):123 - Closing database connection pool. 2022-04-06 20:24:31 source > 2022-04-06 20:24:31 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):125 - Closed database connection pool. 2022-04-06 20:24:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 1580 (172 KB) 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure. 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 702946 bytes 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing assigned_staff: 966 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing crops: 9 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing crop_varieties: 18 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing agroclimatic_regions: 2 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing breeders: 3 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing administrative_regions: 52 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing climate: 420 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing customers: 109 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing countries: 1 records 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 45 streams 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream administrative_regions. schema quicktrials_airbyte, tmp table _airbyte_tmp_yuu_administrative_regions, final table _airbyte_raw_administrative_regions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream agroclimatic_regions. schema quicktrials_airbyte, tmp table _airbyte_tmp_krj_agroclimatic_regions, final table _airbyte_raw_agroclimatic_regions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream assigned_staff. schema quicktrials_airbyte, tmp table _airbyte_tmp_did_assigned_staff, final table _airbyte_raw_assigned_staff 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream breeders. schema quicktrials_airbyte, tmp table _airbyte_tmp_wad_breeders, final table _airbyte_raw_breeders 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream climate. schema quicktrials_airbyte, tmp table _airbyte_tmp_vhb_climate, final table _airbyte_raw_climate 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream countries. schema quicktrials_airbyte, tmp table _airbyte_tmp_ego_countries, final table _airbyte_raw_countries 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream country_transitions. schema quicktrials_airbyte, tmp table _airbyte_tmp_ixn_country_transitions, final table _airbyte_raw_country_transitions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream crop_categories. schema quicktrials_airbyte, tmp table _airbyte_tmp_kog_crop_categories, final table _airbyte_raw_crop_categories 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream crop_varieties. schema quicktrials_airbyte, tmp table _airbyte_tmp_yqq_crop_varieties, final table _airbyte_raw_crop_varieties 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream crop_variety_stages. schema quicktrials_airbyte, tmp table _airbyte_tmp_caa_crop_variety_stages, final table _airbyte_raw_crop_variety_stages 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream crops. schema quicktrials_airbyte, tmp table _airbyte_tmp_qen_crops, final table _airbyte_raw_crops 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream customers. schema quicktrials_airbyte, tmp table _airbyte_tmp_ndr_customers, final table _airbyte_raw_customers 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream data_entry_permissions. schema quicktrials_airbyte, tmp table _airbyte_tmp_syf_data_entry_permissions, final table _airbyte_raw_data_entry_permissions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream derived_observations. schema quicktrials_airbyte, tmp table _airbyte_tmp_jid_derived_observations, final table _airbyte_raw_derived_observations 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream dimensions. schema quicktrials_airbyte, tmp table _airbyte_tmp_vog_dimensions, final table _airbyte_raw_dimensions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observation_comments. schema quicktrials_airbyte, tmp table _airbyte_tmp_yfs_observation_comments, final table _airbyte_raw_observation_comments 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observation_comments_history. schema quicktrials_airbyte, tmp table _airbyte_tmp_utg_observation_comments_history, final table _airbyte_raw_observation_comments_history 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observation_definitions. schema quicktrials_airbyte, tmp table _airbyte_tmp_zxe_observation_definitions, final table _airbyte_raw_observation_definitions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observation_groups. schema quicktrials_airbyte, tmp table _airbyte_tmp_noc_observation_groups, final table _airbyte_raw_observation_groups 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observations. schema quicktrials_airbyte, tmp table _airbyte_tmp_jre_observations, final table _airbyte_raw_observations 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observations_crosstab. schema quicktrials_airbyte, tmp table _airbyte_tmp_ysl_observations_crosstab, final table _airbyte_raw_observations_crosstab 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observations_history. schema quicktrials_airbyte, tmp table _airbyte_tmp_kve_observations_history, final table _airbyte_raw_observations_history 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream observations_library. schema quicktrials_airbyte, tmp table _airbyte_tmp_qif_observations_library, final table _airbyte_raw_observations_library 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream organization_types. schema quicktrials_airbyte, tmp table _airbyte_tmp_ama_organization_types, final table _airbyte_raw_organization_types 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream partners. schema quicktrials_airbyte, tmp table _airbyte_tmp_cck_partners, final table _airbyte_raw_partners 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream plots. schema quicktrials_airbyte, tmp table _airbyte_tmp_xiq_plots, final table _airbyte_raw_plots 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream required_data_entry. schema quicktrials_airbyte, tmp table _airbyte_tmp_ljc_required_data_entry, final table _airbyte_raw_required_data_entry 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream scheduled_applications. schema quicktrials_airbyte, tmp table _airbyte_tmp_jix_scheduled_applications, final table _airbyte_raw_scheduled_applications 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream seasons. schema quicktrials_airbyte, tmp table _airbyte_tmp_rna_seasons, final table _airbyte_raw_seasons 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream site_weather. schema quicktrials_airbyte, tmp table _airbyte_tmp_jfa_site_weather, final table _airbyte_raw_site_weather 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream sites. schema quicktrials_airbyte, tmp table _airbyte_tmp_hhu_sites, final table _airbyte_raw_sites 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream stage_transitions. schema quicktrials_airbyte, tmp table _airbyte_tmp_xcv_stage_transitions, final table _airbyte_raw_stage_transitions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream stages. schema quicktrials_airbyte, tmp table _airbyte_tmp_ebx_stages, final table _airbyte_raw_stages 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trait_categories. schema quicktrials_airbyte, tmp table _airbyte_tmp_oqq_trait_categories, final table _airbyte_raw_trait_categories 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trait_observations. schema quicktrials_airbyte, tmp table _airbyte_tmp_xpx_trait_observations, final table _airbyte_raw_trait_observations 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trial_customers. schema quicktrials_airbyte, tmp table _airbyte_tmp_wfe_trial_customers, final table _airbyte_raw_trial_customers 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trial_owners. schema quicktrials_airbyte, tmp table _airbyte_tmp_siw_trial_owners, final table _airbyte_raw_trial_owners 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trial_sites. schema quicktrials_airbyte, tmp table _airbyte_tmp_lbt_trial_sites, final table _airbyte_raw_trial_sites 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trial_types. schema quicktrials_airbyte, tmp table _airbyte_tmp_qtk_trial_types, final table _airbyte_raw_trial_types 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trial_varieties. schema quicktrials_airbyte, tmp table _airbyte_tmp_ryl_trial_varieties, final table _airbyte_raw_trial_varieties 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trial_varieties_stage. schema quicktrials_airbyte, tmp table _airbyte_tmp_fus_trial_varieties_stage, final table _airbyte_raw_trial_varieties_stage 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream trials. schema quicktrials_airbyte, tmp table _airbyte_tmp_bgv_trials, final table _airbyte_raw_trials 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream users. schema quicktrials_airbyte, tmp table _airbyte_tmp_bwr_users, final table _airbyte_raw_users 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream variety_types. schema quicktrials_airbyte, tmp table _airbyte_tmp_zem_variety_types, final table _airbyte_raw_variety_types 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream visits. schema quicktrials_airbyte, tmp table _airbyte_tmp_awb_visits, final table _airbyte_raw_visits 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables. 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed. 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 45 streams 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream administrative_regions. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_yuu_administrative_regions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream agroclimatic_regions. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_krj_agroclimatic_regions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream assigned_staff. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_did_assigned_staff 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream breeders. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_wad_breeders 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream climate. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_vhb_climate 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream countries. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ego_countries 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream country_transitions. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ixn_country_transitions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream crop_categories. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_kog_crop_categories 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream crop_varieties. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_yqq_crop_varieties 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream crop_variety_stages. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_caa_crop_variety_stages 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream crops. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_qen_crops 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream customers. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ndr_customers 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream data_entry_permissions. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_syf_data_entry_permissions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream derived_observations. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_jid_derived_observations 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream dimensions. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_vog_dimensions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observation_comments. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_yfs_observation_comments 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observation_comments_history. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_utg_observation_comments_history 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observation_definitions. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_zxe_observation_definitions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observation_groups. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_noc_observation_groups 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observations. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_jre_observations 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observations_crosstab. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ysl_observations_crosstab 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observations_history. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_kve_observations_history 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream observations_library. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_qif_observations_library 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream organization_types. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ama_organization_types 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream partners. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_cck_partners 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream plots. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_xiq_plots 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream required_data_entry. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ljc_required_data_entry 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream scheduled_applications. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_jix_scheduled_applications 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream seasons. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_rna_seasons 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream site_weather. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_jfa_site_weather 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream sites. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_hhu_sites 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream stage_transitions. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_xcv_stage_transitions 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream stages. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ebx_stages 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trait_categories. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_oqq_trait_categories 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trait_observations. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_xpx_trait_observations 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trial_customers. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_wfe_trial_customers 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trial_owners. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_siw_trial_owners 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trial_sites. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_lbt_trial_sites 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trial_types. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_qtk_trial_types 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trial_varieties. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_ryl_trial_varieties 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trial_varieties_stage. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_fus_trial_varieties_stage 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream trials. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_bgv_trials 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream users. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_bwr_users 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream variety_types. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_zem_variety_types 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream visits. schema quicktrials_airbyte, tmp table name: _airbyte_tmp_awb_visits 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed. 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-04-06 20:24:31 destination > 2022-04-06 20:24:31 INFO i.a.i.d.p.PostgresDestination(main):79 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-04-06 20:24:31 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.64-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.35.64-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.64-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.35.64-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-04-06 20:24:31 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@346b98ac[status=failed,recordsSynced=1580,bytesSynced=176887,startTime=1649276645934,endTime=1649276671911,totalStats=io.airbyte.config.SyncStats@2ee12fca[recordsEmitted=1580,bytesEmitted=176887,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@2279493f[streamName=administrative_regions,stats=io.airbyte.config.SyncStats@45a6eae3[recordsEmitted=52,bytesEmitted=3396,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@2d60a403[streamName=breeders,stats=io.airbyte.config.SyncStats@ad8511a[recordsEmitted=3,bytesEmitted=386,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@6280c1cf[streamName=agroclimatic_regions,stats=io.airbyte.config.SyncStats@1083de8e[recordsEmitted=2,bytesEmitted=135,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@386b2021[streamName=climate,stats=io.airbyte.config.SyncStats@7073e6b7[recordsEmitted=420,bytesEmitted=76256,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@1419cfcf[streamName=countries,stats=io.airbyte.config.SyncStats@1a60146c[recordsEmitted=1,bytesEmitted=33,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@7beb5529[streamName=crops,stats=io.airbyte.config.SyncStats@14c252bd[recordsEmitted=9,bytesEmitted=877,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@4e7f905d[streamName=customers,stats=io.airbyte.config.SyncStats@54a62e8a[recordsEmitted=109,bytesEmitted=16177,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@75457b2a[streamName=assigned_staff,stats=io.airbyte.config.SyncStats@73948885[recordsEmitted=966,bytesEmitted=75038,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@41db03d2[streamName=crop_varieties,stats=io.airbyte.config.SyncStats@246cb71d[recordsEmitted=18,bytesEmitted=4589,stateMessagesEmitted=,recordsCommitted=]]]] 2022-04-06 20:24:31 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-04-06 20:24:31 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@2d296bf1[state={}] 2022-04-06 20:24:31 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-06 20:24:31 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@6ec08b46[standardSyncSummary=io.airbyte.config.StandardSyncSummary@3ff89751[status=failed,recordsSynced=1580,bytesSynced=176887,startTime=1649276645934,endTime=1649276671911,totalStats=io.airbyte.config.SyncStats@2ee12fca[recordsEmitted=1580,bytesEmitted=176887,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@2279493f[streamName=administrative_regions,stats=io.airbyte.config.SyncStats@45a6eae3[recordsEmitted=52,bytesEmitted=3396,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@2d60a403[streamName=breeders,stats=io.airbyte.config.SyncStats@ad8511a[recordsEmitted=3,bytesEmitted=386,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@6280c1cf[streamName=agroclimatic_regions,stats=io.airbyte.config.SyncStats@1083de8e[recordsEmitted=2,bytesEmitted=135,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@386b2021[streamName=climate,stats=io.airbyte.config.SyncStats@7073e6b7[recordsEmitted=420,bytesEmitted=76256,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@1419cfcf[streamName=countries,stats=io.airbyte.config.SyncStats@1a60146c[recordsEmitted=1,bytesEmitted=33,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@7beb5529[streamName=crops,stats=io.airbyte.config.SyncStats@14c252bd[recordsEmitted=9,bytesEmitted=877,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@4e7f905d[streamName=customers,stats=io.airbyte.config.SyncStats@54a62e8a[recordsEmitted=109,bytesEmitted=16177,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@75457b2a[streamName=assigned_staff,stats=io.airbyte.config.SyncStats@73948885[recordsEmitted=966,bytesEmitted=75038,stateMessagesEmitted=,recordsCommitted=]], io.airbyte.config.StreamSyncStats@41db03d2[streamName=crop_varieties,stats=io.airbyte.config.SyncStats@246cb71d[recordsEmitted=18,bytesEmitted=4589,stateMessagesEmitted=,recordsCommitted=]]]],state=io.airbyte.config.State@2d296bf1[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7dd67c9e[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@71ca6fa2[stream=io.airbyte.protocol.models.AirbyteStream@1b3a4066[name=administrative_regions,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"country_code":{"type":"string"},"administrative_region_id":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@60031e4f[stream=io.airbyte.protocol.models.AirbyteStream@2effac5d[name=agroclimatic_regions,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"country_code":{"type":"string"},"agroclimatic_region_id":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@c6a715f[stream=io.airbyte.protocol.models.AirbyteStream@459a29c4[name=assigned_staff,jsonSchema={ <<<<<<< SNIP -- lots of SCHEMA definition >>>>>>>> },supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5768ddc7[stream=io.airbyte.protocol.models.AirbyteStream@28f8edf3[name=users,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"email":{"type":"string"},"user_id":{"type":"number"},"platform":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1eb9a560[stream=io.airbyte.protocol.models.AirbyteStream@315619a0[name=variety_types,jsonSchema={"type":"object","properties":{"name":{"type":"string"},"variety_type_id":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@20417ca8[stream=io.airbyte.protocol.models.AirbyteStream@4f398a26[name=visits,jsonSchema={"type":"object","properties":{"code":{"type":"string"},"date":{"type":"string"},"name":{"type":"string"},"site_id":{"type":"string"},"trial_id":{"type":"number"},"visit_id":{"type":"string"},"days_after_planting":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@1c78b404[failureOrigin=source,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@1d622532[additionalProperties={attemptNumber=0, jobId=10}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1649276671632]]] 2022-04-06 20:24:31 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-06 20:24:31 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 024181da-abd7-45e1-a4d2-3f658f96341a state: io.airbyte.config.State@2d40cbb1[state={}] 2022-04-06 20:24:32 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/10/0/logs.log 2022-04-06 20:24:32 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.64-alpha 2022-04-06 20:24:32 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization. 2022-04-06 20:24:32 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.74 2022-04-06 20:24:32 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.74 exists... 2022-04-06 20:24:32 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.74 was found locally. 2022-04-06 20:24:32 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 10 2022-04-06 20:24:32 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/10/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.64-alpha airbyte/normalization:0.1.74 run --integration-type postgres --config destination_config.json --catalog destination_catalog.json 2022-04-06 20:24:32 normalization > Running: transform-config --config destination_config.json --integration-type postgres --out /data/10/0/normalize 2022-04-06 20:24:32 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/10/0/normalize') 2022-04-06 20:24:32 normalization > transform_postgres 2022-04-06 20:24:32 normalization > Running: transform-catalog --integration-type postgres --profile-config-dir /data/10/0/normalize --catalog destination_catalog.json --out /data/10/0/normalize/models/generated/ --json-column _airbyte_data 2022-04-06 20:24:32 normalization > Processing destination_catalog.json... 2022-04-06 20:24:32 normalization > Truncating attribute_formulation_type_formulation_state (#44) to attribute_formulatio_ype_formulation_state (#43) 2022-04-06 20:24:32 normalization > Truncating attribute_formulation_type_formulation_state (#44) to attribute_formulatio_ype_formulation_state (#43) <<<<<<<<<<<<<<<<<< SNIP -- lots of tables all saying Truncating...... >>>>>>>>>>>>>>>>>> 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/administrative_regions_ab1.sql from administrative_regions <<<<<<<<<<<<<<<<<< SNIP -- lots of tables all saying Generating...... >>>>>>>>>>>>>>>>>> 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/derived_observations_ab1.sql from derived_observations 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/derived_observations_ab2.sql from derived_observations 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/derived_observations_ab3.sql from derived_observations 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/derived_observations.sql from derived_observations 2022-04-06 20:24:32 normalization > Truncating attribute_formulation_type_formulation_state (#44) to attribute_formulatio_ype_formulation_state (#43) <<<<<<<<<<<<<<<<<< SNIP -- lots of tables all saying Truncating...... >>>>>>>>>>>>>>>>>> 2022-04-06 20:24:32 normalization > Truncating attribute_handheld_sensor_sample_location_handheld_sensor_sample_location_id_ (#77) to attribute_handheld_s_r_sample_location_id_ (#43) 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/dimensions_ab1.sql from dimensions 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/dimensions_ab2.sql from dimensions 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/dimensions_ab3.sql from dimensions 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/dimensions.sql from dimensions 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_comments_ab1.sql from observation_comments 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_comments_ab2.sql from observation_comments 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_comments_ab3.sql from observation_comments 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/observation_comments.sql from observation_comments 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_comments_history_ab1.sql from observation_comments_history 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_comments_history_ab2.sql from observation_comments_history 2022-04-06 20:24:32 normalization > Truncating _airbyte_observation_comments_history_hashid (#44) to _airbyte_observation_mments_history_hashid (#43) 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_comments_history_ab3.sql from observation_comments_history 2022-04-06 20:24:32 normalization > Truncating _airbyte_observation_comments_history_hashid (#44) to _airbyte_observation_mments_history_hashid (#43) 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/observation_comments_history.sql from observation_comments_history 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_definitions_ab1.sql from observation_definitions 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_definitions_ab2.sql from observation_definitions 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_definitions_ab3.sql from observation_definitions 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/observation_definitions.sql from observation_definitions 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_groups_ab1.sql from observation_groups 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_groups_ab2.sql from observation_groups 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observation_groups_ab3.sql from observation_groups 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/observation_groups.sql from observation_groups 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observations_ab1.sql from observations 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observations_ab2.sql from observations 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observations_ab3.sql from observations 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/observations.sql from observations 2022-04-06 20:24:32 normalization > Truncating value_additional_in_furrow_additive_rate_oza (#44) to value_additional_in__row_additive_rate_oza (#43) <<<<<<<<<<<<<<<<<< SNIP -- lots of tables all saying Truncating...... >>>>>>>>>>>>>>>>>> 2022-04-06 20:24:32 normalization > Generating airbyte_ctes/quicktrials_airbyte/observations_crosstab_ab1.sql from observations_crosstab 2022-04-06 20:24:32 normalization > Generating airbyte_views/quicktrials_airbyte/observations_crosstab_ab2.sql from observations_crosstab 2022-04-06 20:24:32 normalization > Generating airbyte_views/quicktrials_airbyte/observations_crosstab_ab3.sql from observations_crosstab 2022-04-06 20:24:32 normalization > Generating airbyte_incremental/quicktrials_airbyte/observations_crosstab.sql from observations_crosstab <<<<<<<<<<<<<<<<<< SNIP -- lots of tables all saying OK...created, etc. >>>>>>>>>>>>>>>>>> 2022-04-06 20:24:33 normalization > Generating airbyte_incremental/quicktrials_airbyte/visits.sql from visits 2022-04-06 20:24:33 normalization > detected no config file for ssh, assuming ssh is off. 2022-04-06 20:24:34 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-04-06 20:24:34 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-04-06 20:24:34 normalization > 2022-04-06 20:24:34 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-04-06 20:24:34 normalization > 2022-04-06 20:24:36 normalization > 20:24:36 Running with dbt=1.0.0 2022-04-06 20:24:36 normalization > 20:24:36 Partial parse save file not found. Starting full parse. 2022-04-06 20:24:40 normalization > 20:24:40 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-04-06 20:24:40 normalization > There are 1 unused configuration paths: 2022-04-06 20:24:40 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-04-06 20:24:40 normalization > 2022-04-06 20:24:40 normalization > 20:24:40 Found 180 models, 0 tests, 0 snapshots, 0 analyses, 514 macros, 0 operations, 0 seed files, 45 sources, 0 exposures, 0 metrics 2022-04-06 20:24:40 normalization > 20:24:40 2022-04-06 20:24:42 normalization > 20:24:42 Concurrency: 8 threads (target='prod') 2022-04-06 20:24:42 normalization > 20:24:42 2022-04-06 20:24:44 normalization > 20:24:44 1 of 47 START view model _airbyte_quicktrials_airbyte.observations_crosstab_ab2......................................... [RUN] 2022-04-06 20:24:50 normalization > 20:24:50 1 of 47 OK created view model _airbyte_quicktrials_airbyte.observations_crosstab_ab2.................................... [CREATE VIEW in 6.56s] 2022-04-06 20:24:53 normalization > 20:24:53 2 of 47 START incremental model quicktrials_airbyte.administrative_regions.............................................. [RUN] <<<<<<<<<<<<<<<<<< SNIP -- lots of tables all saying OK...created, etc. >>>>>>>>>>>>>>>>>> 2022-04-06 20:24:53 normalization > 20:24:53 3 of 47 START incremental model quicktrials_airbyte.agroclimatic_regions................................................ [RUN] 2022-04-06 20:24:54 normalization > 20:24:54 3 of 47 OK created incremental model quicktrials_airbyte.agroclimatic_regions........................................... [INSERT 0 2 in 0.61s] 2022-04-06 20:24:59 normalization > 20:24:59 47 of 47 OK created incremental model quicktrials_airbyte.observations_crosstab......................................... [INSERT 0 0 in 3.48s] 2022-04-06 20:24:59 normalization > 20:24:59 2022-04-06 20:24:59 normalization > 20:24:59 Finished running 2 view models, 45 incremental models in 19.20s. 2022-04-06 20:24:59 normalization > 20:24:59 2022-04-06 20:24:59 normalization > 20:24:59 Completed successfully 2022-04-06 20:24:59 normalization > 20:24:59 2022-04-06 20:24:59 normalization > 20:24:59 Done. PASS=47 WARN=0 ERROR=0 SKIP=0 TOTAL=47 2022-04-06 20:25:00 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 27 seconds. 2022-04-06 20:25:00 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-06 20:25:00 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...