2022-11-08 11:54:37 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.method: must be a constant value Standard, $.method: does not have a value in the enumeration [Standard] 2022-11-08 11:54:37 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required 2022-11-08 11:54:37 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.private_key: is missing but it is required 2022-11-08 11:54:37 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. errors: $.password: object found, string expected 2022-11-08 11:54:37 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/8/0/logs.log 2022-11-08 11:54:37 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.18 2022-11-08 11:54:37 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-11-08 11:54:37 INFO i.a.c.EnvConfigs(getEnvOrDefault):1079 - Using default value for environment variable METRIC_CLIENT: '' 2022-11-08 11:54:37 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 2022-11-08 11:54:37 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-11-08 11:54:37 INFO i.a.w.g.DefaultReplicationWorker(run):133 - start sync worker. job id: 8 attempt id: 0 2022-11-08 11:54:37 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-08 11:54:37 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION ----- 2022-11-08 11:54:37 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-08 11:54:37 INFO i.a.w.g.DefaultReplicationWorker(run):149 - configured sync modes: {public.subcategories=incremental - append_dedup, public.users=incremental - append_dedup, public.admins=incremental - append_dedup, public.product_details=incremental - append_dedup, public.subcategories_maps=incremental - append_dedup, public.producers=incremental - append_dedup, public.products=incremental - append_dedup, public.user_subscriptions=incremental - append_dedup, public.product_variants=incremental - append_dedup, public.schema_migrations=incremental - append_dedup, public.categories_maps=incremental - append_dedup, public.ar_internal_metadata=incremental - append_dedup, public.store_inventories_history=incremental - append_dedup, public.stores=incremental - append_dedup, public.categories=incremental - append_dedup, public.grunters=incremental - append_dedup, public.lamdba_calls=incremental - append_dedup, public.product_variant_details=incremental - append_dedup, public.store_inventories=incremental - append_dedup} 2022-11-08 11:54:37 INFO i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination... 2022-11-08 11:54:37 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-snowflake:0.4.38 exists... 2022-11-08 11:54:37 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-snowflake:0.4.38 was found locally. 2022-11-08 11:54:37 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = destination-snowflake-write-8-0-ysfpf with resources io.airbyte.config.ResourceRequirements@7f81e884[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-08 11:54:37 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/8/0 --log-driver none --name destination-snowflake-write-8-0-ysfpf --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.38 -e AIRBYTE_VERSION=0.40.18 -e WORKER_JOB_ID=8 airbyte/destination-snowflake:0.4.38 write --config destination_config.json --catalog destination_catalog.json 2022-11-08 11:54:37 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0 2022-11-08 11:54:37 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0 2022-11-08 11:54:37 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-postgres:1.0.22 exists... 2022-11-08 11:54:37 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-postgres:1.0.22 was found locally. 2022-11-08 11:54:37 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-postgres-read-8-0-iaevl with resources io.airbyte.config.ResourceRequirements@4ff65a69[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-08 11:54:37 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/8/0 --log-driver none --name source-postgres-read-8-0-iaevl --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-postgres:1.0.22 -e AIRBYTE_VERSION=0.40.18 -e WORKER_JOB_ID=8 airbyte/source-postgres:1.0.22 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-11-08 11:54:37 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0 2022-11-08 11:54:37 INFO i.a.w.g.DefaultReplicationWorker(run):197 - Waiting for source and destination threads to complete. 2022-11-08 11:54:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):468 - Destination output thread started. 2022-11-08 11:54:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):353 - Replication thread started. 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running source under deployment mode: OSS 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting source: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json} 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Command: READ 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'} 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Command: WRITE 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-11-08 11:54:39 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-08 11:54:39 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-08 11:54:39 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword min - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-08 11:54:39 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword max - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-08 11:54:39 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-08 11:54:39 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-11-08 11:54:39 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Using destination type: INTERNAL_STAGING 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting connection with method: NO_TUNNEL 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - using CDC: true 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=admins, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_ihe_admins, outputTableName=_airbyte_raw_admins, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=ar_internal_metadata, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_bfa_ar_internal_metadata, outputTableName=_airbyte_raw_ar_internal_metadata, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=categories, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_zau_categories, outputTableName=_airbyte_raw_categories, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=categories_maps, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_voc_categories_maps, outputTableName=_airbyte_raw_categories_maps, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=grunters, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_uwg_grunters, outputTableName=_airbyte_raw_grunters, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=lamdba_calls, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_www_lamdba_calls, outputTableName=_airbyte_raw_lamdba_calls, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=producers, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_kkl_producers, outputTableName=_airbyte_raw_producers, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=product_details, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_ygt_product_details, outputTableName=_airbyte_raw_product_details, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=product_variant_details, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_tqz_product_variant_details, outputTableName=_airbyte_raw_product_variant_details, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=product_variants, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_sja_product_variants, outputTableName=_airbyte_raw_product_variants, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=products, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_vbp_products, outputTableName=_airbyte_raw_products, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=schema_migrations, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_gmz_schema_migrations, outputTableName=_airbyte_raw_schema_migrations, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Starting... 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=store_inventories, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_hol_store_inventories, outputTableName=_airbyte_raw_store_inventories, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=store_inventories_history, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_erh_store_inventories_history, outputTableName=_airbyte_raw_store_inventories_history, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=stores, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_img_stores, outputTableName=_airbyte_raw_stores, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=subcategories, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_wjy_subcategories, outputTableName=_airbyte_raw_subcategories, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=subcategories_maps, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_gus_subcategories_maps, outputTableName=_airbyte_raw_subcategories_maps, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=user_subscriptions, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_oiq_user_subscriptions, outputTableName=_airbyte_raw_user_subscriptions, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Write config: WriteConfig{streamName=users, namespace=public, outputSchemaName=public, tmpTableName=_airbyte_tmp_tzm_users, outputTableName=_airbyte_raw_users, syncMode=append_dedup} 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing tmp tables in destination started for 19 streams 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream admins: tmp table: _airbyte_tmp_ihe_admins, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Starting... 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Start completed. 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - using CDC: true 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Attempting to get metadata from the database to see if we can connect. 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Attempting to find the named replication slot using the query: HikariProxyPreparedStatement@247795540 wrapping SELECT * FROM pg_replication_slots WHERE slot_name = 'airbyte_slot_wal2json' AND plugin = 'wal2json' AND database = 'db_retracted_production' 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Set initial fetch size: 10 rows 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Attempting to find the publication using the query: HikariProxyPreparedStatement@37268876 wrapping SELECT * FROM pg_publication WHERE pubname = 'airbyte_do_pub' 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Set initial fetch size: 10 rows 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown initiated... 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown completed. 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - using CDC: true 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - using CDC: true 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Global state manager selected to manage state object with type GLOBAL. 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='categories_maps', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='schema_migrations', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='user_subscriptions', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='product_details', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='products', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='store_inventories', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='subcategories', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='users', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='store_inventories_history', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='categories', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='admins', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='product_variant_details', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='stores', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='product_variants', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='grunters', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='producers', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='lamdba_calls', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='ar_internal_metadata', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='subcategories_maps', namespace='public'}. Cursor Field: null Value: null Count: 0 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Initialized CDC state with: io.airbyte.integrations.source.relationaldb.models.CdcState@7fae4d4a[state={"{\"schema\":null,\"payload\":[\"db_retracted_production\",{\"server\":\"db_retracted_production\"}]}":"{\"last_snapshot_record\":true,\"lsn\":18648427287728,\"txId\":735972527,\"ts_usec\":1667685490060591,\"snapshot\":true}"},additionalProperties={}] 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-2 - Starting... 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-2 - Start completed. 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Checking schema: public 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Internal schemas to exclude: [catalog_history, information_schema, pg_catalog, pg_internal] 2022-11-08 11:54:40 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Set initial fetch size: 10 rows 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Max memory limit: 25249710080, JDBC buffer size: 1073741824 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table subcategories_maps column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table subcategories_maps column raw_subcategory (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table subcategories_maps column subcategory_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column store_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column product_variant_detail_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column week_start (type date[13], nullable false) -> JsonSchemaType({type=string, format=date}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column sales (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column revenue (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_weeklies column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table categories_maps column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table categories_maps column raw_category (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table categories_maps column category_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table subcategories column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table subcategories column subcategory (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table subcategories column category_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_details column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_details column product_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_details column oos (type bool[1], nullable false) -> JsonSchemaType({type=boolean}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_details column price (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_details column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_details column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column email (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column encrypted_password (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column reset_password_token (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column reset_password_sent_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column remember_created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table grunters column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table user_subscriptions column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table user_subscriptions column user_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table user_subscriptions column level (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table user_subscriptions column ends_on (type date[13], nullable false) -> JsonSchemaType({type=string, format=date}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table user_subscriptions column comment (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table user_subscriptions column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table user_subscriptions column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table ar_internal_metadata column key (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table ar_internal_metadata column value (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table ar_internal_metadata column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table ar_internal_metadata column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column email (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column encrypted_password (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column reset_password_token (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column reset_password_sent_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column remember_created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table admins column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column store_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column variant_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column quantity (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column variance (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column last_updated (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column price (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column product_variant_detail_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timelines column rectification_flag (type sst_rectification_flag[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column store_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column variant_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column status (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column quantity (type numeric[0], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column last_updated (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories_history column product_variant_detail_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table categories column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table categories column category (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column uuid (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column name (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column phone (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column source (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column address (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column city (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column postcode (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column latitude (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column longitude (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table stores column store_type (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column store_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column variant_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column status (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column quantity (type numeric[0], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column last_updated (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_inventories column product_variant_detail_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table lamdba_calls column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table lamdba_calls column function_name (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table lamdba_calls column s3_path (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table lamdba_calls column endpoint_name (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table lamdba_calls column is_processed (type bool[1], nullable false) -> JsonSchemaType({type=boolean}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table lamdba_calls column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table lamdba_calls column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table schema_migrations column version (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column name (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column sales (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column revenue (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column producer (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column product_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column category (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column subcategory (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column canadian (type bool[1], nullable false) -> JsonSchemaType({type=boolean}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column quebecois (type bool[1], nullable false) -> JsonSchemaType({type=boolean}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table best_sellers_matview column unit_price (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column product_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column variant_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column discounted (type bool[1], nullable false) -> JsonSchemaType({type=boolean}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column display_price (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column product_variant_detail_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variants column store_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column email (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column encrypted_password (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column reset_password_token (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column reset_password_sent_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column remember_created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column locked_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table users column producer_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column brand (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column name (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column uuid (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column source (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column category (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column subcategory (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column active (type bool[1], nullable false) -> JsonSchemaType({type=boolean}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table products column json_attributes (type jsonb[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table producers column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table producers column name (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table producers column website (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column variant_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column product_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column uuid (type varchar[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column json_attributes (type jsonb[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column is_qc_made (type bool[1], nullable false) -> JsonSchemaType({type=boolean}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column producer_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column saq_category (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table product_variant_details column supply_mode (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column userid (type oid[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column dbid (type oid[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column queryid (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column query (type text[2147483647], nullable false) -> JsonSchemaType({type=string}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column calls (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column total_time (type float8[17], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column min_time (type float8[17], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column max_time (type float8[17], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column mean_time (type float8[17], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column stddev_time (type float8[17], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column rows (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column shared_blks_hit (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column shared_blks_read (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column shared_blks_dirtied (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column shared_blks_written (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column local_blks_hit (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column local_blks_read (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column local_blks_dirtied (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column local_blks_written (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column temp_blks_read (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column temp_blks_written (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column blk_read_time (type float8[17], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table pg_stat_statements column blk_write_time (type float8[17], nullable false) -> JsonSchemaType({type=number}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column id (type bigserial[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column store_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column product_variant_detail_id (type int8[19], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column closing_on (type date[13], nullable false) -> JsonSchemaType({type=string, format=date}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column eod (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column variance (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column price (type int4[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column created_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Table store_sales_timeline_dailies column updated_at (type timestamp[29], nullable false) -> JsonSchemaType({type=string, format=date-time, airbyte_type=timestamp_without_timezone}) 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.subcategories_maps 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.store_sales_timeline_weeklies 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.categories_maps 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.subcategories 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.product_details 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.grunters 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.user_subscriptions 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.ar_internal_metadata 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.admins 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.store_sales_timelines 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.store_inventories_history 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.categories 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.stores 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.store_inventories 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.lamdba_calls 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.schema_migrations 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.best_sellers_matview 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.product_variants 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.users 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.products 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.producers 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.product_variant_details 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.pg_stat_statements 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found table: public.store_sales_timeline_dailies 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - using CDC: true 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Set initial fetch size: 10 rows 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Max memory limit: 25249710080, JDBC buffer size: 1073741824 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - For CDC, only tables in publication airbyte_do_pub will be included in the sync: [public.store_sales_timeline_weeklies, public.categories_maps, public.schema_migrations, public.store_sales_timelines, public.user_subscriptions, public.product_details, public.products, public.store_inventories, public.users, public.subcategories, public.store_sales_timeline_dailies, public.store_inventories_history, public.categories, public.product_variant_details, public.admins, public.stores, public.product_variants, public.grunters, public.producers, public.lamdba_calls, public.ar_internal_metadata, public.subcategories_maps] 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - using CDC: true 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - First record waiting time: 300 seconds 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - First record waiting time: 300 seconds 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Attempting to find the named replication slot using the query: HikariProxyPreparedStatement@1184694332 wrapping SELECT * FROM pg_replication_slots WHERE slot_name = 'airbyte_slot_wal2json' AND plugin = 'wal2json' AND database = 'db_retracted_production' 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Set initial fetch size: 10 rows 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - StandaloneConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 1000 offset.flush.timeout.ms = 5000 offset.storage.file.filename = /tmp/cdc-state-offset11380312223909862028/offset.dat plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter 2022-11-08 11:54:41 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting FileOffsetBackingStore with file /tmp/cdc-state-offset11380312223909862028/offset.dat 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found previous partition offset PostgresPartition [sourcePartition={server=db_retracted_production}]: {transaction_id=null, lsn=18648427287728, txId=735972527, ts_usec=1667685490060591} 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closing offsetStorageReader and fileOffsetBackingStore 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopped FileOffsetBackingStore 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Replication slot confirmed_flush_lsn : 18572266059744 Saved offset LSN : 18648427287728 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - identified target lsn: PgLsn{lsn=18852272406968} 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Using CDC: true 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - EmbeddedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 1000 offset.flush.timeout.ms = 5000 offset.storage.file.filename = /tmp/cdc-state-offset14204924509798723861/offset.dat offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter 2022-11-08 11:54:41 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - The worker has been configured with one or more internal converter properties ([internal.key.converter, internal.value.converter]). Support for these properties was deprecated in version 2.0 and removed in version 3.0, and specifying them will have no effect. Instead, an instance of the JsonConverter with schemas.enable set to false will be used. For more information, please visit http://kafka.apache.org/documentation/#upgrade and consult the upgrade notesfor the 3.0 release. 2022-11-08 11:54:41 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting FileOffsetBackingStore with file /tmp/cdc-state-offset14204924509798723861/offset.dat 2022-11-08 11:54:41 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Logical decoder 'wal2json' is deprecated and will be removed in future versions 2022-11-08 11:54:41 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Configuration property 'truncate.handling.mode' is deprecated and will be removed in future versions. Please use 'skipped.operations' instead. 2022-11-08 11:54:41 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Configuration property 'toasted.value.placeholder' is deprecated and will be removed in future versions. Please use 'unavailable.value.placeholder' instead. 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting PostgresConnectorTask with configuration: 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - connector.class = io.debezium.connector.postgresql.PostgresConnector 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - max.queue.size = 8192 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - slot.name = airbyte_slot_wal2json 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - publication.name = airbyte_do_pub 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - offset.storage.file.filename = /tmp/cdc-state-offset14204924509798723861/offset.dat 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - decimal.handling.mode = string 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - converters = datetime 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - datetime.type = io.airbyte.integrations.debezium.internals.PostgresConverter 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - value.converter = org.apache.kafka.connect.json.JsonConverter 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - key.converter = org.apache.kafka.connect.json.JsonConverter 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - publication.autocreate.mode = disabled 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - database.user = username_retracted 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - database.dbname = db_retracted_production 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - database.server.name = db_retracted_production 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - offset.flush.timeout.ms = 5000 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - plugin.name = wal2json 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - database.port = 5432 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - offset.flush.interval.ms = 1000 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - key.converter.schemas.enable = false 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - internal.key.converter = org.apache.kafka.connect.json.JsonConverter 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - include.unknown.datatypes = true 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - database.hostname = 178.128.231.146 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - database.password = ******** 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - name = db_retracted_production 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - value.converter.schemas.enable = false 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - internal.value.converter = org.apache.kafka.connect.json.JsonConverter 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - max.batch.size = 2048 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - table.include.list = public.admins,public.ar_internal_metadata,public.categories,public.categories_maps,public.grunters,public.lamdba_calls,public.producers,public.product_details,public.product_variant_details,public.product_variants,public.products,public.schema_migrations,public.store_inventories,public.store_inventories_history,public.stores,public.subcategories,public.subcategories_maps,public.user_subscriptions,public.users 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - snapshot.mode = initial 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connection gracefully closed 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found previous partition offset PostgresPartition [sourcePartition={server=db_retracted_production}]: {transaction_id=null, lsn=18648427287728, txId=735972527, ts_usec=1667685490060591} 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - user 'username_retracted' connected to database 'db_retracted_production' on PostgreSQL 12.12 (Ubuntu 12.12-0ubuntu0.20.04.1) on x86_64-pc-linux-gnu, compiled by gcc (Ubuntu 9.4.0-1ubuntu1~20.04.1) 9.4.0, 64-bit with roles: role 'username_retracted' [superuser: false, replication: true, inherit: true, create role: false, create db: false, can log in: true] 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{10E4/315237E0}, catalogXmin=731873268] 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='db_retracted_production'db='db_retracted_production', lsn=LSN{10F5/ECE254B0}, txId=735972527, timestamp=2022-11-05T21:58:10.060591Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]] 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Previous snapshot has completed successfully, streaming logical changes from last known position 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Requested thread factory for connector PostgresConnector, id = db_retracted_production named = change-event-source-coordinator 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating thread debezium-postgresconnector-db_retracted_production-change-event-source-coordinator 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Metrics registered 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Context created 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Previous snapshot has completed successfully, streaming logical changes from last known position 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - According to the connector configuration no snapshot will be executed 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='db_retracted_production'db='db_retracted_production', lsn=LSN{10F5/ECE254B0}, txId=735972527, timestamp=2022-11-05T21:58:10.060591Z, snapshot=FALSE, schema=, table=], lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connected metrics set to 'true' 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@1e1b061 2022-11-08 11:54:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Start completed. 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.subcategories' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.users' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.admins' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.product_details' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.subcategories_maps' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.producers' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.products' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.user_subscriptions' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.product_variants' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.schema_migrations' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.categories_maps' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.ar_internal_metadata' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.store_inventories_history' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.stores' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.categories' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.grunters' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.lamdba_calls' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.product_variant_details' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.store_inventories' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting streaming 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Retrieved latest position from stored offset 'LSN{10F5/ECE254B0}' 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Looking for WAL restart position for last commit LSN 'null' and last change LSN 'LSN{10F5/ECE254B0}' 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{10E4/315237E0}, catalogXmin=731873268] 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connection gracefully closed 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Requested thread factory for connector PostgresConnector, id = db_retracted_production named = keep-alive 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating thread debezium-postgresconnector-db_retracted_production-keep-alive 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.subcategories' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.users' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.admins' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.product_details' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.subcategories_maps' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.producers' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.products' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.user_subscriptions' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.product_variants' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.schema_migrations' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.categories_maps' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.ar_internal_metadata' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.store_inventories_history' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.stores' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.categories' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream admins 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream ar_internal_metadata: tmp table: _airbyte_tmp_bfa_ar_internal_metadata, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.grunters' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.lamdba_calls' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.product_variant_details' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - REPLICA IDENTITY for 'public.store_inventories' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Searching for WAL resume position 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream ar_internal_metadata 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream categories: tmp table: _airbyte_tmp_zau_categories, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream categories 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream categories_maps: tmp table: _airbyte_tmp_voc_categories_maps, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream categories_maps 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream grunters: tmp table: _airbyte_tmp_uwg_grunters, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream grunters 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream lamdba_calls: tmp table: _airbyte_tmp_www_lamdba_calls, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:43 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream lamdba_calls 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream producers: tmp table: _airbyte_tmp_kkl_producers, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream producers 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream product_details: tmp table: _airbyte_tmp_ygt_product_details, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream product_details 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream product_variant_details: tmp table: _airbyte_tmp_tqz_product_variant_details, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream product_variant_details 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream product_variants: tmp table: _airbyte_tmp_sja_product_variants, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream product_variants 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream products: tmp table: _airbyte_tmp_vbp_products, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream products 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream schema_migrations: tmp table: _airbyte_tmp_gmz_schema_migrations, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream schema_migrations 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream store_inventories: tmp table: _airbyte_tmp_hol_store_inventories, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream store_inventories 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream store_inventories_history: tmp table: _airbyte_tmp_erh_store_inventories_history, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream store_inventories_history 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream stores: tmp table: _airbyte_tmp_img_stores, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream stores 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream subcategories: tmp table: _airbyte_tmp_wjy_subcategories, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream subcategories 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream subcategories_maps: tmp table: _airbyte_tmp_gus_subcategories_maps, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream subcategories_maps 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream user_subscriptions: tmp table: _airbyte_tmp_oiq_user_subscriptions, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream user_subscriptions 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination started for schema public stream users: tmp table: _airbyte_tmp_tzm_users, stage: 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ 2022-11-08 11:54:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - closing connection 2022-11-08 11:54:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing staging area in destination completed for schema public stream users 2022-11-08 11:54:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Preparing tmp tables in destination completed. 2022-11-08 11:59:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closing cause next is returned as null 2022-11-08 11:59:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopping the embedded engine 2022-11-08 11:59:41 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Waiting for PT5M for connector to stop 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopping the task and engine 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopping down connector 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - WAL resume position 'null' discovered 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connection gracefully closed 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Requested thread factory for connector PostgresConnector, id = db_retracted_production named = keep-alive 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Creating thread debezium-postgresconnector-db_retracted_production-keep-alive 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Processing messages 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connection gracefully closed 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Finished streaming 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connected metrics set to 'false' 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Connection gracefully closed 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Stopped FileOffsetBackingStore 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Debezium engine shutdown. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - no record found. polling again. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - debezium state: {"{\"schema\":null,\"payload\":[\"db_retracted_production\",{\"server\":\"db_retracted_production\"}]}":"{\"last_snapshot_record\":true,\"lsn\":18648427287728,\"txId\":735972527,\"ts_usec\":1667685490060591,\"snapshot\":true}"} 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closing database connection pool. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-2 - Shutdown initiated... 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-2 - Shutdown completed. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Closed database connection pool. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed source: io.airbyte.integrations.base.ssh.SshWrappedSource 2022-11-08 11:59:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):386 - Source has no more messages, closing connection. 2022-11-08 11:59:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):395 - Total records read: 1 (0 bytes) 2022-11-08 11:59:42 INFO i.a.w.g.DefaultReplicationWorker(run):202 - One of source or destination thread complete. Waiting on the other. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Airbyte message consumer: succeeded. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - executing on success close procedure. 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Flushing all 0 current buffers (0 bytes in total) 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying into tables in destination started for 19 streams 2022-11-08 11:59:42 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream admins of schema public into tmp table _airbyte_tmp_ihe_admins to final table _airbyte_raw_admins from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:44 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream ar_internal_metadata of schema public into tmp table _airbyte_tmp_bfa_ar_internal_metadata to final table _airbyte_raw_ar_internal_metadata from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream categories of schema public into tmp table _airbyte_tmp_zau_categories to final table _airbyte_raw_categories from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:45 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream categories_maps of schema public into tmp table _airbyte_tmp_voc_categories_maps to final table _airbyte_raw_categories_maps from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream grunters of schema public into tmp table _airbyte_tmp_uwg_grunters to final table _airbyte_raw_grunters from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:46 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream lamdba_calls of schema public into tmp table _airbyte_tmp_www_lamdba_calls to final table _airbyte_raw_lamdba_calls from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream producers of schema public into tmp table _airbyte_tmp_kkl_producers to final table _airbyte_raw_producers from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:47 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream product_details of schema public into tmp table _airbyte_tmp_ygt_product_details to final table _airbyte_raw_product_details from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream product_variant_details of schema public into tmp table _airbyte_tmp_tqz_product_variant_details to final table _airbyte_raw_product_variant_details from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream product_variants of schema public into tmp table _airbyte_tmp_sja_product_variants to final table _airbyte_raw_product_variants from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:48 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream products of schema public into tmp table _airbyte_tmp_vbp_products to final table _airbyte_raw_products from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream schema_migrations of schema public into tmp table _airbyte_tmp_gmz_schema_migrations to final table _airbyte_raw_schema_migrations from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream store_inventories of schema public into tmp table _airbyte_tmp_hol_store_inventories to final table _airbyte_raw_store_inventories from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream store_inventories_history of schema public into tmp table _airbyte_tmp_erh_store_inventories_history to final table _airbyte_raw_store_inventories_history from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream stores of schema public into tmp table _airbyte_tmp_img_stores to final table _airbyte_raw_stores from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream subcategories of schema public into tmp table _airbyte_tmp_wjy_subcategories to final table _airbyte_raw_subcategories from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream subcategories_maps of schema public into tmp table _airbyte_tmp_gus_subcategories_maps to final table _airbyte_raw_subcategories_maps from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream user_subscriptions of schema public into tmp table _airbyte_tmp_oiq_user_subscriptions to final table _airbyte_raw_user_subscriptions from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Copying stream users of schema public into tmp table _airbyte_tmp_tzm_users to final table _airbyte_raw_users from stage path 2022/11/08/11/5882AD69-6A4F-425A-91CB-27BF0F29EB20/ with 0 file(s) [] 2022-11-08 11:59:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - No onDestinationCloseOperations required for this destination. 2022-11-08 11:59:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Executing finalization of tables. 2022-11-08 11:59:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Finalizing tables in destination completed. 2022-11-08 11:59:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning up destination started for 19 streams 2022-11-08 11:59:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream admins. schema public, tmp table name: _airbyte_tmp_ihe_admins 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream admins. schema public, stage: PUBLIC_ADMINS 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream ar_internal_metadata. schema public, tmp table name: _airbyte_tmp_bfa_ar_internal_metadata 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream ar_internal_metadata. schema public, stage: PUBLIC_AR_INTERNAL_METADATA 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream categories. schema public, tmp table name: _airbyte_tmp_zau_categories 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream categories. schema public, stage: PUBLIC_CATEGORIES 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream categories_maps. schema public, tmp table name: _airbyte_tmp_voc_categories_maps 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream categories_maps. schema public, stage: PUBLIC_CATEGORIES_MAPS 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream grunters. schema public, tmp table name: _airbyte_tmp_uwg_grunters 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream grunters. schema public, stage: PUBLIC_GRUNTERS 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream lamdba_calls. schema public, tmp table name: _airbyte_tmp_www_lamdba_calls 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream lamdba_calls. schema public, stage: PUBLIC_LAMDBA_CALLS 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream producers. schema public, tmp table name: _airbyte_tmp_kkl_producers 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream producers. schema public, stage: PUBLIC_PRODUCERS 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream product_details. schema public, tmp table name: _airbyte_tmp_ygt_product_details 2022-11-08 11:59:56 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream product_details. schema public, stage: PUBLIC_PRODUCT_DETAILS 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream product_variant_details. schema public, tmp table name: _airbyte_tmp_tqz_product_variant_details 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream product_variant_details. schema public, stage: PUBLIC_PRODUCT_VARIANT_DETAILS 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream product_variants. schema public, tmp table name: _airbyte_tmp_sja_product_variants 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream product_variants. schema public, stage: PUBLIC_PRODUCT_VARIANTS 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream products. schema public, tmp table name: _airbyte_tmp_vbp_products 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream products. schema public, stage: PUBLIC_PRODUCTS 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream schema_migrations. schema public, tmp table name: _airbyte_tmp_gmz_schema_migrations 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream schema_migrations. schema public, stage: PUBLIC_SCHEMA_MIGRATIONS 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream store_inventories. schema public, tmp table name: _airbyte_tmp_hol_store_inventories 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream store_inventories. schema public, stage: PUBLIC_STORE_INVENTORIES 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream store_inventories_history. schema public, tmp table name: _airbyte_tmp_erh_store_inventories_history 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream store_inventories_history. schema public, stage: PUBLIC_STORE_INVENTORIES_HISTORY 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream stores. schema public, tmp table name: _airbyte_tmp_img_stores 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream stores. schema public, stage: PUBLIC_STORES 2022-11-08 11:59:57 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream subcategories. schema public, tmp table name: _airbyte_tmp_wjy_subcategories 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream subcategories. schema public, stage: PUBLIC_SUBCATEGORIES 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream subcategories_maps. schema public, tmp table name: _airbyte_tmp_gus_subcategories_maps 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream subcategories_maps. schema public, stage: PUBLIC_SUBCATEGORIES_MAPS 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream user_subscriptions. schema public, tmp table name: _airbyte_tmp_oiq_user_subscriptions 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream user_subscriptions. schema public, stage: PUBLIC_USER_SUBSCRIPTIONS 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning tmp table in destination started for stream users. schema public, tmp table name: _airbyte_tmp_tzm_users 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning stage in destination started for stream users. schema public, stage: PUBLIC_USERS 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Cleaning up destination completed. 2022-11-08 11:59:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):478 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@406d5aae[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@4eaaacd3[type=GLOBAL,stream=,global=io.airbyte.protocol.models.AirbyteGlobalState@4a9531de[sharedState={"state":{"{\"schema\":null,\"payload\":[\"db_retracted_production\",{\"server\":\"db_retracted_production\"}]}":"{\"last_snapshot_record\":true,\"lsn\":18648427287728,\"txId\":735972527,\"ts_usec\":1667685490060591,\"snapshot\":true}"}},streamStates=[io.airbyte.protocol.models.AirbyteStreamState@f97a6e8[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2505259e[name=admins,namespace=public,additionalProperties={}],streamState={"stream_name":"admins","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@3e52c9d9[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@5d2a140c[name=ar_internal_metadata,namespace=public,additionalProperties={}],streamState={"stream_name":"ar_internal_metadata","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@6fb859a7[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@631da81b[name=categories,namespace=public,additionalProperties={}],streamState={"stream_name":"categories","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@4ba9a9a0[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@462e5ead[name=categories_maps,namespace=public,additionalProperties={}],streamState={"stream_name":"categories_maps","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@6bf642ae[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@65a572bb[name=grunters,namespace=public,additionalProperties={}],streamState={"stream_name":"grunters","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@63472306[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@57a8d2f5[name=lamdba_calls,namespace=public,additionalProperties={}],streamState={"stream_name":"lamdba_calls","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@e12199c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@40ec924f[name=producers,namespace=public,additionalProperties={}],streamState={"stream_name":"producers","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@1a69d647[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@bc78085[name=product_details,namespace=public,additionalProperties={}],streamState={"stream_name":"product_details","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@1507a698[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@315d309d[name=product_variant_details,namespace=public,additionalProperties={}],streamState={"stream_name":"product_variant_details","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@6552031f[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@52a67498[name=product_variants,namespace=public,additionalProperties={}],streamState={"stream_name":"product_variants","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@7abd3b32[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@22bc2520[name=products,namespace=public,additionalProperties={}],streamState={"stream_name":"products","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@57839093[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@36602c4f[name=schema_migrations,namespace=public,additionalProperties={}],streamState={"stream_name":"schema_migrations","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@2517f51a[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@664151bd[name=store_inventories,namespace=public,additionalProperties={}],streamState={"stream_name":"store_inventories","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@2d0d52ee[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@1ab80154[name=store_inventories_history,namespace=public,additionalProperties={}],streamState={"stream_name":"store_inventories_history","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@1d883c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@6cbded3b[name=stores,namespace=public,additionalProperties={}],streamState={"stream_name":"stores","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@2b604860[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@71884ef9[name=subcategories,namespace=public,additionalProperties={}],streamState={"stream_name":"subcategories","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@1db8649c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@1e6f9625[name=subcategories_maps,namespace=public,additionalProperties={}],streamState={"stream_name":"subcategories_maps","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@37e5eec0[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@4a99143[name=user_subscriptions,namespace=public,additionalProperties={}],streamState={"stream_name":"user_subscriptions","stream_namespace":"public","cursor_field":[]},additionalProperties={}], io.airbyte.protocol.models.AirbyteStreamState@5a6b99ce[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@3857e218[name=users,namespace=public,additionalProperties={}],streamState={"stream_name":"users","stream_namespace":"public","cursor_field":[]},additionalProperties={}]],additionalProperties={}],data={"cdc":true,"cdc_state":{"state":{"{\"schema\":null,\"payload\":[\"db_retracted_production\",{\"server\":\"db_retracted_production\"}]}":"{\"last_snapshot_record\":true,\"lsn\":18648427287728,\"txId\":735972527,\"ts_usec\":1667685490060591,\"snapshot\":true}"}},"streams":[{"stream_name":"admins","stream_namespace":"public","cursor_field":[]},{"stream_name":"ar_internal_metadata","stream_namespace":"public","cursor_field":[]},{"stream_name":"categories","stream_namespace":"public","cursor_field":[]},{"stream_name":"categories_maps","stream_namespace":"public","cursor_field":[]},{"stream_name":"grunters","stream_namespace":"public","cursor_field":[]},{"stream_name":"lamdba_calls","stream_namespace":"public","cursor_field":[]},{"stream_name":"producers","stream_namespace":"public","cursor_field":[]},{"stream_name":"product_details","stream_namespace":"public","cursor_field":[]},{"stream_name":"product_variant_details","stream_namespace":"public","cursor_field":[]},{"stream_name":"product_variants","stream_namespace":"public","cursor_field":[]},{"stream_name":"products","stream_namespace":"public","cursor_field":[]},{"stream_name":"schema_migrations","stream_namespace":"public","cursor_field":[]},{"stream_name":"store_inventories","stream_namespace":"public","cursor_field":[]},{"stream_name":"store_inventories_history","stream_namespace":"public","cursor_field":[]},{"stream_name":"stores","stream_namespace":"public","cursor_field":[]},{"stream_name":"subcategories","stream_namespace":"public","cursor_field":[]},{"stream_name":"subcategories_maps","stream_namespace":"public","cursor_field":[]},{"stream_name":"user_subscriptions","stream_namespace":"public","cursor_field":[]},{"stream_name":"users","stream_namespace":"public","cursor_field":[]}]},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-11-08 11:59:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination 2022-11-08 11:59:59 INFO i.a.w.g.DefaultReplicationWorker(run):204 - Source and destination threads complete. 2022-11-08 11:59:59 INFO i.a.w.g.DefaultReplicationWorker(run):308 - Source output at least one state message 2022-11-08 11:59:59 INFO i.a.w.g.DefaultReplicationWorker(run):314 - State capture: Updated state to: Optional[io.airbyte.config.State@5f9bd935[state=[{"type":"GLOBAL","global":{"shared_state":{"state":{"{\"schema\":null,\"payload\":[\"db_retracted_production\",{\"server\":\"db_retracted_production\"}]}":"{\"last_snapshot_record\":true,\"lsn\":18648427287728,\"txId\":735972527,\"ts_usec\":1667685490060591,\"snapshot\":true}"}},"stream_states":[{"stream_descriptor":{"name":"admins","namespace":"public"},"stream_state":{"stream_name":"admins","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"ar_internal_metadata","namespace":"public"},"stream_state":{"stream_name":"ar_internal_metadata","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"categories","namespace":"public"},"stream_state":{"stream_name":"categories","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"categories_maps","namespace":"public"},"stream_state":{"stream_name":"categories_maps","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"grunters","namespace":"public"},"stream_state":{"stream_name":"grunters","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"lamdba_calls","namespace":"public"},"stream_state":{"stream_name":"lamdba_calls","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"producers","namespace":"public"},"stream_state":{"stream_name":"producers","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"product_details","namespace":"public"},"stream_state":{"stream_name":"product_details","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"product_variant_details","namespace":"public"},"stream_state":{"stream_name":"product_variant_details","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"product_variants","namespace":"public"},"stream_state":{"stream_name":"product_variants","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"products","namespace":"public"},"stream_state":{"stream_name":"products","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"schema_migrations","namespace":"public"},"stream_state":{"stream_name":"schema_migrations","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"store_inventories","namespace":"public"},"stream_state":{"stream_name":"store_inventories","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"store_inventories_history","namespace":"public"},"stream_state":{"stream_name":"store_inventories_history","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"stores","namespace":"public"},"stream_state":{"stream_name":"stores","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"subcategories","namespace":"public"},"stream_state":{"stream_name":"subcategories","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"subcategories_maps","namespace":"public"},"stream_state":{"stream_name":"subcategories_maps","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"user_subscriptions","namespace":"public"},"stream_state":{"stream_name":"user_subscriptions","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"users","namespace":"public"},"stream_state":{"stream_name":"users","stream_namespace":"public","cursor_field":[]}}]}}]]] 2022-11-08 11:59:59 INFO i.a.w.g.DefaultReplicationWorker(run):329 - sync summary: { "status" : "completed", "recordsSynced" : 0, "bytesSynced" : 0, "startTime" : 1667908477678, "endTime" : 1667908799885, "totalStats" : { "recordsEmitted" : 0, "bytesEmitted" : 0, "sourceStateMessagesEmitted" : 1, "destinationStateMessagesEmitted" : 1, "recordsCommitted" : 0, "meanSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBetweenStateMessageEmittedandCommitted" : 16, "meanSecondsBetweenStateMessageEmittedandCommitted" : 16, "replicationStartTime" : 1667908477678, "replicationEndTime" : 1667908799885, "sourceReadStartTime" : 1667908477711, "sourceReadEndTime" : 1667908782614, "destinationWriteStartTime" : 1667908477762, "destinationWriteEndTime" : 1667908799885 }, "streamStats" : [ ] } 2022-11-08 11:59:59 INFO i.a.w.g.DefaultReplicationWorker(run):330 - failures: [ ] 2022-11-08 11:59:59 INFO i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling... 2022-11-08 11:59:59 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-08 11:59:59 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION ----- 2022-11-08 11:59:59 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-08 11:59:59 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):186 - sync summary: io.airbyte.config.StandardSyncOutput@1605bc8d[standardSyncSummary=io.airbyte.config.StandardSyncSummary@66bf2c95[status=completed,recordsSynced=0,bytesSynced=0,startTime=1667908477678,endTime=1667908799885,totalStats=io.airbyte.config.SyncStats@60dbcdea[recordsEmitted=0,bytesEmitted=0,sourceStateMessagesEmitted=1,destinationStateMessagesEmitted=1,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=16,meanSecondsBetweenStateMessageEmittedandCommitted=16,replicationStartTime=1667908477678,replicationEndTime=1667908799885,sourceReadStartTime=1667908477711,sourceReadEndTime=1667908782614,destinationWriteStartTime=1667908477762,destinationWriteEndTime=1667908799885,additionalProperties={}],streamStats=[]],normalizationSummary=,webhookOperationSummary=,state=io.airbyte.config.State@5f9bd935[state=[{"type":"GLOBAL","global":{"shared_state":{"state":{"{\"schema\":null,\"payload\":[\"db_retracted_production\",{\"server\":\"db_retracted_production\"}]}":"{\"last_snapshot_record\":true,\"lsn\":18648427287728,\"txId\":735972527,\"ts_usec\":1667685490060591,\"snapshot\":true}"}},"stream_states":[{"stream_descriptor":{"name":"admins","namespace":"public"},"stream_state":{"stream_name":"admins","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"ar_internal_metadata","namespace":"public"},"stream_state":{"stream_name":"ar_internal_metadata","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"categories","namespace":"public"},"stream_state":{"stream_name":"categories","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"categories_maps","namespace":"public"},"stream_state":{"stream_name":"categories_maps","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"grunters","namespace":"public"},"stream_state":{"stream_name":"grunters","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"lamdba_calls","namespace":"public"},"stream_state":{"stream_name":"lamdba_calls","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"producers","namespace":"public"},"stream_state":{"stream_name":"producers","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"product_details","namespace":"public"},"stream_state":{"stream_name":"product_details","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"product_variant_details","namespace":"public"},"stream_state":{"stream_name":"product_variant_details","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"product_variants","namespace":"public"},"stream_state":{"stream_name":"product_variants","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"products","namespace":"public"},"stream_state":{"stream_name":"products","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"schema_migrations","namespace":"public"},"stream_state":{"stream_name":"schema_migrations","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"store_inventories","namespace":"public"},"stream_state":{"stream_name":"store_inventories","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"store_inventories_history","namespace":"public"},"stream_state":{"stream_name":"store_inventories_history","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"stores","namespace":"public"},"stream_state":{"stream_name":"stores","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"subcategories","namespace":"public"},"stream_state":{"stream_name":"subcategories","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"subcategories_maps","namespace":"public"},"stream_state":{"stream_name":"subcategories_maps","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"user_subscriptions","namespace":"public"},"stream_state":{"stream_name":"user_subscriptions","stream_namespace":"public","cursor_field":[]}},{"stream_descriptor":{"name":"users","namespace":"public"},"stream_state":{"stream_name":"users","stream_namespace":"public","cursor_field":[]}}]}}]],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5312bf25[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6848901e[stream=io.airbyte.protocol.models.AirbyteStream@778cc206[name=admins,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"email":{"type":"string"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"encrypted_password":{"type":"string"},"remember_created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"reset_password_token":{"type":"string"},"reset_password_sent_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4986e580[stream=io.airbyte.protocol.models.AirbyteStream@f2b8002[name=ar_internal_metadata,jsonSchema={"type":"object","properties":{"key":{"type":"string"},"value":{"type":"string"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[key]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[key]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@23cf3999[stream=io.airbyte.protocol.models.AirbyteStream@32424314[name=categories,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"category":{"type":"string"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4c161a39[stream=io.airbyte.protocol.models.AirbyteStream@1feea829[name=categories_maps,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_lsn":{"type":"number"},"category_id":{"type":"number","airbyte_type":"integer"},"raw_category":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@453749bc[stream=io.airbyte.protocol.models.AirbyteStream@65cdf8ed[name=grunters,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"email":{"type":"string"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"encrypted_password":{"type":"string"},"remember_created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"reset_password_token":{"type":"string"},"reset_password_sent_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@19f6f1bf[stream=io.airbyte.protocol.models.AirbyteStream@73b3bd48[name=lamdba_calls,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"s3_path":{"type":"string"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"is_processed":{"type":"boolean"},"endpoint_name":{"type":"string"},"function_name":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@c36702b[stream=io.airbyte.protocol.models.AirbyteStream@6b6ebd0[name=producers,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"name":{"type":"string"},"website":{"type":"string"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@286389b0[stream=io.airbyte.protocol.models.AirbyteStream@46542809[name=product_details,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"oos":{"type":"boolean"},"price":{"type":"number","airbyte_type":"integer"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"product_id":{"type":"number","airbyte_type":"integer"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@795cbfc0[stream=io.airbyte.protocol.models.AirbyteStream@48852350[name=product_variant_details,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"uuid":{"type":"string"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"is_qc_made":{"type":"boolean"},"product_id":{"type":"number","airbyte_type":"integer"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"variant_id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_lsn":{"type":"number"},"producer_id":{"type":"number","airbyte_type":"integer"},"supply_mode":{"type":"string"},"saq_category":{"type":"string"},"json_attributes":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7c9f1df9[stream=io.airbyte.protocol.models.AirbyteStream@1b6c7603[name=product_variants,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"store_id":{"type":"number","airbyte_type":"integer"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"discounted":{"type":"boolean"},"product_id":{"type":"number","airbyte_type":"integer"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"variant_id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_lsn":{"type":"number"},"display_price":{"type":"number","airbyte_type":"integer"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"product_variant_detail_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@7d26811[stream=io.airbyte.protocol.models.AirbyteStream@66ac5418[name=products,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"name":{"type":"string"},"uuid":{"type":"string"},"brand":{"type":"string"},"active":{"type":"boolean"},"source":{"type":"string"},"category":{"type":"string"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"subcategory":{"type":"string"},"json_attributes":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@62d8ede1[stream=io.airbyte.protocol.models.AirbyteStream@1a7c43d7[name=schema_migrations,jsonSchema={"type":"object","properties":{"version":{"type":"string"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[version]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[version]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@e7a2269[stream=io.airbyte.protocol.models.AirbyteStream@af2bb2a[name=store_inventories,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"status":{"type":"number","airbyte_type":"integer"},"quantity":{"type":"number"},"store_id":{"type":"number","airbyte_type":"integer"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"variant_id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_lsn":{"type":"number"},"last_updated":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"product_variant_detail_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2f60f870[stream=io.airbyte.protocol.models.AirbyteStream@577a74b0[name=store_inventories_history,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"status":{"type":"number","airbyte_type":"integer"},"quantity":{"type":"number"},"store_id":{"type":"number","airbyte_type":"integer"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"variant_id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_lsn":{"type":"number"},"last_updated":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"product_variant_detail_id":{"type":"number","airbyte_type":"integer"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@8cc6d5c[stream=io.airbyte.protocol.models.AirbyteStream@17f8ac84[name=stores,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"city":{"type":"string"},"name":{"type":"string"},"uuid":{"type":"string"},"phone":{"type":"string"},"source":{"type":"string"},"address":{"type":"string"},"latitude":{"type":"string"},"postcode":{"type":"string"},"longitude":{"type":"string"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"store_type":{"type":"string"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3ff37573[stream=io.airbyte.protocol.models.AirbyteStream@3b2849c9[name=subcategories,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_lsn":{"type":"number"},"category_id":{"type":"number","airbyte_type":"integer"},"subcategory":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@50e5757d[stream=io.airbyte.protocol.models.AirbyteStream@2ab7f69[name=subcategories_maps,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_lsn":{"type":"number"},"subcategory_id":{"type":"number","airbyte_type":"integer"},"raw_subcategory":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@26d7caa2[stream=io.airbyte.protocol.models.AirbyteStream@5f48a9b0[name=user_subscriptions,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"level":{"type":"string"},"comment":{"type":"string"},"ends_on":{"type":"string","format":"date"},"user_id":{"type":"number","airbyte_type":"integer"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@24fd61b9[stream=io.airbyte.protocol.models.AirbyteStream@7df40278[name=users,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"email":{"type":"string"},"locked_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"updated_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"_ab_cdc_lsn":{"type":"number"},"producer_id":{"type":"number","airbyte_type":"integer"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"encrypted_password":{"type":"string"},"remember_created_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"},"reset_password_token":{"type":"string"},"reset_password_sent_at":{"type":"string","format":"date-time","airbyte_type":"timestamp_without_timezone"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=public,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-11-08 11:59:59 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):191 - Sync summary length: 22423 2022-11-08 11:59:59 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2022-11-08 11:59:59 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):50 - Using default value for environment variable NEED_STATE_VALIDATION: 'true' 2022-11-08 12:00:00 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/8/0/logs.log 2022-11-08 12:00:00 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.18 2022-11-08 12:00:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-08 12:00:00 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION ----- 2022-11-08 12:00:00 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-08 12:00:00 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):134 - Running with normalization version: airbyte/normalization-snowflake:0.2.24 2022-11-08 12:00:00 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization-snowflake:0.2.24 exists... 2022-11-08 12:00:00 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization-snowflake:0.2.24 was found locally. 2022-11-08 12:00:00 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = normalization-snowflake-normalize-8-0-rmyzm with resources io.airbyte.config.ResourceRequirements@2d315b2c[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-11-08 12:00:00 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/8/0/normalize --log-driver none --name normalization-snowflake-normalize-8-0-rmyzm --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.40.18 airbyte/normalization-snowflake:0.2.24 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json 2022-11-08 12:00:00 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/8/0/normalize 2022-11-08 12:00:00 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/8/0/normalize') 2022-11-08 12:00:00 normalization > transform_snowflake 2022-11-08 12:00:00 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/8/0/normalize --catalog destination_catalog.json --out /data/8/0/normalize/models/generated/ --json-column _airbyte_data 2022-11-08 12:00:01 normalization > Processing destination_catalog.json... 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/ADMINS_AB1.sql from admins 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/ADMINS_AB2.sql from admins 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/ADMINS_STG.sql from admins 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/ADMINS_SCD.sql from admins 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/ADMINS.sql from admins 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/AR_INTERNAL_METADATA_AB1.sql from ar_internal_metadata 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/AR_INTERNAL_METADATA_AB2.sql from ar_internal_metadata 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/AR_INTERNAL_METADATA_STG.sql from ar_internal_metadata 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/AR_INTERNAL_METADATA_SCD.sql from ar_internal_metadata 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/AR_INTERNAL_METADATA.sql from ar_internal_metadata 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/CATEGORIES_AB1.sql from categories 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/CATEGORIES_AB2.sql from categories 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/CATEGORIES_STG.sql from categories 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/CATEGORIES_SCD.sql from categories 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/CATEGORIES.sql from categories 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/CATEGORIES_MAPS_AB1.sql from categories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/CATEGORIES_MAPS_AB2.sql from categories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/CATEGORIES_MAPS_STG.sql from categories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/CATEGORIES_MAPS_SCD.sql from categories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/CATEGORIES_MAPS.sql from categories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/GRUNTERS_AB1.sql from grunters 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/GRUNTERS_AB2.sql from grunters 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/GRUNTERS_STG.sql from grunters 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/GRUNTERS_SCD.sql from grunters 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/GRUNTERS.sql from grunters 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/LAMDBA_CALLS_AB1.sql from lamdba_calls 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/LAMDBA_CALLS_AB2.sql from lamdba_calls 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/LAMDBA_CALLS_STG.sql from lamdba_calls 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/LAMDBA_CALLS_SCD.sql from lamdba_calls 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/LAMDBA_CALLS.sql from lamdba_calls 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCERS_AB1.sql from producers 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCERS_AB2.sql from producers 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/PRODUCERS_STG.sql from producers 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/PRODUCERS_SCD.sql from producers 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/PRODUCERS.sql from producers 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCT_DETAILS_AB1.sql from product_details 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCT_DETAILS_AB2.sql from product_details 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/PRODUCT_DETAILS_STG.sql from product_details 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/PRODUCT_DETAILS_SCD.sql from product_details 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/PRODUCT_DETAILS.sql from product_details 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCT_VARIANT_DETAILS_AB1.sql from product_variant_details 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCT_VARIANT_DETAILS_AB2.sql from product_variant_details 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/PRODUCT_VARIANT_DETAILS_STG.sql from product_variant_details 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/PRODUCT_VARIANT_DETAILS_SCD.sql from product_variant_details 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/PRODUCT_VARIANT_DETAILS.sql from product_variant_details 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCT_VARIANTS_AB1.sql from product_variants 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCT_VARIANTS_AB2.sql from product_variants 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/PRODUCT_VARIANTS_STG.sql from product_variants 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/PRODUCT_VARIANTS_SCD.sql from product_variants 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/PRODUCT_VARIANTS.sql from product_variants 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCTS_AB1.sql from products 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/PRODUCTS_AB2.sql from products 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/PRODUCTS_STG.sql from products 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/PRODUCTS_SCD.sql from products 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/PRODUCTS.sql from products 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/SCHEMA_MIGRATIONS_AB1.sql from schema_migrations 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/SCHEMA_MIGRATIONS_AB2.sql from schema_migrations 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/SCHEMA_MIGRATIONS_STG.sql from schema_migrations 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/SCHEMA_MIGRATIONS_SCD.sql from schema_migrations 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/SCHEMA_MIGRATIONS.sql from schema_migrations 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/STORE_INVENTORIES_AB1.sql from store_inventories 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/STORE_INVENTORIES_AB2.sql from store_inventories 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/STORE_INVENTORIES_STG.sql from store_inventories 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/STORE_INVENTORIES_SCD.sql from store_inventories 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/STORE_INVENTORIES.sql from store_inventories 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/STORE_INVENTORIES_HISTORY_AB1.sql from store_inventories_history 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/STORE_INVENTORIES_HISTORY_AB2.sql from store_inventories_history 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/STORE_INVENTORIES_HISTORY_STG.sql from store_inventories_history 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/STORE_INVENTORIES_HISTORY_SCD.sql from store_inventories_history 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/STORE_INVENTORIES_HISTORY.sql from store_inventories_history 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/STORES_AB1.sql from stores 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/STORES_AB2.sql from stores 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/STORES_STG.sql from stores 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/STORES_SCD.sql from stores 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/STORES.sql from stores 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/SUBCATEGORIES_AB1.sql from subcategories 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/SUBCATEGORIES_AB2.sql from subcategories 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/SUBCATEGORIES_STG.sql from subcategories 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/SUBCATEGORIES_SCD.sql from subcategories 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/SUBCATEGORIES.sql from subcategories 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/SUBCATEGORIES_MAPS_AB1.sql from subcategories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/SUBCATEGORIES_MAPS_AB2.sql from subcategories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/SUBCATEGORIES_MAPS_STG.sql from subcategories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/SUBCATEGORIES_MAPS_SCD.sql from subcategories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/SUBCATEGORIES_MAPS.sql from subcategories_maps 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/USER_SUBSCRIPTIONS_AB1.sql from user_subscriptions 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/USER_SUBSCRIPTIONS_AB2.sql from user_subscriptions 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/USER_SUBSCRIPTIONS_STG.sql from user_subscriptions 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/USER_SUBSCRIPTIONS_SCD.sql from user_subscriptions 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/USER_SUBSCRIPTIONS.sql from user_subscriptions 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/USERS_AB1.sql from users 2022-11-08 12:00:01 normalization > Generating airbyte_ctes/PUBLIC/USERS_AB2.sql from users 2022-11-08 12:00:01 normalization > Generating airbyte_views/PUBLIC/USERS_STG.sql from users 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/scd/PUBLIC/USERS_SCD.sql from users 2022-11-08 12:00:01 normalization > Generating airbyte_incremental/PUBLIC/USERS.sql from users 2022-11-08 12:00:01 normalization > detected no config file for ssh, assuming ssh is off. 2022-11-08 12:00:04 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-11-08 12:00:04 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-11-08 12:00:04 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2022-11-08 12:00:04 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-11-08 12:00:04 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2022-11-08 12:00:06 normalization > Running with dbt=1.0.0 2022-11-08 12:00:06 normalization > Partial parse save file not found. Starting full parse. 2022-11-08 12:00:09 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. There are 1 unused configuration paths: - models.airbyte_utils.generated.airbyte_tables 2022-11-08 12:00:09 normalization > Found 95 models, 0 tests, 0 snapshots, 0 analyses, 593 macros, 0 operations, 0 seed files, 19 sources, 0 exposures, 0 metrics 2022-11-08 12:00:11 normalization > Concurrency: 5 threads (target='prod') 2022-11-08 12:00:12 normalization > 1 of 57 START view model _AIRBYTE_PUBLIC.CATEGORIES_STG................................................................. [RUN] 2022-11-08 12:00:12 normalization > 2 of 57 START view model _AIRBYTE_PUBLIC.ADMINS_STG..................................................................... [RUN] 2022-11-08 12:00:12 normalization > 3 of 57 START view model _AIRBYTE_PUBLIC.CATEGORIES_MAPS_STG............................................................ [RUN] 2022-11-08 12:00:12 normalization > 4 of 57 START view model _AIRBYTE_PUBLIC.GRUNTERS_STG................................................................... [RUN] 2022-11-08 12:00:12 normalization > 5 of 57 START view model _AIRBYTE_PUBLIC.PRODUCERS_STG.................................................................. [RUN] 2022-11-08 12:00:13 normalization > 1 of 57 OK created view model _AIRBYTE_PUBLIC.CATEGORIES_STG............................................................ [SUCCESS 1 in 1.90s] 2022-11-08 12:00:13 normalization > 6 of 57 START view model _AIRBYTE_PUBLIC.AR_INTERNAL_METADATA_STG....................................................... [RUN] 2022-11-08 12:00:13 normalization > 3 of 57 OK created view model _AIRBYTE_PUBLIC.CATEGORIES_MAPS_STG....................................................... [SUCCESS 1 in 1.88s] 2022-11-08 12:00:14 normalization > 7 of 57 START view model _AIRBYTE_PUBLIC.LAMDBA_CALLS_STG............................................................... [RUN] 2022-11-08 12:00:14 normalization > 2 of 57 OK created view model _AIRBYTE_PUBLIC.ADMINS_STG................................................................ [SUCCESS 1 in 1.94s] 2022-11-08 12:00:14 normalization > 8 of 57 START view model _AIRBYTE_PUBLIC.PRODUCTS_STG................................................................... [RUN] 2022-11-08 12:00:14 normalization > 4 of 57 OK created view model _AIRBYTE_PUBLIC.GRUNTERS_STG.............................................................. [SUCCESS 1 in 2.33s] 2022-11-08 12:00:14 normalization > 9 of 57 START view model _AIRBYTE_PUBLIC.PRODUCT_DETAILS_STG............................................................ [RUN] 2022-11-08 12:00:14 normalization > 5 of 57 OK created view model _AIRBYTE_PUBLIC.PRODUCERS_STG............................................................. [SUCCESS 1 in 2.36s] 2022-11-08 12:00:14 normalization > 10 of 57 START view model _AIRBYTE_PUBLIC.PRODUCT_VARIANTS_STG.......................................................... [RUN] 2022-11-08 12:00:15 normalization > 6 of 57 OK created view model _AIRBYTE_PUBLIC.AR_INTERNAL_METADATA_STG.................................................. [SUCCESS 1 in 1.68s] 2022-11-08 12:00:15 normalization > 11 of 57 START view model _AIRBYTE_PUBLIC.SCHEMA_MIGRATIONS_STG......................................................... [RUN] 2022-11-08 12:00:15 normalization > 8 of 57 OK created view model _AIRBYTE_PUBLIC.PRODUCTS_STG.............................................................. [SUCCESS 1 in 1.63s] 2022-11-08 12:00:15 normalization > 12 of 57 START view model _AIRBYTE_PUBLIC.PRODUCT_VARIANT_DETAILS_STG................................................... [RUN] 2022-11-08 12:00:15 normalization > 7 of 57 OK created view model _AIRBYTE_PUBLIC.LAMDBA_CALLS_STG.......................................................... [SUCCESS 1 in 1.74s] 2022-11-08 12:00:15 normalization > 9 of 57 OK created view model _AIRBYTE_PUBLIC.PRODUCT_DETAILS_STG....................................................... [SUCCESS 1 in 1.22s] 2022-11-08 12:00:15 normalization > 13 of 57 START view model _AIRBYTE_PUBLIC.STORES_STG.................................................................... [RUN] 2022-11-08 12:00:15 normalization > 14 of 57 START view model _AIRBYTE_PUBLIC.STORE_INVENTORIES_STG......................................................... [RUN] 2022-11-08 12:00:15 normalization > 10 of 57 OK created view model _AIRBYTE_PUBLIC.PRODUCT_VARIANTS_STG..................................................... [SUCCESS 1 in 1.24s] 2022-11-08 12:00:16 normalization > 15 of 57 START view model _AIRBYTE_PUBLIC.STORE_INVENTORIES_HISTORY_STG................................................. [RUN] 2022-11-08 12:00:17 normalization > 11 of 57 OK created view model _AIRBYTE_PUBLIC.SCHEMA_MIGRATIONS_STG.................................................... [SUCCESS 1 in 1.69s] 2022-11-08 12:00:17 normalization > 16 of 57 START view model _AIRBYTE_PUBLIC.SUBCATEGORIES_STG............................................................. [RUN] 2022-11-08 12:00:17 normalization > 13 of 57 OK created view model _AIRBYTE_PUBLIC.STORES_STG............................................................... [SUCCESS 1 in 1.65s] 2022-11-08 12:00:17 normalization > 14 of 57 OK created view model _AIRBYTE_PUBLIC.STORE_INVENTORIES_STG.................................................... [SUCCESS 1 in 1.58s] 2022-11-08 12:00:17 normalization > 18 of 57 START view model _AIRBYTE_PUBLIC.USERS_STG..................................................................... [RUN] 2022-11-08 12:00:17 normalization > 17 of 57 START view model _AIRBYTE_PUBLIC.SUBCATEGORIES_MAPS_STG........................................................ [RUN] 2022-11-08 12:00:17 normalization > 15 of 57 OK created view model _AIRBYTE_PUBLIC.STORE_INVENTORIES_HISTORY_STG............................................ [SUCCESS 1 in 1.45s] 2022-11-08 12:00:17 normalization > 12 of 57 OK created view model _AIRBYTE_PUBLIC.PRODUCT_VARIANT_DETAILS_STG.............................................. [SUCCESS 1 in 1.77s] 2022-11-08 12:00:17 normalization > 19 of 57 START view model _AIRBYTE_PUBLIC.USER_SUBSCRIPTIONS_STG........................................................ [RUN] 2022-11-08 12:00:17 normalization > 20 of 57 START incremental model PUBLIC.CATEGORIES_SCD.................................................................. [RUN] 2022-11-08 12:00:18 normalization > 16 of 57 OK created view model _AIRBYTE_PUBLIC.SUBCATEGORIES_STG........................................................ [SUCCESS 1 in 0.95s] 2022-11-08 12:00:18 normalization > 21 of 57 START incremental model PUBLIC.CATEGORIES_MAPS_SCD............................................................. [RUN] 2022-11-08 12:00:18 normalization > 18 of 57 OK created view model _AIRBYTE_PUBLIC.USERS_STG................................................................ [SUCCESS 1 in 1.36s] 2022-11-08 12:00:18 normalization > 22 of 57 START incremental model PUBLIC.ADMINS_SCD...................................................................... [RUN] 2022-11-08 12:00:19 normalization > 17 of 57 OK created view model _AIRBYTE_PUBLIC.SUBCATEGORIES_MAPS_STG................................................... [SUCCESS 1 in 2.14s] 2022-11-08 12:00:19 normalization > 23 of 57 START incremental model PUBLIC.GRUNTERS_SCD.................................................................... [RUN] 2022-11-08 12:00:19 normalization > 19 of 57 OK created view model _AIRBYTE_PUBLIC.USER_SUBSCRIPTIONS_STG................................................... [SUCCESS 1 in 2.20s] 2022-11-08 12:00:19 normalization > 24 of 57 START incremental model PUBLIC.PRODUCERS_SCD................................................................... [RUN] 2022-11-08 12:00:23 normalization > 23 of 57 OK created incremental model PUBLIC.GRUNTERS_SCD............................................................... [SUCCESS 1 in 3.67s] 2022-11-08 12:00:23 normalization > 25 of 57 START incremental model PUBLIC.AR_INTERNAL_METADATA_SCD........................................................ [RUN] 2022-11-08 12:00:24 normalization > 21 of 57 OK created incremental model PUBLIC.CATEGORIES_MAPS_SCD........................................................ [SUCCESS 1 in 6.05s] 2022-11-08 12:00:24 normalization > 26 of 57 START incremental model PUBLIC.PRODUCTS_SCD.................................................................... [RUN] 2022-11-08 12:00:24 normalization > 20 of 57 OK created incremental model PUBLIC.CATEGORIES_SCD............................................................. [SUCCESS 1 in 7.02s] 2022-11-08 12:00:24 normalization > 27 of 57 START incremental model PUBLIC.LAMDBA_CALLS_SCD................................................................ [RUN] 2022-11-08 12:00:24 normalization > 22 of 57 OK created incremental model PUBLIC.ADMINS_SCD................................................................. [SUCCESS 1 in 5.87s] 2022-11-08 12:00:24 normalization > 28 of 57 START incremental model PUBLIC.PRODUCT_DETAILS_SCD............................................................. [RUN] 2022-11-08 12:00:25 normalization > 24 of 57 OK created incremental model PUBLIC.PRODUCERS_SCD.............................................................. [SUCCESS 1 in 6.00s] 2022-11-08 12:00:25 normalization > 29 of 57 START incremental model PUBLIC.PRODUCT_VARIANTS_SCD............................................................ [RUN] 2022-11-08 12:00:28 normalization > 27 of 57 OK created incremental model PUBLIC.LAMDBA_CALLS_SCD........................................................... [SUCCESS 1 in 3.44s] 2022-11-08 12:00:28 normalization > 30 of 57 START incremental model PUBLIC.SCHEMA_MIGRATIONS_SCD........................................................... [RUN] 2022-11-08 12:00:28 normalization > 28 of 57 OK created incremental model PUBLIC.PRODUCT_DETAILS_SCD........................................................ [SUCCESS 1 in 3.98s] 2022-11-08 12:00:28 normalization > 31 of 57 START incremental model PUBLIC.STORES_SCD...................................................................... [RUN] 2022-11-08 12:00:29 normalization > 25 of 57 OK created incremental model PUBLIC.AR_INTERNAL_METADATA_SCD................................................... [SUCCESS 1 in 5.95s] 2022-11-08 12:00:29 normalization > 32 of 57 START incremental model PUBLIC.STORE_INVENTORIES_SCD........................................................... [RUN] 2022-11-08 12:00:31 normalization > 26 of 57 OK created incremental model PUBLIC.PRODUCTS_SCD............................................................... [SUCCESS 1 in 7.62s] 2022-11-08 12:00:31 normalization > 33 of 57 START incremental model PUBLIC.STORE_INVENTORIES_HISTORY_SCD................................................... [RUN] 2022-11-08 12:00:32 normalization > 29 of 57 OK created incremental model PUBLIC.PRODUCT_VARIANTS_SCD....................................................... [SUCCESS 1 in 7.14s] 2022-11-08 12:00:32 normalization > 34 of 57 START incremental model PUBLIC.PRODUCT_VARIANT_DETAILS_SCD..................................................... [RUN] 2022-11-08 12:00:33 normalization > 30 of 57 OK created incremental model PUBLIC.SCHEMA_MIGRATIONS_SCD...................................................... [SUCCESS 1 in 5.34s] 2022-11-08 12:00:33 normalization > 35 of 57 START incremental model PUBLIC.SUBCATEGORIES_SCD............................................................... [RUN] 2022-11-08 12:00:34 normalization > 31 of 57 OK created incremental model PUBLIC.STORES_SCD................................................................. [SUCCESS 1 in 5.79s] 2022-11-08 12:00:34 normalization > 36 of 57 START incremental model PUBLIC.USERS_SCD....................................................................... [RUN] 2022-11-08 12:01:02 normalization > 35 of 57 OK created incremental model PUBLIC.SUBCATEGORIES_SCD.......................................................... [SUCCESS 1 in 28.86s] 2022-11-08 12:01:02 normalization > 37 of 57 START incremental model PUBLIC.SUBCATEGORIES_MAPS_SCD.......................................................... [RUN] 2022-11-08 12:01:02 normalization > 36 of 57 OK created incremental model PUBLIC.USERS_SCD.................................................................. [SUCCESS 1 in 27.88s] 2022-11-08 12:01:02 normalization > 38 of 57 START incremental model PUBLIC.USER_SUBSCRIPTIONS_SCD.......................................................... [RUN] 2022-11-08 12:01:26 normalization > 37 of 57 OK created incremental model PUBLIC.SUBCATEGORIES_MAPS_SCD..................................................... [SUCCESS 1 in 24.61s] 2022-11-08 12:01:26 normalization > 39 of 57 START incremental model PUBLIC.GRUNTERS........................................................................ [RUN] 2022-11-08 12:01:28 normalization > 38 of 57 OK created incremental model PUBLIC.USER_SUBSCRIPTIONS_SCD..................................................... [SUCCESS 1 in 26.10s] 2022-11-08 12:01:28 normalization > 40 of 57 START incremental model PUBLIC.CATEGORIES_MAPS................................................................. [RUN] 2022-11-08 12:01:29 normalization > 39 of 57 OK created incremental model PUBLIC.GRUNTERS................................................................... [SUCCESS 1 in 2.65s] 2022-11-08 12:01:29 normalization > 41 of 57 START incremental model PUBLIC.CATEGORIES...................................................................... [RUN] 2022-11-08 12:01:31 normalization > 40 of 57 OK created incremental model PUBLIC.CATEGORIES_MAPS............................................................ [SUCCESS 1 in 2.96s] 2022-11-08 12:01:31 normalization > 42 of 57 START incremental model PUBLIC.ADMINS.......................................................................... [RUN] 2022-11-08 12:01:32 normalization > 41 of 57 OK created incremental model PUBLIC.CATEGORIES................................................................. [SUCCESS 1 in 3.34s] 2022-11-08 12:01:32 normalization > 43 of 57 START incremental model PUBLIC.PRODUCERS....................................................................... [RUN] 2022-11-08 12:01:34 normalization > 32 of 57 OK created incremental model PUBLIC.STORE_INVENTORIES_SCD...................................................... [SUCCESS 1 in 65.34s] 2022-11-08 12:01:34 normalization > 44 of 57 START incremental model PUBLIC.LAMDBA_CALLS.................................................................... [RUN] 2022-11-08 12:01:34 normalization > 42 of 57 OK created incremental model PUBLIC.ADMINS..................................................................... [SUCCESS 1 in 3.37s] 2022-11-08 12:01:34 normalization > 45 of 57 START incremental model PUBLIC.PRODUCT_DETAILS................................................................. [RUN] 2022-11-08 12:01:35 normalization > 34 of 57 OK created incremental model PUBLIC.PRODUCT_VARIANT_DETAILS_SCD................................................ [SUCCESS 1 in 62.38s] 2022-11-08 12:01:35 normalization > 46 of 57 START incremental model PUBLIC.AR_INTERNAL_METADATA............................................................ [RUN] 2022-11-08 12:01:36 normalization > 43 of 57 OK created incremental model PUBLIC.PRODUCERS.................................................................. [SUCCESS 1 in 3.69s] 2022-11-08 12:01:36 normalization > 47 of 57 START incremental model PUBLIC.PRODUCTS........................................................................ [RUN] 2022-11-08 12:01:36 normalization > 44 of 57 OK created incremental model PUBLIC.LAMDBA_CALLS............................................................... [SUCCESS 1 in 2.30s] 2022-11-08 12:01:36 normalization > 48 of 57 START incremental model PUBLIC.PRODUCT_VARIANTS................................................................ [RUN] 2022-11-08 12:01:37 normalization > 45 of 57 OK created incremental model PUBLIC.PRODUCT_DETAILS............................................................ [SUCCESS 1 in 2.26s] 2022-11-08 12:01:37 normalization > 49 of 57 START incremental model PUBLIC.SCHEMA_MIGRATIONS............................................................... [RUN] 2022-11-08 12:01:38 normalization > 46 of 57 OK created incremental model PUBLIC.AR_INTERNAL_METADATA....................................................... [SUCCESS 1 in 2.95s] 2022-11-08 12:01:38 normalization > 50 of 57 START incremental model PUBLIC.STORES.......................................................................... [RUN] 2022-11-08 12:01:40 normalization > 49 of 57 OK created incremental model PUBLIC.SCHEMA_MIGRATIONS.......................................................... [SUCCESS 1 in 3.14s] 2022-11-08 12:01:40 normalization > 51 of 57 START incremental model PUBLIC.SUBCATEGORIES................................................................... [RUN] 2022-11-08 12:01:40 normalization > 47 of 57 OK created incremental model PUBLIC.PRODUCTS................................................................... [SUCCESS 1 in 4.41s] 2022-11-08 12:01:40 normalization > 52 of 57 START incremental model PUBLIC.USERS........................................................................... [RUN] 2022-11-08 12:01:41 normalization > 50 of 57 OK created incremental model PUBLIC.STORES..................................................................... [SUCCESS 1 in 2.89s] 2022-11-08 12:01:41 normalization > 53 of 57 START incremental model PUBLIC.SUBCATEGORIES_MAPS.............................................................. [RUN] 2022-11-08 12:01:41 normalization > 48 of 57 OK created incremental model PUBLIC.PRODUCT_VARIANTS........................................................... [SUCCESS 1 in 4.42s] 2022-11-08 12:01:41 normalization > 54 of 57 START incremental model PUBLIC.USER_SUBSCRIPTIONS.............................................................. [RUN] 2022-11-08 12:01:43 normalization > 51 of 57 OK created incremental model PUBLIC.SUBCATEGORIES.............................................................. [SUCCESS 1 in 3.45s] 2022-11-08 12:01:43 normalization > 55 of 57 START incremental model PUBLIC.STORE_INVENTORIES............................................................... [RUN] 2022-11-08 12:01:43 normalization > 54 of 57 OK created incremental model PUBLIC.USER_SUBSCRIPTIONS......................................................... [SUCCESS 1 in 2.58s] 2022-11-08 12:01:43 normalization > 56 of 57 START incremental model PUBLIC.PRODUCT_VARIANT_DETAILS......................................................... [RUN] 2022-11-08 12:01:44 normalization > 52 of 57 OK created incremental model PUBLIC.USERS...................................................................... [SUCCESS 1 in 3.48s] 2022-11-08 12:01:44 normalization > 53 of 57 OK created incremental model PUBLIC.SUBCATEGORIES_MAPS......................................................... [SUCCESS 1 in 3.43s] 2022-11-08 12:01:59 normalization > 56 of 57 OK created incremental model PUBLIC.PRODUCT_VARIANT_DETAILS.................................................... [SUCCESS 1 in 15.96s] 2022-11-08 12:02:18 normalization > 55 of 57 OK created incremental model PUBLIC.STORE_INVENTORIES.......................................................... [SUCCESS 1 in 34.90s] 2022-11-08 16:44:45 normalization > 33 of 57 OK created incremental model PUBLIC.STORE_INVENTORIES_HISTORY_SCD.............................................. [SUCCESS 1 in 17053.78s] 2022-11-08 16:44:45 normalization > 57 of 57 START incremental model PUBLIC.STORE_INVENTORIES_HISTORY....................................................... [RUN] 2022-11-08 18:18:21 normalization > 57 of 57 OK created incremental model PUBLIC.STORE_INVENTORIES_HISTORY.................................................. [SUCCESS 1 in 5615.60s] 2022-11-08 18:18:21 normalization > Finished running 19 view models, 38 incremental models in 22692.29s. 2022-11-08 18:18:21 normalization > Completed successfully 2022-11-08 18:18:21 normalization > Done. PASS=57 WARN=0 ERROR=0 SKIP=0 TOTAL=57 2022-11-08 18:18:21 INFO i.a.w.g.DefaultNormalizationWorker(run):93 - Normalization executed in 6 hours 18 minutes 21 seconds. 2022-11-08 18:18:21 INFO i.a.w.g.DefaultNormalizationWorker(run):106 - Normalization summary: io.airbyte.config.NormalizationSummary@493c3963[startTime=1667908800030,endTime=1667931501736,failures=[]] 2022-11-08 18:18:21 INFO i.a.w.t.TemporalAttemptExecution(get):162 - Stopping cancellation check scheduling... 2022-11-08 18:18:21 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2022-11-08 18:18:21 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-11-08 18:18:21 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION ----- 2022-11-08 18:18:21 INFO i.a.c.i.LineGobbler(voidCall):114 -