2022-04-22 02:02:56 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.30-alpha
2022-04-22 02:02:57 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/98/2/logs.log
2022-04-22 02:02:57 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.30-alpha
2022-04-22 02:02:57 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 98 attempt id: 2
2022-04-22 02:02:57 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.pages=incremental - append_dedup, null.devices=incremental - append_dedup, null.locations=incremental - append_dedup, null.user__gender=full_refresh - append, null.users__age=full_refresh - append, null.traffic_sources=incremental - append_dedup, null.website_overview=incremental - append_dedup}
2022-04-22 02:02:57 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-22 02:02:58 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-redshift:0.3.32 exists...
2022-04-22 02:02:59 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-redshift:0.3.32 was found locally.
2022-04-22 02:02:59 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/98/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-redshift:0.3.32 write --config destination_config.json --catalog destination_catalog.json
2022-04-22 02:02:59 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-google-analytics-v4:0.1.19 exists...
2022-04-22 02:03:00 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-google-analytics-v4:0.1.19 was found locally.
2022-04-22 02:03:01 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/98/2 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-google-analytics-v4:0.1.19 read --config source_config.json --catalog source_catalog.json
2022-04-22 02:03:01 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):337 - Destination output thread started.
2022-04-22 02:03:01 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-04-22 02:03:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-04-22 02:03:09 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-22 02:03:09 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-22 02:03:09 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-22 02:03:09 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-22 02:03:10 source > Starting syncing SourceGoogleAnalyticsV4
2022-04-22 02:03:11 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-22 02:03:21 source > Syncing stream: devices 
2022-04-22 02:03:26 destination > 2022-04-22 02:03:26 INFO i.a.i.d.r.RedshiftDestination(main):70 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-22 02:03:30 destination > 2022-04-22 02:03:30 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-22 02:03:30 destination > 2022-04-22 02:03:30 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-04-22 02:03:30 destination > 2022-04-22 02:03:30 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-04-22 02:03:30 destination > 2022-04-22 02:03:30 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-22 02:03:33 destination > 2022-04-22 02:03:33 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 02:03:33 destination > 2022-04-22 02:03:33 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 02:03:33 destination > 2022-04-22 02:03:33 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3_WITH_SUPER_TMP_TYPE
2022-04-22 02:03:37 destination > 2022-04-22 02:03:37 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):165 - Creating S3 client...
2022-04-22 02:03:50 destination > 2022-04-22 02:03:50 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-22 02:03:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 1000
2022-04-22 02:03:56 source > Read 557 records from devices stream
2022-04-22 02:03:56 source > Finished syncing devices
2022-04-22 02:03:56 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream devices 0:00:34.890058
2022-04-22 02:03:56 source > Syncing stream: locations 
2022-04-22 02:04:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 2000
2022-04-22 02:04:33 source > Read 716 records from locations stream
2022-04-22 02:04:33 source > Finished syncing locations
2022-04-22 02:04:33 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream devices 0:00:34.890058
Syncing stream locations 0:00:36.499702
2022-04-22 02:04:33 source > Syncing stream: pages 
2022-04-22 02:04:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 3000
2022-04-22 02:04:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 4000
2022-04-22 02:05:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 5000
2022-04-22 02:05:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 6000
2022-04-22 02:05:18 source > Read 1906 records from pages stream
2022-04-22 02:05:18 source > Finished syncing pages
2022-04-22 02:05:18 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream devices 0:00:34.890058
Syncing stream locations 0:00:36.499702
Syncing stream pages 0:00:44.810685
2022-04-22 02:05:18 source > Syncing stream: traffic_sources 
2022-04-22 02:05:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):300 - Records read: 7000
2022-04-22 02:05:53 source > Read 367 records from traffic_sources stream
2022-04-22 02:05:53 source > Finished syncing traffic_sources
2022-04-22 02:05:53 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream devices 0:00:34.890058
Syncing stream locations 0:00:36.499702
Syncing stream pages 0:00:44.810685
Syncing stream traffic_sources 0:00:35.883275
2022-04-22 02:05:53 source > Syncing stream: user__gender 
2022-04-22 02:06:25 source > Read 0 records from user__gender stream
2022-04-22 02:06:25 source > Finished syncing user__gender
2022-04-22 02:06:25 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream devices 0:00:34.890058
Syncing stream locations 0:00:36.499702
Syncing stream pages 0:00:44.810685
Syncing stream traffic_sources 0:00:35.883275
Syncing stream user__gender 0:00:31.360786
2022-04-22 02:06:25 source > Syncing stream: users__age 
2022-04-22 02:06:57 source > Read 0 records from users__age stream
2022-04-22 02:06:57 source > Finished syncing users__age
2022-04-22 02:06:57 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream devices 0:00:34.890058
Syncing stream locations 0:00:36.499702
Syncing stream pages 0:00:44.810685
Syncing stream traffic_sources 0:00:35.883275
Syncing stream user__gender 0:00:31.360786
Syncing stream users__age 0:00:32.517405
2022-04-22 02:06:57 source > Syncing stream: website_overview 
2022-04-22 02:07:27 source > Read 112 records from website_overview stream
2022-04-22 02:07:27 source > Finished syncing website_overview
2022-04-22 02:07:27 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream devices 0:00:34.890058
Syncing stream locations 0:00:36.499702
Syncing stream pages 0:00:44.810685
Syncing stream traffic_sources 0:00:35.883275
Syncing stream user__gender 0:00:31.360786
Syncing stream users__age 0:00:32.517405
Syncing stream website_overview 0:00:29.354571
2022-04-22 02:07:27 source > Finished syncing SourceGoogleAnalyticsV4
2022-04-22 02:07:27 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-04-22 02:07:27 destination > 2022-04-22 02:07:27 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-22 02:07:27 destination > 2022-04-22 02:07:27 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-04-22 02:07:27 destination > 2022-04-22 02:07:27 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing locations: 716 records (5 MB)
2022-04-22 02:07:27 destination > 2022-04-22 02:07:27 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-22 02:07:27 destination > 2022-04-22 02:07:27 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'locations': s3://travlrdatatesting/airbyte_staging/locations/2022_04_22_1650593030056_c291aef3-5cd0-45fb-8207-47b4a490af4f.csv
2022-04-22 02:07:27 destination > 2022-04-22 02:07:27 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-22 02:07:29 destination > 2022-04-22 02:07:29 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_staging/locations/2022_04_22_1650593030056_c291aef3-5cd0-45fb-8207-47b4a490af4f.csv with full ID bG_oM0FZHsKii6tHzj4eVxoM1fHAj_poh572sCJCf5uugaKpleuVr5E4OWooF7prUg5ZD15CqANZrRdQrvYYeaf7mSXxzXuQyC0Q_mz.7hslKzkw9loACu8HMGk9CWwYYf6qyzXoB1yFRdqYJrCS4Q--
2022-04-22 02:07:29 destination > 2022-04-22 02:07:29 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing traffic_sources: 367 records (5 MB)
2022-04-22 02:07:29 destination > 2022-04-22 02:07:29 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-22 02:07:29 destination > 2022-04-22 02:07:29 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'traffic_sources': s3://travlrdatatesting/airbyte_staging/traffic_sources/2022_04_22_1650593030081_b84d5100-0a3b-4f42-9b2b-6c371039f983.csv
2022-04-22 02:07:29 destination > 2022-04-22 02:07:29 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-22 02:07:30 destination > 2022-04-22 02:07:30 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_staging/traffic_sources/2022_04_22_1650593030081_b84d5100-0a3b-4f42-9b2b-6c371039f983.csv with full ID 9EltHb9qZxkzdYaJHC9cnqyuK9ogofdKKqV4tAaveK4rz4hAW9tV3M7HMDZpRHxupnmNpyuB1yCm_2syPXp_r5F1G4Dxy6EqYFakifhv9M.M8HygSie8XmPxWrgMsiByTUenSUwvJTTQfZtMs24Ylg--
2022-04-22 02:07:30 destination > 2022-04-22 02:07:30 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing devices: 557 records (5 MB)
2022-04-22 02:07:30 destination > 2022-04-22 02:07:30 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-22 02:07:30 destination > 2022-04-22 02:07:30 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'devices': s3://travlrdatatesting/airbyte_staging/devices/2022_04_22_1650593030054_5fa4f9ab-ae16-4614-baa7-55c5535f2dc3.csv
2022-04-22 02:07:30 destination > 2022-04-22 02:07:30 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-22 02:07:31 destination > 2022-04-22 02:07:31 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_staging/devices/2022_04_22_1650593030054_5fa4f9ab-ae16-4614-baa7-55c5535f2dc3.csv with full ID 3QYyKvyYq3G4n.EtFlwI0kHw8GrjeXVfg7QSaMIhqCYJacz.lHnn1wich8oTI1MLDqzHswxVAeruZ_pg.JYtPASpBiuF9WfuAsZofL6fSKe5q0EZ18XjazpKVmkWb.9tKk.OkHFMy0OyBYAus0GHQA--
2022-04-22 02:07:32 destination > 2022-04-22 02:07:32 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing website_overview: 112 records (5 MB)
2022-04-22 02:07:32 destination > 2022-04-22 02:07:32 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-22 02:07:32 destination > 2022-04-22 02:07:32 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'website_overview': s3://travlrdatatesting/airbyte_staging/website_overview/2022_04_22_1650593030082_25097833-886a-4e2f-972b-9205d44505b5.csv
2022-04-22 02:07:32 destination > 2022-04-22 02:07:32 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-22 02:07:32 destination > 2022-04-22 02:07:32 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_staging/website_overview/2022_04_22_1650593030082_25097833-886a-4e2f-972b-9205d44505b5.csv with full ID _h7B2nIRCwANPUf7Spc9LeD5iendlkDiRbXQCzbRIxnjCebDGQ4NwyRjx4tD2cbs9ERsQSIo4FDEuPIAgxiWf_dDC82ogBOIRq03h8PF110g29EvyOdqOkJOH42IX9puitJLEgv4NC8tD._sQePrUg--
2022-04-22 02:07:33 destination > 2022-04-22 02:07:33 INFO i.a.i.d.r.InMemoryRecordBufferingStrategy(lambda$flushAll$1):84 - Flushing pages: 1906 records (5 MB)
2022-04-22 02:07:33 destination > 2022-04-22 02:07:33 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):96 - S3 upload part size: 10 MB
2022-04-22 02:07:33 destination > 2022-04-22 02:07:33 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'pages': s3://travlrdatatesting/airbyte_staging/pages/2022_04_22_1650593030057_61f5a0f6-085b-481e-b810-b2e625e8e5d4.csv
2022-04-22 02:07:33 destination > 2022-04-22 02:07:33 INFO i.a.i.d.s.u.StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-04-22 02:07:33 destination > 2022-04-22 02:07:33 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to travlrdatatesting/airbyte_staging/pages/2022_04_22_1650593030057_61f5a0f6-085b-481e-b810-b2e625e8e5d4.csv with full ID EJmm_YlK3TTtGBEMdSCMp.ydw7xpyqQjFoowMjEY54XGqnNjDrjjAlnwVYlACl8W1w6DOBey_5BFB__1vVLPb4dRRVIpKpBqrogJ0bbStpbP9wRE.Wur5KUWyppBZc3lNhyVhWbNEIodNc_lOx1ZGQ--
2022-04-22 02:07:34 destination > 2022-04-22 02:07:34 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: googleanalytic
2022-04-22 02:07:39 destination > 2022-04-22 02:07:39 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: users__age, schema: googleanalytic, tmp table name: _airbyte_tmp_iqv_users__age.
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_iqv_users__age in destination for stream: users__age, schema: googleanalytic, .
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_iqv_users__age in destination for stream users__age complete.
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_users__age in destination.
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_iqv_users__age in destination prepared.
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_iqv_users__age to dest table: _airbyte_raw_users__age, schema: googleanalytic, in destination.
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'locations'.
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-22 02:07:40 destination > 2022-04-22 02:07:40 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to travlrdatatesting/airbyte_staging/locations/2022_04_22_1650593030056_c291aef3-5cd0-45fb-8207-47b4a490af4f.csv with id bG_oM0FZH...YJrCS4Q--]: Uploading leftover stream [Part number 1 containing 0.36 MB]
2022-04-22 02:07:42 destination > 2022-04-22 02:07:42 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to travlrdatatesting/airbyte_staging/locations/2022_04_22_1650593030056_c291aef3-5cd0-45fb-8207-47b4a490af4f.csv with id bG_oM0FZH...YJrCS4Q--]: Finished uploading [Part number 1 containing 0.36 MB]
2022-04-22 02:07:42 destination > 2022-04-22 02:07:42 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to travlrdatatesting/airbyte_staging/locations/2022_04_22_1650593030056_c291aef3-5cd0-45fb-8207-47b4a490af4f.csv with id bG_oM0FZH...YJrCS4Q--]: Completed
2022-04-22 02:07:42 destination > 2022-04-22 02:07:42 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'locations'.
2022-04-22 02:07:42 destination > 2022-04-22 02:07:42 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: googleanalytic
2022-04-22 02:07:42 destination > 2022-04-22 02:07:42 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: locations, schema: googleanalytic, tmp table name: _airbyte_tmp_aso_locations.
2022-04-22 02:07:42 destination > 2022-04-22 02:07:42 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_aso_locations in destination for stream: locations, schema: googleanalytic, .
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_aso_locations in destination for stream locations complete.
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_locations in destination.
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_aso_locations in destination prepared.
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_aso_locations to dest table: _airbyte_raw_locations, schema: googleanalytic, in destination.
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'devices'.
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to travlrdatatesting/airbyte_staging/devices/2022_04_22_1650593030054_5fa4f9ab-ae16-4614-baa7-55c5535f2dc3.csv with id 3QYyKvyYq...us0GHQA--]: Uploading leftover stream [Part number 1 containing 0.24 MB]
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to travlrdatatesting/airbyte_staging/devices/2022_04_22_1650593030054_5fa4f9ab-ae16-4614-baa7-55c5535f2dc3.csv with id 3QYyKvyYq...us0GHQA--]: Finished uploading [Part number 1 containing 0.24 MB]
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to travlrdatatesting/airbyte_staging/devices/2022_04_22_1650593030054_5fa4f9ab-ae16-4614-baa7-55c5535f2dc3.csv with id 3QYyKvyYq...us0GHQA--]: Completed
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'devices'.
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: googleanalytic
2022-04-22 02:07:45 destination > 2022-04-22 02:07:45 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: devices, schema: googleanalytic, tmp table name: _airbyte_tmp_bqu_devices.
2022-04-22 02:07:46 destination > 2022-04-22 02:07:46 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_bqu_devices in destination for stream: devices, schema: googleanalytic, .
2022-04-22 02:07:46 destination > 2022-04-22 02:07:46 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_bqu_devices in destination for stream devices complete.
2022-04-22 02:07:46 destination > 2022-04-22 02:07:46 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_devices in destination.
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_bqu_devices in destination prepared.
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_bqu_devices to dest table: _airbyte_raw_devices, schema: googleanalytic, in destination.
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'traffic_sources'.
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to travlrdatatesting/airbyte_staging/traffic_sources/2022_04_22_1650593030081_b84d5100-0a3b-4f42-9b2b-6c371039f983.csv with id 9EltHb9qZ...Ms24Ylg--]: Uploading leftover stream [Part number 1 containing 0.16 MB]
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to travlrdatatesting/airbyte_staging/traffic_sources/2022_04_22_1650593030081_b84d5100-0a3b-4f42-9b2b-6c371039f983.csv with id 9EltHb9qZ...Ms24Ylg--]: Finished uploading [Part number 1 containing 0.16 MB]
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to travlrdatatesting/airbyte_staging/traffic_sources/2022_04_22_1650593030081_b84d5100-0a3b-4f42-9b2b-6c371039f983.csv with id 9EltHb9qZ...Ms24Ylg--]: Completed
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'traffic_sources'.
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: googleanalytic
2022-04-22 02:07:47 destination > 2022-04-22 02:07:47 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: traffic_sources, schema: googleanalytic, tmp table name: _airbyte_tmp_xmr_traffic_sources.
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_xmr_traffic_sources in destination for stream: traffic_sources, schema: googleanalytic, .
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_xmr_traffic_sources in destination for stream traffic_sources complete.
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_traffic_sources in destination.
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_xmr_traffic_sources in destination prepared.
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_xmr_traffic_sources to dest table: _airbyte_raw_traffic_sources, schema: googleanalytic, in destination.
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'pages'.
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-22 02:07:48 destination > 2022-04-22 02:07:48 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to travlrdatatesting/airbyte_staging/pages/2022_04_22_1650593030057_61f5a0f6-085b-481e-b810-b2e625e8e5d4.csv with id EJmm_YlK3...lOx1ZGQ--]: Uploading leftover stream [Part number 1 containing 0.88 MB]
2022-04-22 02:07:49 destination > 2022-04-22 02:07:49 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to travlrdatatesting/airbyte_staging/pages/2022_04_22_1650593030057_61f5a0f6-085b-481e-b810-b2e625e8e5d4.csv with id EJmm_YlK3...lOx1ZGQ--]: Finished uploading [Part number 1 containing 0.88 MB]
2022-04-22 02:07:49 destination > 2022-04-22 02:07:49 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to travlrdatatesting/airbyte_staging/pages/2022_04_22_1650593030057_61f5a0f6-085b-481e-b810-b2e625e8e5d4.csv with id EJmm_YlK3...lOx1ZGQ--]: Completed
2022-04-22 02:07:49 destination > 2022-04-22 02:07:49 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'pages'.
2022-04-22 02:07:49 destination > 2022-04-22 02:07:49 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: googleanalytic
2022-04-22 02:07:49 destination > 2022-04-22 02:07:49 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: pages, schema: googleanalytic, tmp table name: _airbyte_tmp_aaw_pages.
2022-04-22 02:07:49 destination > 2022-04-22 02:07:49 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_aaw_pages in destination for stream: pages, schema: googleanalytic, .
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_aaw_pages in destination for stream pages complete.
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_pages in destination.
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_aaw_pages in destination prepared.
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_aaw_pages to dest table: _airbyte_raw_pages, schema: googleanalytic, in destination.
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'website_overview'.
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-04-22 02:07:50 destination > 2022-04-22 02:07:50 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to travlrdatatesting/airbyte_staging/website_overview/2022_04_22_1650593030082_25097833-886a-4e2f-972b-9205d44505b5.csv with id _h7B2nIRC...sQePrUg--]: Uploading leftover stream [Part number 1 containing 0.04 MB]
2022-04-22 02:07:51 destination > 2022-04-22 02:07:51 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to travlrdatatesting/airbyte_staging/website_overview/2022_04_22_1650593030082_25097833-886a-4e2f-972b-9205d44505b5.csv with id _h7B2nIRC...sQePrUg--]: Finished uploading [Part number 1 containing 0.04 MB]
2022-04-22 02:07:51 destination > 2022-04-22 02:07:51 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to travlrdatatesting/airbyte_staging/website_overview/2022_04_22_1650593030082_25097833-886a-4e2f-972b-9205d44505b5.csv with id _h7B2nIRC...sQePrUg--]: Completed
2022-04-22 02:07:51 destination > 2022-04-22 02:07:51 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'website_overview'.
2022-04-22 02:07:51 destination > 2022-04-22 02:07:51 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: googleanalytic
2022-04-22 02:07:51 destination > 2022-04-22 02:07:51 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: website_overview, schema: googleanalytic, tmp table name: _airbyte_tmp_wpz_website_overview.
2022-04-22 02:07:51 destination > 2022-04-22 02:07:51 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_wpz_website_overview in destination for stream: website_overview, schema: googleanalytic, .
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_wpz_website_overview in destination for stream website_overview complete.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_website_overview in destination.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_wpz_website_overview in destination prepared.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_wpz_website_overview to dest table: _airbyte_raw_website_overview, schema: googleanalytic, in destination.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: googleanalytic
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: user__gender, schema: googleanalytic, tmp table name: _airbyte_tmp_oct_user__gender.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_oct_user__gender in destination for stream: user__gender, schema: googleanalytic, .
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_oct_user__gender in destination for stream user__gender complete.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_user__gender in destination.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_oct_user__gender in destination prepared.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_oct_user__gender to dest table: _airbyte_raw_user__gender, schema: googleanalytic, in destination.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.r.RedshiftSqlOperations(onDestinationCloseOperations):110 - Executing operations for Redshift Destination DB engine...
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.r.RedshiftSqlOperations(discoverNotSuperTables):129 - Discovering NOT SUPER table types...
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 ERROR i.a.i.d.r.RedshiftSqlOperations(discoverNotSuperTables):146 - Error during discoverNotSuperTables() appears: 
2022-04-22 02:07:52 destination > java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:52 destination > Position: 20;
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:52 destination > 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-04-22 02:07:52 destination > 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-04-22 02:07:52 destination > 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-04-22 02:07:52 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:52 destination > Position: 20;
2022-04-22 02:07:52 destination > 	... 13 more
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_iqv_users__age tmp table in destination.
2022-04-22 02:07:52 destination > 2022-04-22 02:07:52 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_iqv_users__age tmp table in destination cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):201 - S3 staging file airbyte_staging/locations/2022_04_22_1650593030056_c291aef3-5cd0-45fb-8207-47b4a490af4f.csv cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_aso_locations tmp table in destination.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_aso_locations tmp table in destination cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):106 - Begin cleaning s3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/cea5bf69-8ad0-4125-b727-4c9f06840416.manifest.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):110 - S3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/cea5bf69-8ad0-4125-b727-4c9f06840416.manifest cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):201 - S3 staging file airbyte_staging/devices/2022_04_22_1650593030054_5fa4f9ab-ae16-4614-baa7-55c5535f2dc3.csv cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_bqu_devices tmp table in destination.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_bqu_devices tmp table in destination cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):106 - Begin cleaning s3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/f4bd963a-fc9a-4d43-9818-acdd38e87488.manifest.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):110 - S3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/f4bd963a-fc9a-4d43-9818-acdd38e87488.manifest cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):201 - S3 staging file airbyte_staging/traffic_sources/2022_04_22_1650593030081_b84d5100-0a3b-4f42-9b2b-6c371039f983.csv cleaned.
2022-04-22 02:07:53 destination > 2022-04-22 02:07:53 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_xmr_traffic_sources tmp table in destination.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_xmr_traffic_sources tmp table in destination cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):106 - Begin cleaning s3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/c88325db-91ba-49ff-bf2a-87192c2c2aeb.manifest.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):110 - S3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/c88325db-91ba-49ff-bf2a-87192c2c2aeb.manifest cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):201 - S3 staging file airbyte_staging/pages/2022_04_22_1650593030057_61f5a0f6-085b-481e-b810-b2e625e8e5d4.csv cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_aaw_pages tmp table in destination.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_aaw_pages tmp table in destination cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):106 - Begin cleaning s3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/ceb56a66-322c-430f-8e6e-e802a453496c.manifest.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):110 - S3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/ceb56a66-322c-430f-8e6e-e802a453496c.manifest cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):201 - S3 staging file airbyte_staging/website_overview/2022_04_22_1650593030082_25097833-886a-4e2f-972b-9205d44505b5.csv cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_wpz_website_overview tmp table in destination.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_wpz_website_overview tmp table in destination cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):106 - Begin cleaning s3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/e00670c4-c184-4027-b2a8-072bf90bc64f.manifest.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.r.RedshiftStreamCopier(removeFileAndDropTmpTable):110 - S3 manifest file airbyte_staging/06a04ca5-b6e4-4b97-b1ce-31abad889e65/googleanalytic/e00670c4-c184-4027-b2a8-072bf90bc64f.manifest cleaned.
2022-04-22 02:07:54 destination > 2022-04-22 02:07:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_oct_user__gender tmp table in destination.
2022-04-22 02:07:55 destination > 2022-04-22 02:07:55 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):207 - _airbyte_tmp_oct_user__gender tmp table in destination cleaned.
2022-04-22 02:07:55 destination > Exception in thread "main" java.lang.RuntimeException: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:55 destination > Position: 20;
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.discoverNotSuperTables(RedshiftSqlOperations.java:147)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.lambda$onDestinationCloseOperations$0(RedshiftSqlOperations.java:113)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:273)
2022-04-22 02:07:55 destination > 	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622)
2022-04-22 02:07:55 destination > 	at java.base/java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.onDestinationCloseOperations(RedshiftSqlOperations.java:114)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.closeAsOneTransaction(CopyConsumerFactory.java:160)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.lambda$onCloseFunction$3(CopyConsumerFactory.java:126)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.OnCloseFunction.accept(OnCloseFunction.java:9)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:182)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.lambda$close$0(FailureTrackingAirbyteMessageConsumer.java:67)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:164)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105)
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71)
2022-04-22 02:07:55 destination > Caused by: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:55 destination > Position: 20;
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source)
2022-04-22 02:07:55 destination > 2022-04-22 02:07:55 ERROR i.a.i.d.b.BufferedStreamConsumer(close):191 - Close failed.
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source)
2022-04-22 02:07:55 destination > 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2022-04-22 02:07:55 destination > 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
2022-04-22 02:07:55 destination > 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
2022-04-22 02:07:55 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:55 destination > Position: 20;
2022-04-22 02:07:55 destination > 	... 13 more
2022-04-22 02:07:55 destination > java.lang.RuntimeException: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:55 destination > Position: 20;
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.discoverNotSuperTables(RedshiftSqlOperations.java:147) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.lambda$onDestinationCloseOperations$0(RedshiftSqlOperations.java:113) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:273) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1707) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627) ~[?:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftSqlOperations.onDestinationCloseOperations(RedshiftSqlOperations.java:114) ~[io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.closeAsOneTransaction(CopyConsumerFactory.java:160) ~[io.airbyte.airbyte-integrations.connectors-destination-jdbc-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.jdbc.copy.CopyConsumerFactory.lambda$onCloseFunction$3(CopyConsumerFactory.java:126) ~[io.airbyte.airbyte-integrations.connectors-destination-jdbc-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.OnCloseFunction.accept(OnCloseFunction.java:9) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.close(BufferedStreamConsumer.java:182) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.lambda$close$0(FailureTrackingAirbyteMessageConsumer.java:67) ~[io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.sentry.AirbyteSentry.executeWithTracing(AirbyteSentry.java:54) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.close(FailureTrackingAirbyteMessageConsumer.java:67) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:164) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:105) [io.airbyte.airbyte-integrations.bases-base-java-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > 	at io.airbyte.integrations.destination.redshift.RedshiftDestination.main(RedshiftDestination.java:71) [io.airbyte.airbyte-integrations.connectors-destination-redshift-0.36.1-alpha.jar:?]
2022-04-22 02:07:55 destination > Caused by: java.sql.SQLException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:55 destination > Position: 20;
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-04-22 02:07:55 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: syntax error at or near "null" 
2022-04-22 02:07:55 destination > Position: 20;
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078]
2022-04-22 02:07:55 destination > 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
2022-04-22 02:07:55 destination > 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
2022-04-22 02:07:55 ERROR i.a.w.DefaultReplicationWorker(run):168 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:163) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:125) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:56) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:352) ~[io.airbyte-airbyte-workers-0.35.30-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-04-22 02:07:55 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@538dd301[status=failed,recordsSynced=3658,bytesSynced=1389521,startTime=1650592977894,endTime=1650593275888,totalStats=io.airbyte.config.SyncStats@144a87bf[recordsEmitted=3658,bytesEmitted=1389521,stateMessagesEmitted=3938,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@55319b24[streamName=pages,stats=io.airbyte.config.SyncStats@6c093fbd[recordsEmitted=1906,bytesEmitted=732901,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@51a1ece6[streamName=devices,stats=io.airbyte.config.SyncStats@1116ee12[recordsEmitted=557,bytesEmitted=195012,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@4827afaf[streamName=traffic_sources,stats=io.airbyte.config.SyncStats@6d7685c1[recordsEmitted=367,bytesEmitted=128925,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@33ee8255[streamName=locations,stats=io.airbyte.config.SyncStats@15ae8c44[recordsEmitted=716,bytesEmitted=298882,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@60811389[streamName=website_overview,stats=io.airbyte.config.SyncStats@3980dad5[recordsEmitted=112,bytesEmitted=33801,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-22 02:07:55 INFO i.a.w.DefaultReplicationWorker(run):247 - Source output at least one state message
2022-04-22 02:07:55 WARN i.a.w.DefaultReplicationWorker(run):260 - State capture: No state retained.
2022-04-22 02:07:55 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-22 02:07:55 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):144 - sync summary: io.airbyte.config.StandardSyncOutput@5cee8ca4[standardSyncSummary=io.airbyte.config.StandardSyncSummary@63551851[status=failed,recordsSynced=3658,bytesSynced=1389521,startTime=1650592977894,endTime=1650593275888,totalStats=io.airbyte.config.SyncStats@144a87bf[recordsEmitted=3658,bytesEmitted=1389521,stateMessagesEmitted=3938,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@55319b24[streamName=pages,stats=io.airbyte.config.SyncStats@6c093fbd[recordsEmitted=1906,bytesEmitted=732901,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@51a1ece6[streamName=devices,stats=io.airbyte.config.SyncStats@1116ee12[recordsEmitted=557,bytesEmitted=195012,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@4827afaf[streamName=traffic_sources,stats=io.airbyte.config.SyncStats@6d7685c1[recordsEmitted=367,bytesEmitted=128925,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@33ee8255[streamName=locations,stats=io.airbyte.config.SyncStats@15ae8c44[recordsEmitted=716,bytesEmitted=298882,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@60811389[streamName=website_overview,stats=io.airbyte.config.SyncStats@3980dad5[recordsEmitted=112,bytesEmitted=33801,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7bad3cc2[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@31a75f83[stream=io.airbyte.protocol.models.AirbyteStream@19047ebf[name=devices,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_browser":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_deviceCategory":{"type":["string"]},"ga_operatingSystem":{"type":["string"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_browser], [ga_date], [ga_deviceCategory], [ga_operatingSystem], [view_id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@52d87a5e[stream=io.airbyte.protocol.models.AirbyteStream@408117eb[name=locations,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_city":{"type":["string"]},"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_metro":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_region":{"type":["string"]},"ga_country":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_continent":{"type":["string"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_subContinent":{"type":["string"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_city], [ga_continent], [ga_country], [ga_date], [ga_metro], [ga_region], [view_id], [ga_subContinent]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4bd1033f[stream=io.airbyte.protocol.models.AirbyteStream@711a7d7c[name=pages,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_exits":{"type":["null","integer"]},"ga_exitRate":{"type":["null","number"]},"ga_hostname":{"type":["string"]},"ga_pagePath":{"type":["string"]},"ga_entrances":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_entranceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_uniquePageviews":{"type":["null","integer"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_date], [ga_hostname], [ga_pagePath], [view_id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6081f38b[stream=io.airbyte.protocol.models.AirbyteStream@28f79e3f[name=traffic_sources,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_medium":{"type":["string"]},"ga_source":{"type":["string"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_socialNetwork":{"type":["string"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_date], [ga_medium], [ga_socialNetwork], [view_id], [ga_source]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6bfcb8e5[stream=io.airbyte.protocol.models.AirbyteStream@49afd97b[name=user__gender,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_newUsers":{"type":["null","integer"]},"ga_userGender":{"type":["string"]},"ga_visitorGender":{"type":["string"]},"ga_userAgeBracket":{"type":["string"]},"ga_visitorAgeBracket":{"type":["string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@265d766e[stream=io.airbyte.protocol.models.AirbyteStream@324f12fc[name=users__age,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_newUsers":{"type":["null","integer"]},"ga_userGender":{"type":["string"]},"ga_visitorGender":{"type":["string"]},"ga_userAgeBracket":{"type":["string"]},"ga_visitorAgeBracket":{"type":["string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3cfabfc0[stream=io.airbyte.protocol.models.AirbyteStream@b29cd25[name=website_overview,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_users":{"type":["null","integer"]},"ga_exitRate":{"type":["null","number"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_date], [view_id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@460a2428[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@c9816e7[additionalProperties={attemptNumber=2, jobId=98}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:352)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1650593275887]]]
2022-04-22 02:07:55 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):234 - Stopping temporal heartbeating...
2022-04-22 02:07:57 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/98/2/logs.log
2022-04-22 02:07:57 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.30-alpha
2022-04-22 02:07:57 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-04-22 02:07:57 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.66
2022-04-22 02:07:57 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.66 exists...
2022-04-22 02:07:58 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.66 was found locally.
2022-04-22 02:07:58 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/98/2/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization:0.1.66 run --integration-type redshift --config destination_config.json --catalog destination_catalog.json
2022-04-22 02:08:02 normalization > Running: transform-config --config destination_config.json --integration-type redshift --out /data/98/2/normalize
2022-04-22 02:08:04 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.redshift: 'redshift'>, out='/data/98/2/normalize')
2022-04-22 02:08:04 normalization > transform_redshift
2022-04-22 02:08:04 normalization > Running: transform-catalog --integration-type redshift --profile-config-dir /data/98/2/normalize --catalog destination_catalog.json --out /data/98/2/normalize/models/generated/ --json-column _airbyte_data
2022-04-22 02:08:06 normalization > Processing destination_catalog.json...
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/devices_ab1.sql from devices
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/devices_ab2.sql from devices
2022-04-22 02:08:06 normalization >   Generating airbyte_views/googleanalytic/devices_stg.sql from devices
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/scd/googleanalytic/devices_scd.sql from devices
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/googleanalytic/devices.sql from devices
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/locations_ab1.sql from locations
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/locations_ab2.sql from locations
2022-04-22 02:08:06 normalization >   Generating airbyte_views/googleanalytic/locations_stg.sql from locations
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/scd/googleanalytic/locations_scd.sql from locations
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/googleanalytic/locations.sql from locations
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/pages_ab1.sql from pages
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/pages_ab2.sql from pages
2022-04-22 02:08:06 normalization >   Generating airbyte_views/googleanalytic/pages_stg.sql from pages
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/scd/googleanalytic/pages_scd.sql from pages
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/googleanalytic/pages.sql from pages
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/traffic_sources_ab1.sql from traffic_sources
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/traffic_sources_ab2.sql from traffic_sources
2022-04-22 02:08:06 normalization >   Generating airbyte_views/googleanalytic/traffic_sources_stg.sql from traffic_sources
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/scd/googleanalytic/traffic_sources_scd.sql from traffic_sources
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/googleanalytic/traffic_sources.sql from traffic_sources
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/user__gender_ab1.sql from user__gender
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/user__gender_ab2.sql from user__gender
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/user__gender_ab3.sql from user__gender
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/googleanalytic/user__gender.sql from user__gender
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/users__age_ab1.sql from users__age
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/users__age_ab2.sql from users__age
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/users__age_ab3.sql from users__age
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/googleanalytic/users__age.sql from users__age
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/website_overview_ab1.sql from website_overview
2022-04-22 02:08:06 normalization >   Generating airbyte_ctes/googleanalytic/website_overview_ab2.sql from website_overview
2022-04-22 02:08:06 normalization >   Generating airbyte_views/googleanalytic/website_overview_stg.sql from website_overview
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/scd/googleanalytic/website_overview_scd.sql from website_overview
2022-04-22 02:08:06 normalization >   Generating airbyte_incremental/googleanalytic/website_overview.sql from website_overview
2022-04-22 02:08:06 normalization > detected no config file for ssh, assuming ssh is off.
2022-04-22 02:08:31 normalization > Running with dbt=0.21.1
2022-04-22 02:08:35 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found
2022-04-22 02:09:03 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-04-22 02:09:03 normalization > There are 1 unused configuration paths:
2022-04-22 02:09:03 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-04-22 02:09:03 normalization > 
2022-04-22 02:09:04 normalization > Found 33 models, 0 tests, 0 snapshots, 0 analyses, 520 macros, 0 operations, 0 seed files, 7 sources, 0 exposures
2022-04-22 02:09:04 normalization > 
2022-04-22 02:09:05 normalization > 02:09:05 | Concurrency: 4 threads (target='prod')
2022-04-22 02:09:05 normalization > 02:09:05 | 
2022-04-22 02:09:09 normalization > 02:09:09 | 1 of 17 START view model _airbyte_googleanalytic.locations_stg............................................... [RUN]
2022-04-22 02:09:10 normalization > 02:09:10 | 2 of 17 START view model _airbyte_googleanalytic.devices_stg................................................. [RUN]
2022-04-22 02:09:10 normalization > 02:09:10 | 3 of 17 START view model _airbyte_googleanalytic.pages_stg................................................... [RUN]
2022-04-22 02:09:11 normalization > 02:09:11 | 4 of 17 START view model _airbyte_googleanalytic.traffic_sources_stg......................................... [RUN]
2022-04-22 02:09:15 normalization > 02:09:15 | 2 of 17 OK created view model _airbyte_googleanalytic.devices_stg............................................ [CREATE VIEW in 5.27s]
2022-04-22 02:09:15 normalization > 02:09:15 | 1 of 17 OK created view model _airbyte_googleanalytic.locations_stg.......................................... [CREATE VIEW in 6.18s]
2022-04-22 02:09:15 normalization > 02:09:15 | 5 of 17 START view model _airbyte_googleanalytic.website_overview_stg........................................ [RUN]
2022-04-22 02:09:16 normalization > 02:09:16 | 3 of 17 OK created view model _airbyte_googleanalytic.pages_stg.............................................. [CREATE VIEW in 5.55s]
2022-04-22 02:09:16 normalization > 02:09:16 | 6 of 17 START incremental model googleanalytic.devices_scd................................................... [RUN]
2022-04-22 02:09:16 normalization > 02:09:16 | 7 of 17 START incremental model googleanalytic.locations_scd................................................. [RUN]
2022-04-22 02:09:16 normalization > 02:09:16 | 4 of 17 OK created view model _airbyte_googleanalytic.traffic_sources_stg.................................... [CREATE VIEW in 5.69s]
2022-04-22 02:09:16 normalization > 02:09:16 | 8 of 17 START incremental model googleanalytic.users__age.................................................... [RUN]
2022-04-22 02:09:17 normalization > 02:09:17 | 5 of 17 OK created view model _airbyte_googleanalytic.website_overview_stg................................... [CREATE VIEW in 1.75s]
2022-04-22 02:09:17 normalization > 02:09:17 | 9 of 17 START incremental model googleanalytic.pages_scd..................................................... [RUN]
2022-04-22 02:09:24 normalization > 02:09:24 | 8 of 17 OK created incremental model googleanalytic.users__age............................................... [INSERT 0 3 in 7.51s]
2022-04-22 02:09:24 normalization > 02:09:24 | 10 of 17 START incremental model googleanalytic.user__gender................................................. [RUN]
2022-04-22 02:09:29 normalization > 02:09:29 | 6 of 17 OK created incremental model googleanalytic.devices_scd.............................................. [INSERT 0 3 in 13.60s]
2022-04-22 02:09:29 normalization > 02:09:29 | 11 of 17 START incremental model googleanalytic.traffic_sources_scd.......................................... [RUN]
2022-04-22 02:09:30 normalization > 02:09:30 | 10 of 17 OK created incremental model googleanalytic.user__gender............................................ [INSERT 0 1 in 5.90s]
2022-04-22 02:09:30 normalization > 02:09:30 | 9 of 17 OK created incremental model googleanalytic.pages_scd................................................ [INSERT 0 2 in 12.71s]
2022-04-22 02:09:30 normalization > 02:09:30 | 12 of 17 START incremental model googleanalytic.website_overview_scd......................................... [RUN]
2022-04-22 02:09:30 normalization > 02:09:30 | 13 of 17 START incremental model googleanalytic.devices...................................................... [RUN]
2022-04-22 02:09:30 normalization > 02:09:30 | 7 of 17 OK created incremental model googleanalytic.locations_scd............................................ [INSERT 0 1 in 13.99s]
2022-04-22 02:09:30 normalization > 02:09:30 | 14 of 17 START incremental model googleanalytic.pages........................................................ [RUN]
2022-04-22 02:09:36 normalization > 02:09:36 | 13 of 17 OK created incremental model googleanalytic.devices................................................. [INSERT 0 8 in 6.16s]
2022-04-22 02:09:36 normalization > 02:09:36 | 15 of 17 START incremental model googleanalytic.locations.................................................... [RUN]
2022-04-22 02:09:36 normalization > 02:09:36 | 14 of 17 OK created incremental model googleanalytic.pages................................................... [INSERT 0 6 in 6.38s]
2022-04-22 02:09:40 normalization > 02:09:40 | 12 of 17 OK created incremental model googleanalytic.website_overview_scd.................................... [INSERT 0 1 in 10.45s]
2022-04-22 02:09:40 normalization > 02:09:40 | 16 of 17 START incremental model googleanalytic.website_overview............................................. [RUN]
2022-04-22 02:09:41 normalization > 02:09:41 | 15 of 17 OK created incremental model googleanalytic.locations............................................... [INSERT 0 2 in 5.15s]
2022-04-22 02:09:41 normalization > 02:09:41 | 11 of 17 OK created incremental model googleanalytic.traffic_sources_scd..................................... [INSERT 0 1 in 11.84s]
2022-04-22 02:09:41 normalization > 02:09:41 | 17 of 17 START incremental model googleanalytic.traffic_sources.............................................. [RUN]
2022-04-22 02:09:44 normalization > 02:09:44 | 16 of 17 OK created incremental model googleanalytic.website_overview........................................ [INSERT 0 2 in 3.41s]
2022-04-22 02:09:44 normalization > 02:09:44 | 17 of 17 OK created incremental model googleanalytic.traffic_sources......................................... [INSERT 0 2 in 3.16s]
2022-04-22 02:09:45 normalization > 02:09:45 | 
2022-04-22 02:09:45 normalization > 02:09:45 | Finished running 5 view models, 12 incremental models in 40.95s.
2022-04-22 02:09:45 normalization > 
2022-04-22 02:09:45 normalization > Completed successfully
2022-04-22 02:09:45 normalization > 
2022-04-22 02:09:45 normalization > Done. PASS=17 WARN=0 ERROR=0 SKIP=0 TOTAL=17
2022-04-22 02:09:47 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 1 minute 49 seconds.
2022-04-22 02:09:47 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-22 02:09:47 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):234 - Stopping temporal heartbeating...