2022-12-14 12:53:40 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/12/0/logs.log 2022-12-14 12:53:40 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.25 2022-12-14 12:53:40 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation 2022-12-14 12:53:40 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):56 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-12-14 12:53:40 INFO i.a.c.EnvConfigs(getEnvOrDefault):1140 - Using default value for environment variable METRIC_CLIENT: '' 2022-12-14 12:53:40 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 2022-12-14 12:53:40 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):56 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false' 2022-12-14 12:53:40 INFO i.a.w.g.DefaultReplicationWorker(run):135 - start sync worker. job id: 12 attempt id: 0 2022-12-14 12:53:40 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-12-14 12:53:40 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION ----- 2022-12-14 12:53:40 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-12-14 12:53:40 INFO i.a.w.g.DefaultReplicationWorker(run):150 - configured sync modes: {null.ad_group_ads=incremental - append_dedup, null.accounts=incremental - append_dedup, null.click_view=incremental - append_dedup, null.ad_groups=incremental - append_dedup, null.ad_group_labels=full_refresh - overwrite, null.ad_group_ad_labels=full_refresh - overwrite, null.campaign_labels=full_refresh - overwrite} 2022-12-14 12:53:40 INFO i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination... 2022-12-14 12:53:40 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-bigquery:1.2.8 exists... 2022-12-14 12:53:40 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-bigquery:1.2.8 was found locally. 2022-12-14 12:53:40 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-bigquery-write-12-0-uclvu with resources io.airbyte.config.ResourceRequirements@51cfb0a9[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-12-14 12:53:40 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/12/0 --log-driver none --name destination-bigquery-write-12-0-uclvu --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-bigquery:1.2.8 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.25 -e WORKER_JOB_ID=12 airbyte/destination-bigquery:1.2.8 write --config destination_config.json --catalog destination_catalog.json 2022-12-14 12:53:40 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0 2022-12-14 12:53:40 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0 2022-12-14 12:53:40 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-google-ads:0.2.5 exists... 2022-12-14 12:53:40 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-google-ads:0.2.5 was found locally. 2022-12-14 12:53:40 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-google-ads-read-12-0-dmgny with resources io.airbyte.config.ResourceRequirements@7b4ae74e[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-12-14 12:53:40 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/12/0 --log-driver none --name source-google-ads-read-12-0-dmgny --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-google-ads:0.2.5 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.25 -e WORKER_JOB_ID=12 airbyte/source-google-ads:0.2.5 read --config source_config.json --catalog source_catalog.json --state input_state.json 2022-12-14 12:53:40 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0 2022-12-14 12:53:40 INFO i.a.w.g.DefaultReplicationWorker(replicate):217 - Waiting for source and destination threads to complete. 2022-12-14 12:53:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):243 - Destination output thread started. 2022-12-14 12:53:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):291 - Replication thread started. 2022-12-14 12:53:41 destination > integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-12-14 12:53:41 destination > Running integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-12-14 12:53:41 destination > Command: WRITE 2022-12-14 12:53:41 destination > Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-12-14 12:53:41 source > Starting syncing SourceGoogleAds 2022-12-14 12:53:42 destination > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-12-14 12:53:42 destination > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-12-14 12:53:42 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:42 destination > The "standard" upload mode is not performant, and is not recommended for production. Please use the GCS upload mode if you are syncing a large amount of data. 2022-12-14 12:53:42 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:43 source > Syncing stream: ad_group_ads 2022-12-14 12:53:44 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_tds_ad_group_ads}} 2022-12-14 12:53:44 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:45 source > Read 0 records from ad_group_ads stream 2022-12-14 12:53:45 source > Finished syncing ad_group_ads 2022-12-14 12:53:45 source > SourceGoogleAds runtimes: Syncing stream ad_group_ads 0:00:02.444318 2022-12-14 12:53:45 source > Syncing stream: ad_group_ad_labels 2022-12-14 12:53:45 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:46 source > Read 0 records from ad_group_ad_labels stream 2022-12-14 12:53:46 source > Finished syncing ad_group_ad_labels 2022-12-14 12:53:46 source > SourceGoogleAds runtimes: Syncing stream ad_group_ad_labels 0:00:00.521050 Syncing stream ad_group_ads 0:00:02.444318 2022-12-14 12:53:46 source > Syncing stream: ad_groups 2022-12-14 12:53:46 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_yyl_ad_group_ad_labels}} 2022-12-14 12:53:46 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:47 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:48 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_yzq_ad_groups}} 2022-12-14 12:53:48 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:49 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:50 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_hak_ad_group_labels}} 2022-12-14 12:53:50 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:51 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:52 source > Read 0 records from ad_groups stream 2022-12-14 12:53:52 source > Finished syncing ad_groups 2022-12-14 12:53:52 source > SourceGoogleAds runtimes: Syncing stream ad_group_ad_labels 0:00:00.521050 Syncing stream ad_group_ads 0:00:02.444318 Syncing stream ad_groups 0:00:05.921956 2022-12-14 12:53:52 source > Syncing stream: ad_group_labels 2022-12-14 12:53:52 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_ljz_accounts}} 2022-12-14 12:53:52 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:52 source > Read 0 records from ad_group_labels stream 2022-12-14 12:53:52 source > Finished syncing ad_group_labels 2022-12-14 12:53:52 source > SourceGoogleAds runtimes: Syncing stream ad_group_ad_labels 0:00:00.521050 Syncing stream ad_group_ads 0:00:02.444318 Syncing stream ad_group_labels 0:00:00.518017 Syncing stream ad_groups 0:00:05.921956 2022-12-14 12:53:52 source > Syncing stream: accounts 2022-12-14 12:53:53 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:53 source > Read 0 records from accounts stream 2022-12-14 12:53:53 source > Finished syncing accounts 2022-12-14 12:53:53 source > SourceGoogleAds runtimes: Syncing stream accounts 0:00:01.073861 Syncing stream ad_group_ad_labels 0:00:00.521050 Syncing stream ad_group_ads 0:00:02.444318 Syncing stream ad_group_labels 0:00:00.518017 Syncing stream ad_groups 0:00:05.921956 2022-12-14 12:53:53 source > Syncing stream: campaign_labels 2022-12-14 12:53:54 source > Read 0 records from campaign_labels stream 2022-12-14 12:53:54 source > Finished syncing campaign_labels 2022-12-14 12:53:54 source > SourceGoogleAds runtimes: Syncing stream accounts 0:00:01.073861 Syncing stream ad_group_ad_labels 0:00:00.521050 Syncing stream ad_group_ads 0:00:02.444318 Syncing stream ad_group_labels 0:00:00.518017 Syncing stream ad_groups 0:00:05.921956 Syncing stream campaign_labels 0:00:00.543508 2022-12-14 12:53:54 source > Syncing stream: click_view 2022-12-14 12:53:54 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_zsv_campaign_labels}} 2022-12-14 12:53:54 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:55 destination > Selected loading method is set to: STANDARD 2022-12-14 12:53:56 destination > Partitioned table created successfully: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_qbx_click_view}} 2022-12-14 12:53:56 destination > Selected loading method is set to: STANDARD 2022-12-14 12:54:12 source > Read 0 records from click_view stream 2022-12-14 12:54:12 source > Finished syncing click_view 2022-12-14 12:54:12 source > SourceGoogleAds runtimes: Syncing stream accounts 0:00:01.073861 Syncing stream ad_group_ad_labels 0:00:00.521050 Syncing stream ad_group_ads 0:00:02.444318 Syncing stream ad_group_labels 0:00:00.518017 Syncing stream ad_groups 0:00:05.921956 Syncing stream campaign_labels 0:00:00.543508 Syncing stream click_view 0:00:18.195013 2022-12-14 12:54:12 source > Finished syncing SourceGoogleAds 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):324 - Source has no more messages, closing connection. 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):333 - Total records read: 34 (0 bytes) 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(replicate):222 - One of source or destination thread complete. Waiting on the other. 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@4a345a54[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@1dbbcfb8[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2d581c15[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@79f1ed71[name=ad_group_ads,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@117feee1[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@52fa3579[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@3f2f2387[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@49c3cb76[name=ad_group_ads,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):221 - The message tracker encountered an issue that prevents committed record counts from being reliably computed. 2022-12-14 12:54:12 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):222 - This only impacts metadata and does not indicate a problem with actual sync data. 2022-12-14 12:54:12 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):223 - State hash -1979175224 was already committed, likely indicating a state hash collision io.airbyte.workers.internal.book_keeping.StateDeltaTracker$StateDeltaTrackerException: State hash -1979175224 was already committed, likely indicating a state hash collision at io.airbyte.workers.internal.book_keeping.StateDeltaTracker.commitStateHash(StateDeltaTracker.java:119) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.handleDestinationEmittedState(AirbyteMessageTracker.java:218) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.acceptFromDestination(AirbyteMessageTracker.java:141) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:254) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@27a53c49[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@24f78439[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@6202b83b[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@354d5776[name=ad_groups,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@3b8472e2[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@234aefe7[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@54fe48d5[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@bd753db[name=ad_groups,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@13dc3321[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@679dc36a[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@418387ac[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@70fb4dcc[name=accounts,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@2cc3dc9[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@b432869[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@56a0704a[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@7c9fc27f[name=accounts,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@1fde8a50[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@dccf9a2[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@58bbea71[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@5a354723[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@31d2da3f[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@5b39244e[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@5cd6a53a[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2caafddc[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@b8ed954[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@1907973f[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@70110e50[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@b2e5993[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@761765db[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@530cba49[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2b974df6[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@520c6bd6[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@1ff8e5f1[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@2990dab5[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@38f9da8c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@99a449e[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@5115ef31[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@7effc2d4[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@8a45a3d[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@53415103[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@2d53503d[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@2d3ade21[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@7650c09[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@5ef59caf[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@6990edf4[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@1220fd31[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@3d8abe38[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@4fe85dc2[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@f261ad3[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@5898bba7[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@599ab21b[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2c6bfad5[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@13a48d09[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@efc4959[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2fa28f7[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@7134c72f[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@46cfc0c5[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@2a95ffc4[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@79fbc7f1[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2e217a5e[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@16d04eb7[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@13bee876[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@34dd71bf[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@118b0ef0[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@3e2c3f0b[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@77194ab0[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@20085d9c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@5e858826[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@10e309a[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@3c7fb6c1[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@5e79e86f[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2ccf8f3e[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@5c35f0dd[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@1d3d9c24[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@c16357c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@5c70fdbf[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@2fb04df4[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@5e9d389a[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@639d5be0[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@385bdf29[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@15a9fa3b[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@224759fc[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2b0c440f[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@4dc874d0[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@176a2770[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@ffa04d8[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@469f0514[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@48ff87e3[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@e68682b[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@51eb71fa[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@6f626976[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@5b963be6[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@16f2298f[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@1c9cee0a[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@60c91d36[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@a6a53c2[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@d53ad51[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@7644fe4f[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@5e4c6d1c[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@660c154[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@16c9ddec[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@47aefffc[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@7a375e98[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@7a5d4aeb[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@22a3cef1[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@12c28446[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@5241db18[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@425bc9a9[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@7eb35355[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@78550871[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@24908578[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@381a16c2[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@5cd7d36f[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@c114e04[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2c0aa1bb[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@44ce0efe[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@2660e1a3[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@2007fa05[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@597990c7[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@6df4cce8[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@4c38450c[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@5370495c[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@469a045d[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@d4203ea[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@3dc276b[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@52b7b4e5[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@4419ea02[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@59d9ec38[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:12 destination > Airbyte message consumer: succeeded. 2022-12-14 12:54:12 destination > Started closing all connections 2022-12-14 12:54:12 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_campaign_labels, tmpTable=_airbyte_tmp_zsv_campaign_labels, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:12 destination > Uploading data from the tmp table _airbyte_tmp_zsv_campaign_labels to the source table _airbyte_raw_campaign_labels. 2022-12-14 12:54:12 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-12-14 12:54:14 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_zsv_campaign_labels}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_raw_campaign_labels}} 2022-12-14 12:54:14 destination > Data is successfully loaded to the source table _airbyte_raw_campaign_labels! 2022-12-14 12:54:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@3bdc6f17[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@5423e415[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@5fe14d69[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@494fd281[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:14 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):232 - The state message tracker was unable to match the destination state message to a corresponding source state message. 2022-12-14 12:54:14 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):233 - This only impacts metrics and does not indicate a problem with actual sync data. 2022-12-14 12:54:14 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):234 - Destination state message cannot be matched to corresponding Source state message. io.airbyte.workers.internal.book_keeping.StateMetricsTracker$StateMetricsTrackerNoStateMatchException: Destination state message cannot be matched to corresponding Source state message. at io.airbyte.workers.internal.book_keeping.StateMetricsTracker.findStartingTimeStampAndRemoveOlderEntries(StateMetricsTracker.java:147) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at io.airbyte.workers.internal.book_keeping.StateMetricsTracker.updateStates(StateMetricsTracker.java:80) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.handleDestinationEmittedState(AirbyteMessageTracker.java:229) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.acceptFromDestination(AirbyteMessageTracker.java:141) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:254) ~[io.airbyte-airbyte-commons-worker-0.40.25.jar:?] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?] at java.lang.Thread.run(Thread.java:1589) ~[?:?] 2022-12-14 12:54:14 destination > Final state message is accepted. 2022-12-14 12:54:14 destination > Removing tmp tables... 2022-12-14 12:54:14 destination > Finishing destination process...completed 2022-12-14 12:54:14 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_campaign_labels, tmpTable=_airbyte_tmp_zsv_campaign_labels, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:14 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_group_ad_labels, tmpTable=_airbyte_tmp_yyl_ad_group_ad_labels, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:14 destination > Uploading data from the tmp table _airbyte_tmp_yyl_ad_group_ad_labels to the source table _airbyte_raw_ad_group_ad_labels. 2022-12-14 12:54:14 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-12-14 12:54:15 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_yyl_ad_group_ad_labels}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_raw_ad_group_ad_labels}} 2022-12-14 12:54:15 destination > Data is successfully loaded to the source table _airbyte_raw_ad_group_ad_labels! 2022-12-14 12:54:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@1133a868[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@5afbf517[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@f247124[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@38c8719b[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:15 destination > Final state message is accepted. 2022-12-14 12:54:15 destination > Removing tmp tables... 2022-12-14 12:54:15 destination > Finishing destination process...completed 2022-12-14 12:54:15 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_group_ad_labels, tmpTable=_airbyte_tmp_yyl_ad_group_ad_labels, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:15 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_group_labels, tmpTable=_airbyte_tmp_hak_ad_group_labels, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:15 destination > Uploading data from the tmp table _airbyte_tmp_hak_ad_group_labels to the source table _airbyte_raw_ad_group_labels. 2022-12-14 12:54:15 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-12-14 12:54:16 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_hak_ad_group_labels}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_raw_ad_group_labels}} 2022-12-14 12:54:16 destination > Data is successfully loaded to the source table _airbyte_raw_ad_group_labels! 2022-12-14 12:54:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@34b4ee02[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@3162f6ce[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@1de31c97[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@66dce219[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:16 destination > Final state message is accepted. 2022-12-14 12:54:16 destination > Removing tmp tables... 2022-12-14 12:54:16 destination > Finishing destination process...completed 2022-12-14 12:54:16 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_group_labels, tmpTable=_airbyte_tmp_hak_ad_group_labels, syncMode=WRITE_TRUNCATE, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:16 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_accounts, tmpTable=_airbyte_tmp_ljz_accounts, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:16 destination > Uploading data from the tmp table _airbyte_tmp_ljz_accounts to the source table _airbyte_raw_accounts. 2022-12-14 12:54:16 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-12-14 12:54:20 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_ljz_accounts}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_raw_accounts}} 2022-12-14 12:54:20 destination > Data is successfully loaded to the source table _airbyte_raw_accounts! 2022-12-14 12:54:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@758bc43e[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@53f998c7[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@567b218b[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@57b6cd77[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:20 destination > Final state message is accepted. 2022-12-14 12:54:20 destination > Removing tmp tables... 2022-12-14 12:54:20 destination > Finishing destination process...completed 2022-12-14 12:54:20 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_accounts, tmpTable=_airbyte_tmp_ljz_accounts, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:20 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_groups, tmpTable=_airbyte_tmp_yzq_ad_groups, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:20 destination > Uploading data from the tmp table _airbyte_tmp_yzq_ad_groups to the source table _airbyte_raw_ad_groups. 2022-12-14 12:54:20 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-12-14 12:54:23 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_yzq_ad_groups}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_raw_ad_groups}} 2022-12-14 12:54:23 destination > Data is successfully loaded to the source table _airbyte_raw_ad_groups! 2022-12-14 12:54:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@7c37598b[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@6317c96a[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@6cefcbfa[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@dd37e65[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:23 destination > Final state message is accepted. 2022-12-14 12:54:23 destination > Removing tmp tables... 2022-12-14 12:54:24 destination > Finishing destination process...completed 2022-12-14 12:54:24 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_groups, tmpTable=_airbyte_tmp_yzq_ad_groups, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:24 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_click_view, tmpTable=_airbyte_tmp_qbx_click_view, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:24 destination > Uploading data from the tmp table _airbyte_tmp_qbx_click_view to the source table _airbyte_raw_click_view. 2022-12-14 12:54:24 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-12-14 12:54:26 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_qbx_click_view}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_raw_click_view}} 2022-12-14 12:54:26 destination > Data is successfully loaded to the source table _airbyte_raw_click_view! 2022-12-14 12:54:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@4bee8555[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@166f59db[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@44df0f7[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@12fb964d[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:26 destination > Final state message is accepted. 2022-12-14 12:54:26 destination > Removing tmp tables... 2022-12-14 12:54:26 destination > Finishing destination process...completed 2022-12-14 12:54:26 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_click_view, tmpTable=_airbyte_tmp_qbx_click_view, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:26 destination > Closing connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_group_ads, tmpTable=_airbyte_tmp_tds_ad_group_ads, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:26 destination > Uploading data from the tmp table _airbyte_tmp_tds_ad_group_ads to the source table _airbyte_raw_ad_group_ads. 2022-12-14 12:54:26 destination > Replication finished with no explicit errors. Copying data from tmp tables to permanent 2022-12-14 12:54:28 destination > successfully copied table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_tmp_tds_ad_group_ads}} to table: GenericData{classInfo=[datasetId, projectId, tableId], {datasetId=datacat, tableId=_airbyte_raw_ad_group_ads}} 2022-12-14 12:54:28 destination > Data is successfully loaded to the source table _airbyte_raw_ad_group_ads! 2022-12-14 12:54:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):253 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@2d807d6a[type=STATE,log=,spec=,connectionStatus=,catalog=,record=,state=io.airbyte.protocol.models.AirbyteStateMessage@414d4880[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2a6cd216[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@64eb60e8[name=click_view,namespace=,additionalProperties={}],streamState={},additionalProperties={}],global=,data={"ad_groups":{},"accounts":{},"ad_group_ads":{},"click_view":{}},additionalProperties={}],trace=,control=,additionalProperties={}] 2022-12-14 12:54:28 destination > Final state message is accepted. 2022-12-14 12:54:28 destination > Removing tmp tables... 2022-12-14 12:54:28 destination > Finishing destination process...completed 2022-12-14 12:54:28 destination > Closed connector: AbstractBigQueryUploader{table=_airbyte_raw_ad_group_ads, tmpTable=_airbyte_tmp_tds_ad_group_ads, syncMode=WRITE_APPEND, writer=class io.airbyte.integrations.destination.bigquery.writer.BigQueryTableWriter, recordFormatter=class io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryRecordFormatter} 2022-12-14 12:54:28 destination > Completed integration: io.airbyte.integrations.destination.bigquery.BigQueryDestination 2022-12-14 12:54:28 INFO i.a.w.g.DefaultReplicationWorker(replicate):224 - Source and destination threads complete. 2022-12-14 12:54:28 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):475 - Source output at least one state message 2022-12-14 12:54:28 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):481 - State capture: Updated state to: Optional[io.airbyte.config.State@37de64e0[state=[{"type":"STREAM","stream":{"stream_descriptor":{"name":"ad_groups"},"stream_state":{}}},{"type":"STREAM","stream":{"stream_descriptor":{"name":"accounts"},"stream_state":{}}},{"type":"STREAM","stream":{"stream_descriptor":{"name":"ad_group_ads"},"stream_state":{}}},{"type":"STREAM","stream":{"stream_descriptor":{"name":"click_view"},"stream_state":{}}}]]] 2022-12-14 12:54:28 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):408 - sync summary: { "status" : "completed", "recordsSynced" : 0, "bytesSynced" : 0, "startTime" : 1671022420788, "endTime" : 1671022468847, "totalStats" : { "recordsEmitted" : 0, "bytesEmitted" : 0, "sourceStateMessagesEmitted" : 34, "destinationStateMessagesEmitted" : 41, "recordsCommitted" : 0, "meanSecondsBeforeSourceStateMessageEmitted" : 0, "maxSecondsBeforeSourceStateMessageEmitted" : 18, "replicationStartTime" : 1671022420788, "replicationEndTime" : 1671022468847, "sourceReadStartTime" : 1671022420860, "sourceReadEndTime" : 1671022452656, "destinationWriteStartTime" : 1671022420950, "destinationWriteEndTime" : 1671022468847 }, "streamStats" : [ ] } 2022-12-14 12:54:28 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):409 - failures: [ ] 2022-12-14 12:54:28 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling... 2022-12-14 12:54:28 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-12-14 12:54:28 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION ----- 2022-12-14 12:54:28 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-12-14 12:54:28 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):205 - sync summary: io.airbyte.config.StandardSyncOutput@5d0c5450[standardSyncSummary=io.airbyte.config.StandardSyncSummary@4ac4d87[status=completed,recordsSynced=0,bytesSynced=0,startTime=1671022420788,endTime=1671022468847,totalStats=io.airbyte.config.SyncStats@41e08d3f[recordsEmitted=0,bytesEmitted=0,sourceStateMessagesEmitted=34,destinationStateMessagesEmitted=41,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=18,maxSecondsBetweenStateMessageEmittedandCommitted=,meanSecondsBetweenStateMessageEmittedandCommitted=,replicationStartTime=1671022420788,replicationEndTime=1671022468847,sourceReadStartTime=1671022420860,sourceReadEndTime=1671022452656,destinationWriteStartTime=1671022420950,destinationWriteEndTime=1671022468847,additionalProperties={}],streamStats=[]],normalizationSummary=,webhookOperationSummary=,state=io.airbyte.config.State@37de64e0[state=[{"type":"STREAM","stream":{"stream_descriptor":{"name":"ad_groups"},"stream_state":{}}},{"type":"STREAM","stream":{"stream_descriptor":{"name":"accounts"},"stream_state":{}}},{"type":"STREAM","stream":{"stream_descriptor":{"name":"ad_group_ads"},"stream_state":{}}},{"type":"STREAM","stream":{"stream_descriptor":{"name":"click_view"},"stream_state":{}}}]],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@15197d78[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2a08055f[stream=io.airbyte.protocol.models.AirbyteStream@4c2ea5ec[name=ad_group_ads,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"segments.date":{"type":["null","string"],"format":"date"},"ad_group_ad.ad.id":{"type":["null","integer"]},"ad_group_ad.labels":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.status":{"type":["null","string"]},"ad_group_ad.ad.name":{"type":["null","string"]},"ad_group_ad.ad.type":{"type":["null","string"]},"ad_group_ad.ad_group":{"type":["null","string"]},"ad_group_ad.ad.hotel_ad":{"type":["null","string"]},"ad_group_ad.ad_strength":{"type":["null","string"]},"ad_group_ad.ad.final_urls":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.resource_name":{"type":["null","string"]},"ad_group_ad.ad.display_url":{"type":["null","string"]},"ad_group_ad.ad.app_ad.images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.call_ad.path1":{"type":["null","string"]},"ad_group_ad.ad.call_ad.path2":{"type":["null","string"]},"ad_group_ad.ad.image_ad.name":{"type":["null","string"]},"ad_group_ad.ad.resource_name":{"type":["null","string"]},"ad_group_ad.ad.final_app_urls":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.local_ad.path1":{"type":["null","string"]},"ad_group_ad.ad.local_ad.path2":{"type":["null","string"]},"ad_group_ad.ad.local_ad.videos":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.url_collections":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.app_ad.headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.final_url_suffix":{"type":["null","string"]},"ad_group_ad.ad.text_ad.headline":{"type":["null","string"]},"ad_group_ad.ad.call_ad.headline1":{"type":["null","string"]},"ad_group_ad.ad.call_ad.headline2":{"type":["null","string"]},"ad_group_ad.ad.device_preference":{"type":["null","string"]},"ad_group_ad.ad.final_mobile_urls":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.shopping_smart_ad":{"type":["null","string"]},"ad_group_ad.ad.image_ad.image_url":{"type":["null","string"]},"ad_group_ad.ad.image_ad.mime_type":{"type":["null","string"]},"ad_group_ad.ad.local_ad.headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.added_by_google_ads":{"type":["null","boolean"]},"ad_group_ad.ad.app_ad.descriptions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.shopping_product_ad":{"type":["null","string"]},"ad_group_ad.ad.call_ad.call_tracked":{"type":["null","boolean"]},"ad_group_ad.ad.call_ad.country_code":{"type":["null","string"]},"ad_group_ad.ad.call_ad.description1":{"type":["null","string"]},"ad_group_ad.ad.call_ad.description2":{"type":["null","string"]},"ad_group_ad.ad.call_ad.phone_number":{"type":["null","string"]},"ad_group_ad.ad.image_ad.pixel_width":{"type":["null","integer"]},"ad_group_ad.ad.local_ad.logo_images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.text_ad.description1":{"type":["null","string"]},"ad_group_ad.ad.text_ad.description2":{"type":["null","string"]},"ad_group_ad.ad.app_ad.youtube_videos":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.call_ad.business_name":{"type":["null","string"]},"ad_group_ad.ad.gmail_ad.header_image":{"type":["null","string"]},"ad_group_ad.ad.image_ad.pixel_height":{"type":["null","integer"]},"ad_group_ad.ad.legacy_app_install_ad":{"type":["null","string"]},"ad_group_ad.ad.local_ad.descriptions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.tracking_url_template":{"type":["null","string"]},"ad_group_ad.ad.url_custom_parameters":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.expanded_text_ad.path1":{"type":["null","string"]},"ad_group_ad.ad.expanded_text_ad.path2":{"type":["null","string"]},"ad_group_ad.ad.gmail_ad.product_images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.gmail_ad.product_videos":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.app_ad.mandatory_ad_text":{"type":["null","string"]},"ad_group_ad.ad.app_engagement_ad.images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.app_engagement_ad.videos":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.gmail_ad.marketing_image":{"type":["null","string"]},"ad_group_ad.ad.gmail_ad.teaser.headline":{"type":["null","string"]},"ad_group_ad.ad.local_ad.call_to_actions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.call_ad.conversion_action":{"type":["null","string"]},"ad_group_ad.ad.local_ad.marketing_images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.video_ad.in_feed.headline":{"type":["null","string"]},"ad_group_ad.policy_summary.review_status":{"type":["null","string"]},"ad_group_ad.ad.app_ad.html5_media_bundles":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.gmail_ad.teaser.logo_image":{"type":["null","string"]},"ad_group_ad.ad.image_ad.preview_image_url":{"type":["null","string"]},"ad_group_ad.ad.responsive_search_ad.path1":{"type":["null","string"]},"ad_group_ad.ad.responsive_search_ad.path2":{"type":["null","string"]},"ad_group_ad.ad.video_responsive_ad.videos":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.app_engagement_ad.headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.gmail_ad.teaser.description":{"type":["null","string"]},"ad_group_ad.ad.smart_campaign_ad.headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.policy_summary.approval_status":{"type":["null","string"]},"ad_group_ad.ad.expanded_text_ad.description":{"type":["null","string"]},"ad_group_ad.ad.image_ad.preview_pixel_width":{"type":["null","integer"]},"ad_group_ad.ad.video_ad.out_stream.headline":{"type":["null","string"]},"ad_group_ad.ad.expanded_text_ad.description2":{"type":["null","string"]},"ad_group_ad.ad.gmail_ad.teaser.business_name":{"type":["null","string"]},"ad_group_ad.ad.image_ad.preview_pixel_height":{"type":["null","integer"]},"ad_group_ad.ad.video_ad.in_feed.description1":{"type":["null","string"]},"ad_group_ad.ad.video_ad.in_feed.description2":{"type":["null","string"]},"ad_group_ad.ad.video_responsive_ad.headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.app_engagement_ad.descriptions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.display_upload_ad.media_bundle":{"type":["null","string"]},"ad_group_ad.ad.responsive_search_ad.headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.smart_campaign_ad.descriptions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.system_managed_resource_source":{"type":["null","string"]},"ad_group_ad.ad.call_ad.disable_call_conversion":{"type":["null","boolean"]},"ad_group_ad.ad.expanded_text_ad.headline_part1":{"type":["null","string"]},"ad_group_ad.ad.expanded_text_ad.headline_part2":{"type":["null","string"]},"ad_group_ad.ad.expanded_text_ad.headline_part3":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.video_ad.out_stream.description":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.main_color":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.promo_text":{"type":["null","string"]},"ad_group_ad.ad.video_responsive_ad.descriptions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.policy_summary.policy_topic_entries":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.gmail_ad.marketing_image_headline":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.logo_images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.responsive_search_ad.descriptions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.call_ad.conversion_reporting_state":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.accent_color":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.descriptions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.responsive_display_ad.price_prefix":{"type":["null","string"]},"ad_group_ad.ad.video_ad.in_stream.action_headline":{"type":["null","string"]},"ad_group_ad.ad.video_responsive_ad.long_headlines":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.responsive_display_ad.business_name":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.long_headline":{"type":["null","string"]},"ad_group_ad.ad.video_responsive_ad.call_to_actions":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.gmail_ad.marketing_image_description":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.format_setting":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.youtube_videos":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.call_ad.phone_number_verification_url":{"type":["null","string"]},"ad_group_ad.ad.video_responsive_ad.companion_banners":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.expanded_dynamic_search_ad.description":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.marketing_images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.video_ad.in_stream.action_button_label":{"type":["null","string"]},"ad_group_ad.ad.expanded_dynamic_search_ad.description2":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.logo_image":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.main_color":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.promo_text":{"type":["null","string"]},"ad_group_ad.ad.shopping_comparison_listing_ad.headline":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.description":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.square_logo_images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.legacy_responsive_display_ad.accent_color":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.price_prefix":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.call_to_action_text":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.business_name":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.long_headline":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.allow_flexible_color":{"type":["null","boolean"]},"ad_group_ad.ad.legacy_responsive_display_ad.format_setting":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.short_headline":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.marketing_image":{"type":["null","string"]},"ad_group_ad.ad.display_upload_ad.display_upload_product_type":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.square_marketing_images":{"type":["null","array"],"items":{"type":"string"}},"ad_group_ad.ad.legacy_responsive_display_ad.square_logo_image":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.call_to_action_text":{"type":["null","string"]},"ad_group_ad.ad.legacy_responsive_display_ad.allow_flexible_color":{"type":["null","boolean"]},"ad_group_ad.ad.legacy_responsive_display_ad.square_marketing_image":{"type":["null","string"]},"ad_group_ad.ad.gmail_ad.marketing_image_display_call_to_action.text":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.control_spec.enable_autogen_video":{"type":["null","boolean"]},"ad_group_ad.ad.gmail_ad.marketing_image_display_call_to_action.text_color":{"type":["null","string"]},"ad_group_ad.ad.responsive_display_ad.control_spec.enable_asset_enhancements":{"type":["null","boolean"]},"ad_group_ad.ad.gmail_ad.marketing_image_display_call_to_action.url_collection_id":{"type":["null","string"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[segments.date],sourceDefinedPrimaryKey=[[ad_group_ad.ad.id], [segments.date]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[segments.date],destinationSyncMode=append_dedup,primaryKey=[[ad_group_ad.ad.id], [segments.date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@9625023[stream=io.airbyte.protocol.models.AirbyteStream@574e0eca[name=ad_group_ad_labels,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"label.name":{"type":["null","string"]},"label.resource_name":{"type":["null","string"]},"ad_group_ad.ad.resource_name":{"type":["null","string"]},"ad_group_ad_label.resource_name":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[ad_group_ad_label.resource_name]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[ad_group_ad_label.resource_name]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3d86db81[stream=io.airbyte.protocol.models.AirbyteStream@4be0818[name=ad_groups,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"ad_group.id":{"type":["null","integer"]},"ad_group.name":{"type":["null","string"]},"ad_group.type":{"type":["null","string"]},"segments.date":{"type":["null","string"],"format":"date"},"ad_group.labels":{"type":["null","array"],"items":{"type":"string"}},"ad_group.status":{"type":["null","string"]},"ad_group.campaign":{"type":["null","string"]},"ad_group.target_roas":{"type":["null","number"]},"ad_group.base_ad_group":{"type":["null","string"]},"ad_group.resource_name":{"type":["null","string"]},"ad_group.cpc_bid_micros":{"type":["null","integer"]},"ad_group.cpm_bid_micros":{"type":["null","integer"]},"ad_group.cpv_bid_micros":{"type":["null","integer"]},"ad_group.ad_rotation_mode":{"type":["null","string"]},"ad_group.final_url_suffix":{"type":["null","string"]},"ad_group.target_cpa_micros":{"type":["null","integer"]},"ad_group.target_cpm_micros":{"type":["null","integer"]},"ad_group.effective_target_roas":{"type":["null","number"]},"ad_group.tracking_url_template":{"type":["null","string"]},"ad_group.url_custom_parameters":{"type":["null","array"],"items":{"type":"string"}},"ad_group.percent_cpc_bid_micros":{"type":["null","integer"]},"ad_group.effective_target_cpa_micros":{"type":["null","integer"]},"ad_group.effective_target_cpa_source":{"type":["null","string"]},"ad_group.display_custom_bid_dimension":{"type":["null","string"]},"ad_group.effective_target_roas_source":{"type":["null","string"]},"ad_group.excluded_parent_asset_field_types":{"type":["null","array"],"items":{"type":"string"}},"ad_group.targeting_setting.target_restrictions":{"type":["null","array"],"items":{"type":"string"}},"ad_group.explorer_auto_optimizer_setting.opt_in":{"type":["null","boolean"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[segments.date],sourceDefinedPrimaryKey=[[ad_group.id], [segments.date]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[segments.date],destinationSyncMode=append_dedup,primaryKey=[[ad_group.id], [segments.date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1fc6b3e4[stream=io.airbyte.protocol.models.AirbyteStream@38d9d688[name=ad_group_labels,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"label.name":{"type":["null","string"]},"label.resource_name":{"type":["null","string"]},"ad_group.resource_name":{"type":["null","string"]},"ad_group_label.resource_name":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[ad_group_label.resource_name]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[ad_group_label.resource_name]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@330858c1[stream=io.airbyte.protocol.models.AirbyteStream@47827870[name=accounts,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"customer.id":{"type":["null","integer"]},"segments.date":{"type":["null","string"],"format":"date"},"customer.manager":{"type":["null","boolean"]},"customer.time_zone":{"type":["null","string"]},"customer.test_account":{"type":["null","boolean"]},"customer.currency_code":{"type":["null","string"]},"customer.resource_name":{"type":["null","string"]},"customer.descriptive_name":{"type":["null","string"]},"customer.final_url_suffix":{"type":["null","string"]},"customer.has_partners_badge":{"type":["null","boolean"]},"customer.optimization_score":{"type":["null","number"]},"customer.auto_tagging_enabled":{"type":["null","boolean"]},"customer.tracking_url_template":{"type":["null","string"]},"customer.optimization_score_weight":{"type":["null","number"]},"customer.remarketing_setting.google_global_site_tag":{"type":["null","string"]},"customer.call_reporting_setting.call_conversion_action":{"type":["null","string"]},"customer.call_reporting_setting.call_reporting_enabled":{"type":["null","boolean"]},"customer.pay_per_conversion_eligibility_failure_reasons":{"type":["null","array"],"items":{"type":"string"}},"customer.conversion_tracking_setting.conversion_tracking_id":{"type":["null","integer"]},"customer.call_reporting_setting.call_conversion_reporting_enabled":{"type":["null","boolean"]},"customer.conversion_tracking_setting.cross_account_conversion_tracking_id":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[segments.date],sourceDefinedPrimaryKey=[[customer.id], [segments.date]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[segments.date],destinationSyncMode=append_dedup,primaryKey=[[customer.id], [segments.date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6df1aaf7[stream=io.airbyte.protocol.models.AirbyteStream@1b6a4c57[name=campaign_labels,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"label.name":{"type":["null","string"]},"label.resource_name":{"type":["null","string"]},"campaign.resource_name":{"type":["null","string"]},"campaign_label.resource_name":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=,defaultCursorField=[],sourceDefinedPrimaryKey=[[campaign_label.resource_name]],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[campaign_label.resource_name]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6a55d1ab[stream=io.airbyte.protocol.models.AirbyteStream@3ec07569[name=click_view,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"ad_group.id":{"type":["null","integer"]},"campaign.id":{"type":["null","integer"]},"customer.id":{"type":["null","integer"]},"ad_group.name":{"type":["null","string"]},"campaign.name":{"type":["null","string"]},"segments.date":{"type":["null","string"]},"click_view.gclid":{"type":["null","string"]},"click_view.keyword":{"type":["null","string"]},"click_view.ad_group_ad":{"type":["null","string"]},"segments.ad_network_type":{"type":["null","string"]},"click_view.keyword_info.text":{"type":["null","string"]},"click_view.keyword_info.match_type":{"type":["null","string"]},"campaign.network_settings.target_google_search":{"type":["null","boolean"]},"campaign.network_settings.target_search_network":{"type":["null","boolean"]},"campaign.network_settings.target_content_network":{"type":["null","boolean"]},"campaign.network_settings.target_partner_search_network":{"type":["null","boolean"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[segments.date],sourceDefinedPrimaryKey=[[click_view.gclid], [segments.date], [segments.ad_network_type]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[segments.date],destinationSyncMode=append_dedup,primaryKey=[[click_view.gclid], [segments.date], [segments.ad_network_type]],additionalProperties={}]],additionalProperties={}],failures=[]] 2022-12-14 12:54:28 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):210 - Sync summary length: 21872 2022-12-14 12:54:28 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2022-12-14 12:54:28 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state 2022-12-14 12:54:28 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):56 - Using default value for environment variable NEED_STATE_VALIDATION: 'true' 2022-12-14 12:54:28 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to create or update state 2022-12-14 12:54:28 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get normalization statuses 2022-12-14 12:54:29 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/12/0/logs.log 2022-12-14 12:54:29 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.25 2022-12-14 12:54:29 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation 2022-12-14 12:54:29 ERROR i.a.w.n.NormalizationRunnerFactory(create):50 - The normalization image name or tag in the definition file is different from the normalization image or tag in the NormalizationRunnerFactory! 2022-12-14 12:54:29 ERROR i.a.w.n.NormalizationRunnerFactory(create):52 - the definition file value - airbyte/normalization:0.2.24, the NormalizationRunnerFactory value - airbyte/normalization:0.2.25 2022-12-14 12:54:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-12-14 12:54:29 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START DEFAULT NORMALIZATION ----- 2022-12-14 12:54:29 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):141 - Running with normalization version: airbyte/normalization:0.2.25 2022-12-14 12:54:29 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-12-14 12:54:29 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/normalization:0.2.25 exists... 2022-12-14 12:54:29 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/normalization:0.2.25 was found locally. 2022-12-14 12:54:29 INFO i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = normalization-normalize-12-0-opziv with resources io.airbyte.config.ResourceRequirements@122a4b63[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] 2022-12-14 12:54:29 INFO i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/12/0/normalize --log-driver none --name normalization-normalize-12-0-opziv --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.40.25 airbyte/normalization:0.2.25 run --integration-type bigquery --config destination_config.json --catalog destination_catalog.json 2022-12-14 12:54:29 normalization > Running: transform-config --config destination_config.json --integration-type bigquery --out /data/12/0/normalize 2022-12-14 12:54:32 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/12/0/normalize') 2022-12-14 12:54:32 normalization > transform_bigquery 2022-12-14 12:54:32 normalization > Running: transform-catalog --integration-type bigquery --profile-config-dir /data/12/0/normalize --catalog destination_catalog.json --out /data/12/0/normalize/models/generated/ --json-column _airbyte_data 2022-12-14 12:54:36 normalization > Processing destination_catalog.json... 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_ads_ab1.sql from ad_group_ads 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_ads_ab2.sql from ad_group_ads 2022-12-14 12:54:36 normalization > Generating airbyte_views/datacat/ad_group_ads_stg.sql from ad_group_ads 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/scd/datacat/ad_group_ads_scd.sql from ad_group_ads 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/datacat/ad_group_ads.sql from ad_group_ads 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_ad_labels_ab1.sql from ad_group_ad_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_ad_labels_ab2.sql from ad_group_ad_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_ad_labels_ab3.sql from ad_group_ad_labels 2022-12-14 12:54:36 normalization > Adding drop table hook for ad_group_ad_labels_scd to ad_group_ad_labels 2022-12-14 12:54:36 normalization > Generating airbyte_tables/datacat/ad_group_ad_labels.sql from ad_group_ad_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_groups_ab1.sql from ad_groups 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_groups_ab2.sql from ad_groups 2022-12-14 12:54:36 normalization > Generating airbyte_views/datacat/ad_groups_stg.sql from ad_groups 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/scd/datacat/ad_groups_scd.sql from ad_groups 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/datacat/ad_groups.sql from ad_groups 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_labels_ab1.sql from ad_group_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_labels_ab2.sql from ad_group_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/ad_group_labels_ab3.sql from ad_group_labels 2022-12-14 12:54:36 normalization > Adding drop table hook for ad_group_labels_scd to ad_group_labels 2022-12-14 12:54:36 normalization > Generating airbyte_tables/datacat/ad_group_labels.sql from ad_group_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/accounts_ab1.sql from accounts 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/accounts_ab2.sql from accounts 2022-12-14 12:54:36 normalization > Generating airbyte_views/datacat/accounts_stg.sql from accounts 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/scd/datacat/accounts_scd.sql from accounts 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/datacat/accounts.sql from accounts 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/campaign_labels_ab1.sql from campaign_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/campaign_labels_ab2.sql from campaign_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/campaign_labels_ab3.sql from campaign_labels 2022-12-14 12:54:36 normalization > Adding drop table hook for campaign_labels_scd to campaign_labels 2022-12-14 12:54:36 normalization > Generating airbyte_tables/datacat/campaign_labels.sql from campaign_labels 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/click_view_ab1.sql from click_view 2022-12-14 12:54:36 normalization > Generating airbyte_ctes/datacat/click_view_ab2.sql from click_view 2022-12-14 12:54:36 normalization > Generating airbyte_views/datacat/click_view_stg.sql from click_view 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/scd/datacat/click_view_scd.sql from click_view 2022-12-14 12:54:36 normalization > Generating airbyte_incremental/datacat/click_view.sql from click_view 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.labels' from ad_group_ads/ad_group_ad.labels because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.final_urls' from ad_group_ads/ad_group_ad.ad.final_urls because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_ad.images' from ad_group_ads/ad_group_ad.ad.app_ad.images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.final_app_urls' from ad_group_ads/ad_group_ad.ad.final_app_urls because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.local_ad.videos' from ad_group_ads/ad_group_ad.ad.local_ad.videos because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.url_collections' from ad_group_ads/ad_group_ad.ad.url_collections because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_ad.headlines' from ad_group_ads/ad_group_ad.ad.app_ad.headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.final_mobile_urls' from ad_group_ads/ad_group_ad.ad.final_mobile_urls because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.local_ad.headlines' from ad_group_ads/ad_group_ad.ad.local_ad.headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_ad.descriptions' from ad_group_ads/ad_group_ad.ad.app_ad.descriptions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.local_ad.logo_images' from ad_group_ads/ad_group_ad.ad.local_ad.logo_images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_ad.youtube_videos' from ad_group_ads/ad_group_ad.ad.app_ad.youtube_videos because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.local_ad.descriptions' from ad_group_ads/ad_group_ad.ad.local_ad.descriptions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.url_custom_parameters' from ad_group_ads/ad_group_ad.ad.url_custom_parameters because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.gmail_ad.product_images' from ad_group_ads/ad_group_ad.ad.gmail_ad.product_images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.gmail_ad.product_videos' from ad_group_ads/ad_group_ad.ad.gmail_ad.product_videos because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_engagement_ad.images' from ad_group_ads/ad_group_ad.ad.app_engagement_ad.images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_engagement_ad.videos' from ad_group_ads/ad_group_ad.ad.app_engagement_ad.videos because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.local_ad.call_to_actions' from ad_group_ads/ad_group_ad.ad.local_ad.call_to_actions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.local_ad.marketing_images' from ad_group_ads/ad_group_ad.ad.local_ad.marketing_images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_ad.html5_media_bundles' from ad_group_ads/ad_group_ad.ad.app_ad.html5_media_bundles because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.video_responsive_ad.videos' from ad_group_ads/ad_group_ad.ad.video_responsive_ad.videos because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_engagement_ad.headlines' from ad_group_ads/ad_group_ad.ad.app_engagement_ad.headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.smart_campaign_ad.headlines' from ad_group_ads/ad_group_ad.ad.smart_campaign_ad.headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.video_responsive_ad.headlines' from ad_group_ads/ad_group_ad.ad.video_responsive_ad.headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.app_engagement_ad.descriptions' from ad_group_ads/ad_group_ad.ad.app_engagement_ad.descriptions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_search_ad.headlines' from ad_group_ads/ad_group_ad.ad.responsive_search_ad.headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.smart_campaign_ad.descriptions' from ad_group_ads/ad_group_ad.ad.smart_campaign_ad.descriptions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_display_ad.headlines' from ad_group_ads/ad_group_ad.ad.responsive_display_ad.headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.video_responsive_ad.descriptions' from ad_group_ads/ad_group_ad.ad.video_responsive_ad.descriptions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.policy_summary.policy_topic_entries' from ad_group_ads/ad_group_ad.policy_summary.policy_topic_entries because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_display_ad.logo_images' from ad_group_ads/ad_group_ad.ad.responsive_display_ad.logo_images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_search_ad.descriptions' from ad_group_ads/ad_group_ad.ad.responsive_search_ad.descriptions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_display_ad.descriptions' from ad_group_ads/ad_group_ad.ad.responsive_display_ad.descriptions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.video_responsive_ad.long_headlines' from ad_group_ads/ad_group_ad.ad.video_responsive_ad.long_headlines because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.video_responsive_ad.call_to_actions' from ad_group_ads/ad_group_ad.ad.video_responsive_ad.call_to_actions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_display_ad.youtube_videos' from ad_group_ads/ad_group_ad.ad.responsive_display_ad.youtube_videos because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.video_responsive_ad.companion_banners' from ad_group_ads/ad_group_ad.ad.video_responsive_ad.companion_banners because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_display_ad.marketing_images' from ad_group_ads/ad_group_ad.ad.responsive_display_ad.marketing_images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_display_ad.square_logo_images' from ad_group_ads/ad_group_ad.ad.responsive_display_ad.square_logo_images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group_ad.ad.responsive_display_ad.square_marketing_images' from ad_group_ads/ad_group_ad.ad.responsive_display_ad.square_marketing_images because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group.labels' from ad_groups/ad_group.labels because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group.url_custom_parameters' from ad_groups/ad_group.url_custom_parameters because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group.excluded_parent_asset_field_types' from ad_groups/ad_group.excluded_parent_asset_field_types because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'ad_group.targeting_setting.target_restrictions' from ad_groups/ad_group.targeting_setting.target_restrictions because properties list is empty 2022-12-14 12:54:36 normalization > Ignoring stream 'customer.pay_per_conversion_eligibility_failure_reasons' from accounts/customer.pay_per_conversion_eligibility_failure_reasons because properties list is empty 2022-12-14 12:54:36 normalization > detected no config file for ssh, assuming ssh is off. 2022-12-14 12:54:53 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-12-14 12:54:53 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-12-14 12:54:53 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2022-12-14 12:54:53 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-12-14 12:54:53 INFO i.a.w.n.NormalizationAirbyteStreamFactory(filterOutAndHandleNonAirbyteMessageLines):104 - 2022-12-14 12:55:13 normalization > Running with dbt=1.0.0 2022-12-14 12:55:13 normalization > Partial parse save file not found. Starting full parse. 2022-12-14 12:55:27 normalization > Found 32 models, 0 tests, 0 snapshots, 0 analyses, 602 macros, 0 operations, 0 seed files, 7 sources, 0 exposures, 0 metrics 2022-12-14 12:55:32 normalization > Concurrency: 8 threads (target='prod') 2022-12-14 12:55:35 normalization > 1 of 15 START view model _airbyte_datacat.accounts_stg.................................................................. [RUN] 2022-12-14 12:55:36 normalization > 2 of 15 START view model _airbyte_datacat.click_view_stg................................................................ [RUN] 2022-12-14 12:55:36 normalization > 3 of 15 START view model _airbyte_datacat.ad_groups_stg................................................................. [RUN] 2022-12-14 12:55:36 normalization > 4 of 15 START table model datacat.ad_group_ad_labels.................................................................... [RUN] 2022-12-14 12:55:37 normalization > 5 of 15 START table model datacat.ad_group_labels....................................................................... [RUN] 2022-12-14 12:55:37 normalization > 6 of 15 START table model datacat.campaign_labels....................................................................... [RUN] 2022-12-14 12:55:40 normalization > 2 of 15 OK created view model _airbyte_datacat.click_view_stg........................................................... [OK in 4.32s] 2022-12-14 12:55:40 normalization > 7 of 15 START incremental model datacat.click_view_scd.................................................................. [RUN] 2022-12-14 12:55:40 normalization > 1 of 15 OK created view model _airbyte_datacat.accounts_stg............................................................. [OK in 4.87s] 2022-12-14 12:55:40 normalization > 8 of 15 START incremental model datacat.accounts_scd.................................................................... [RUN] 2022-12-14 12:55:41 normalization > 9 of 15 START view model _airbyte_datacat.ad_group_ads_stg.............................................................. [RUN] 2022-12-14 12:55:41 normalization > 3 of 15 OK created view model _airbyte_datacat.ad_groups_stg............................................................ [OK in 4.67s] 2022-12-14 12:55:41 normalization > 10 of 15 START incremental model datacat.ad_groups_scd.................................................................. [RUN] 2022-12-14 12:55:43 normalization > 5 of 15 OK created table model datacat.ad_group_labels.................................................................. [CREATE TABLE (0.0 rows, 0 processed) in 6.11s] 2022-12-14 12:55:43 normalization > 4 of 15 OK created table model datacat.ad_group_ad_labels............................................................... [CREATE TABLE (0.0 rows, 0 processed) in 6.38s] 2022-12-14 12:55:43 normalization > 6 of 15 OK created table model datacat.campaign_labels.................................................................. [CREATE TABLE (0.0 rows, 0 processed) in 6.16s] 2022-12-14 12:55:48 normalization > 9 of 15 OK created view model _airbyte_datacat.ad_group_ads_stg......................................................... [OK in 7.49s] 2022-12-14 12:55:48 normalization > 11 of 15 START incremental model datacat.ad_group_ads_scd............................................................... [RUN] 2022-12-14 12:56:01 normalization > 7 of 15 OK created incremental model datacat.click_view_scd............................................................. [MERGE (0.0 rows, 0 processed) in 20.97s] 2022-12-14 12:56:01 normalization > 8 of 15 OK created incremental model datacat.accounts_scd............................................................... [MERGE (0.0 rows, 0 processed) in 20.78s] 2022-12-14 12:56:01 normalization > 12 of 15 START incremental model datacat.click_view..................................................................... [RUN] 2022-12-14 12:56:01 normalization > 13 of 15 START incremental model datacat.accounts....................................................................... [RUN] 2022-12-14 12:56:01 normalization > 10 of 15 OK created incremental model datacat.ad_groups_scd............................................................. [MERGE (0.0 rows, 0 processed) in 20.65s] 2022-12-14 12:56:02 normalization > 14 of 15 START incremental model datacat.ad_groups...................................................................... [RUN] 2022-12-14 12:56:09 normalization > 11 of 15 OK created incremental model datacat.ad_group_ads_scd.......................................................... [MERGE (0.0 rows, 0 processed) in 20.80s] 2022-12-14 12:56:09 normalization > 15 of 15 START incremental model datacat.ad_group_ads................................................................... [RUN] 2022-12-14 12:56:10 normalization > 12 of 15 OK created incremental model datacat.click_view................................................................ [MERGE (0.0 rows, 0 processed) in 8.59s] 2022-12-14 12:56:11 normalization > 14 of 15 OK created incremental model datacat.ad_groups................................................................. [MERGE (0.0 rows, 0 processed) in 9.10s] 2022-12-14 12:56:11 normalization > 13 of 15 OK created incremental model datacat.accounts.................................................................. [MERGE (0.0 rows, 0 processed) in 9.47s] 2022-12-14 12:56:19 normalization > 15 of 15 OK created incremental model datacat.ad_group_ads.............................................................. [MERGE (0.0 rows, 0 processed) in 9.83s] 2022-12-14 12:56:19 normalization > Finished running 4 view models, 3 table models, 8 incremental models in 52.08s. 2022-12-14 12:56:19 normalization > Completed successfully 2022-12-14 12:56:19 normalization > Done. PASS=15 WARN=0 ERROR=0 SKIP=0 TOTAL=15 2022-12-14 12:56:20 INFO i.a.w.n.DefaultNormalizationRunner(close):206 - Terminating normalization process... 2022-12-14 12:56:20 INFO i.a.w.n.DefaultNormalizationRunner(close):219 - Normalization process successfully terminated. 2022-12-14 12:56:20 INFO i.a.w.g.DefaultNormalizationWorker(run):94 - Normalization executed in 1 minute 51 seconds for job 12. 2022-12-14 12:56:20 INFO i.a.w.g.DefaultNormalizationWorker(run):106 - Normalization summary: io.airbyte.config.NormalizationSummary@331b742a[startTime=1671022469026,endTime=1671022580291,failures=[]] 2022-12-14 12:56:20 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling... 2022-12-14 12:56:20 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating... 2022-12-14 12:56:20 INFO i.a.c.i.LineGobbler(voidCall):114 - 2022-12-14 12:56:20 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END DEFAULT NORMALIZATION ----- 2022-12-14 12:56:20 INFO i.a.c.i.LineGobbler(voidCall):114 -