2023-03-01 00:36:02 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-03-01 00:36:02 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:36:02 INFO i.a.w.g.DefaultReplicationWorker(run):167 - configured sync modes: {null.campaign_performance=incremental - append_dedup, null.payment_id_channel=incremental - append_dedup, null.browser_and_operating_system_overview=incremental - append_dedup, null.channel_traffic=incremental - append_dedup, null.traffic=incremental - append_dedup, null.social_media_acquisitions=incremental - append_dedup, null.audience_overview=incremental - append_dedup}
2023-03-01 00:36:02 INFO i.a.w.i.DefaultAirbyteDestination(start):84 - Running destination...
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-03-01 00:36:02 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-snowflake:0.4.49 exists...
2023-03-01 00:36:02 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-snowflake:0.4.49 was found locally.
2023-03-01 00:36:02 INFO i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-snowflake-write-4629-0-zyswv with resources io.airbyte.config.ResourceRequirements@75301b54[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-03-01 00:36:02 INFO i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/4629/0 --log-driver none --name destination-snowflake-write-4629-0-zyswv --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=CLOUD -e STRICT_COMPARISON_NORMALIZATION_WORKSPACES= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.49 -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e STRICT_COMPARISON_NORMALIZATION_TAG=strict_comparison2 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=false -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=0 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.41.0 -e WORKER_JOB_ID=4629 airbyte/destination-snowflake:0.4.49 write --config destination_config.json --catalog destination_catalog.json
2023-03-01 00:36:02 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):38 - Writing messages to protocol version 0.2.0
2023-03-01 00:36:02 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-03-01 00:36:02 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-03-01 00:36:02 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-google-analytics-v4:0.1.34 exists...
2023-03-01 00:36:02 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-google-analytics-v4:0.1.34 was found locally.
2023-03-01 00:36:02 INFO i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-google-analytics-v4-read-4629-0-gxiof with resources io.airbyte.config.ResourceRequirements@31d1c7a0[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-03-01 00:36:02 INFO i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/4629/0 --log-driver none --name source-google-analytics-v4-read-4629-0-gxiof --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=CLOUD -e STRICT_COMPARISON_NORMALIZATION_WORKSPACES= -e WORKER_CONNECTOR_IMAGE=airbyte/source-google-analytics-v4:0.1.34 -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e STRICT_COMPARISON_NORMALIZATION_TAG=strict_comparison2 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=false -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=0 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.41.0 -e WORKER_JOB_ID=4629 airbyte/source-google-analytics-v4:0.1.34 read --config source_config.json --catalog source_catalog.json --state input_state.json
2023-03-01 00:36:02 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0
2023-03-01 00:36:02 INFO i.a.w.g.DefaultReplicationWorker(replicate):247 - Waiting for source and destination threads to complete.
2023-03-01 00:36:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):275 - Destination output thread started.
2023-03-01 00:36:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):337 - Replication thread started.
2023-03-01 00:36:02 source > Starting syncing SourceGoogleAnalyticsV4
2023-03-01 00:36:02 destination > INFO i.a.i.b.a.AdaptiveDestinationRunner$Runner(getDestination):74 Running destination under deployment mode: CLOUD
2023-03-01 00:36:03 destination > INFO i.a.i.b.a.AdaptiveDestinationRunner$Runner(run):86 Starting destination: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:36:03 destination > INFO i.a.i.b.IntegrationCliParser(parseOptions):126 integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2023-03-01 00:36:03 destination > INFO i.a.i.b.IntegrationRunner(runInternal):105 Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:36:03 destination > INFO i.a.i.b.IntegrationRunner(runInternal):106 Command: WRITE
2023-03-01 00:36:03 destination > INFO i.a.i.b.IntegrationRunner(runInternal):107 Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2023-03-01 00:36:03 destination > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-03-01 00:36:03 destination > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-03-01 00:36:03 destination > INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 Using destination type: INTERNAL_STAGING
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):117 Write config: WriteConfig{streamName=audience_overview, namespace=null, outputSchemaName=GOOGLE_ANALYTICS, tmpTableName=_airbyte_tmp_lnr_audience_overview, outputTableName=_airbyte_raw_audience_overview, syncMode=append_dedup}
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):117 Write config: WriteConfig{streamName=browser_and_operating_system_overview, namespace=null, outputSchemaName=GOOGLE_ANALYTICS, tmpTableName=_airbyte_tmp_fmb_browser_and_operating_system_overview, outputTableName=_airbyte_raw_browser_and_operating_system_overview, syncMode=append_dedup}
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):117 Write config: WriteConfig{streamName=campaign_performance, namespace=null, outputSchemaName=GOOGLE_ANALYTICS, tmpTableName=_airbyte_tmp_hmd_campaign_performance, outputTableName=_airbyte_raw_campaign_performance, syncMode=append_dedup}
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):117 Write config: WriteConfig{streamName=channel_traffic, namespace=null, outputSchemaName=GOOGLE_ANALYTICS, tmpTableName=_airbyte_tmp_vvn_channel_traffic, outputTableName=_airbyte_raw_channel_traffic, syncMode=append_dedup}
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):117 Write config: WriteConfig{streamName=payment_id_channel, namespace=null, outputSchemaName=GOOGLE_ANALYTICS, tmpTableName=_airbyte_tmp_rjo_payment_id_channel, outputTableName=_airbyte_raw_payment_id_channel, syncMode=append_dedup}
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):117 Write config: WriteConfig{streamName=social_media_acquisitions, namespace=null, outputSchemaName=GOOGLE_ANALYTICS, tmpTableName=_airbyte_tmp_gac_social_media_acquisitions, outputTableName=_airbyte_raw_social_media_acquisitions, syncMode=append_dedup}
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):117 Write config: WriteConfig{streamName=traffic, namespace=null, outputSchemaName=GOOGLE_ANALYTICS, tmpTableName=_airbyte_tmp_ksh_traffic, outputTableName=_airbyte_raw_traffic, syncMode=append_dedup}
2023-03-01 00:36:03 destination > INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):118 class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):135 Preparing raw tables in destination started for 7 streams
2023-03-01 00:36:03 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):144 Preparing staging area in destination started for schema GOOGLE_ANALYTICS stream audience_overview: target table: _airbyte_raw_audience_overview, stage: 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/
2023-03-01 00:36:03 destination > INFO c.z.h.HikariDataSource(getConnection):110 HikariPool-1 - Starting...
2023-03-01 00:36:04 source > Syncing stream: audience_overview 
2023-03-01 00:36:04 destination > INFO c.z.h.p.HikariPool(checkFailFast):565 HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@7f9fc8bd
2023-03-01 00:36:04 destination > INFO c.z.h.HikariDataSource(getConnection):123 HikariPool-1 - Start completed.
2023-03-01 00:36:04 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:36:05 source > Google Analytics data is not golden. Future requests may return different data.
2023-03-01 00:36:05 source > Read 3 records from audience_overview stream
2023-03-01 00:36:05 source > Finished syncing audience_overview
2023-03-01 00:36:05 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream audience_overview 0:00:00.594878
2023-03-01 00:36:05 source > Syncing stream: browser_and_operating_system_overview 
2023-03-01 00:36:05 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):161 Preparing staging area in destination completed for schema GOOGLE_ANALYTICS stream audience_overview
2023-03-01 00:36:05 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):144 Preparing staging area in destination started for schema GOOGLE_ANALYTICS stream browser_and_operating_system_overview: target table: _airbyte_raw_browser_and_operating_system_overview, stage: 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/
2023-03-01 00:36:05 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:36:05 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):161 Preparing staging area in destination completed for schema GOOGLE_ANALYTICS stream browser_and_operating_system_overview
2023-03-01 00:36:05 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):144 Preparing staging area in destination started for schema GOOGLE_ANALYTICS stream campaign_performance: target table: _airbyte_raw_campaign_performance, stage: 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/
2023-03-01 00:36:05 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:36:05 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):161 Preparing staging area in destination completed for schema GOOGLE_ANALYTICS stream campaign_performance
2023-03-01 00:36:05 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):144 Preparing staging area in destination started for schema GOOGLE_ANALYTICS stream channel_traffic: target table: _airbyte_raw_channel_traffic, stage: 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/
2023-03-01 00:36:05 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:36:05 source > Google Analytics data is not golden. Future requests may return different data.
2023-03-01 00:36:05 source > Read 116 records from browser_and_operating_system_overview stream
2023-03-01 00:36:05 source > Finished syncing browser_and_operating_system_overview
2023-03-01 00:36:05 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream audience_overview 0:00:00.594878
Syncing stream browser_and_operating_system_overview 0:00:00.924450
2023-03-01 00:36:05 source > Syncing stream: campaign_performance 
2023-03-01 00:36:06 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):161 Preparing staging area in destination completed for schema GOOGLE_ANALYTICS stream channel_traffic
2023-03-01 00:36:06 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):144 Preparing staging area in destination started for schema GOOGLE_ANALYTICS stream payment_id_channel: target table: _airbyte_raw_payment_id_channel, stage: 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/
2023-03-01 00:36:06 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:36:06 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):161 Preparing staging area in destination completed for schema GOOGLE_ANALYTICS stream payment_id_channel
2023-03-01 00:36:06 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):144 Preparing staging area in destination started for schema GOOGLE_ANALYTICS stream social_media_acquisitions: target table: _airbyte_raw_social_media_acquisitions, stage: 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/
2023-03-01 00:36:06 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:36:06 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):161 Preparing staging area in destination completed for schema GOOGLE_ANALYTICS stream social_media_acquisitions
2023-03-01 00:36:06 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):144 Preparing staging area in destination started for schema GOOGLE_ANALYTICS stream traffic: target table: _airbyte_raw_traffic, stage: 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/
2023-03-01 00:36:06 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:36:07 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):161 Preparing staging area in destination completed for schema GOOGLE_ANALYTICS stream traffic
2023-03-01 00:36:07 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$1):163 Executing finalization of tables.
2023-03-01 00:36:08 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):76 Starting a new buffer for stream audience_overview (current state: 0 bytes in 0 buffers)
2023-03-01 00:36:08 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):76 Starting a new buffer for stream browser_and_operating_system_overview (current state: 0 bytes in 1 buffers)
2023-03-01 00:36:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 1000 (168 KB)
2023-03-01 00:36:08 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):76 Starting a new buffer for stream campaign_performance (current state: 0 bytes in 2 buffers)
2023-03-01 00:36:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 2000 (327 KB)
2023-03-01 00:36:08 source > Google Analytics data is not golden. Future requests may return different data.
2023-03-01 00:36:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 3000 (485 KB)
2023-03-01 00:36:08 source > Read 1473 records from campaign_performance stream
2023-03-01 00:36:08 source > Finished syncing campaign_performance
2023-03-01 00:36:08 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream audience_overview 0:00:00.594878
Syncing stream browser_and_operating_system_overview 0:00:00.924450
Syncing stream campaign_performance 0:00:01.967576
2023-03-01 00:36:08 source > Syncing stream: channel_traffic 
2023-03-01 00:36:08 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):76 Starting a new buffer for stream channel_traffic (current state: 82 KB in 3 buffers)
2023-03-01 00:36:08 source > Google Analytics data is not golden. Future requests may return different data.
2023-03-01 00:36:08 source > Read 24 records from channel_traffic stream
2023-03-01 00:36:08 source > Finished syncing channel_traffic
2023-03-01 00:36:08 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream audience_overview 0:00:00.594878
Syncing stream browser_and_operating_system_overview 0:00:00.924450
Syncing stream campaign_performance 0:00:01.967576
Syncing stream channel_traffic 0:00:00.820344
2023-03-01 00:36:08 source > Syncing stream: payment_id_channel 
2023-03-01 00:36:17 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):76 Starting a new buffer for stream payment_id_channel (current state: 82 KB in 4 buffers)
2023-03-01 00:36:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 4000 (589 KB)
2023-03-01 00:36:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 5000 (677 KB)
2023-03-01 00:36:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 6000 (766 KB)
2023-03-01 00:36:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 7000 (854 KB)
2023-03-01 00:36:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 8000 (943 KB)
2023-03-01 00:36:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 9000 (1 MB)
2023-03-01 00:36:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 10000 (1 MB)
2023-03-01 00:36:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 11000 (1 MB)
2023-03-01 00:36:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 12000 (1 MB)
2023-03-01 00:36:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 13000 (1 MB)
2023-03-01 00:36:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 14000 (1 MB)
2023-03-01 00:36:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 15000 (1 MB)
2023-03-01 00:36:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 16000 (1 MB)
2023-03-01 00:36:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 17000 (1 MB)
2023-03-01 00:36:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 18000 (1 MB)
2023-03-01 00:36:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 19000 (1 MB)
2023-03-01 00:36:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 20000 (1 MB)
2023-03-01 00:36:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 21000 (2 MB)
2023-03-01 00:36:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 22000 (2 MB)
2023-03-01 00:36:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 23000 (2 MB)
2023-03-01 00:36:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 24000 (2 MB)
2023-03-01 00:36:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 25000 (2 MB)
2023-03-01 00:36:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 26000 (2 MB)
2023-03-01 00:36:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 27000 (2 MB)
2023-03-01 00:36:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 28000 (2 MB)
2023-03-01 00:36:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 29000 (2 MB)
2023-03-01 00:36:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 30000 (2 MB)
2023-03-01 00:36:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 31000 (2 MB)
2023-03-01 00:36:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 32000 (2 MB)
2023-03-01 00:36:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 33000 (3 MB)
2023-03-01 00:36:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 34000 (3 MB)
2023-03-01 00:36:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 35000 (3 MB)
2023-03-01 00:36:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 36000 (3 MB)
2023-03-01 00:36:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 37000 (3 MB)
2023-03-01 00:36:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 38000 (3 MB)
2023-03-01 00:36:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 39000 (3 MB)
2023-03-01 00:36:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 40000 (3 MB)
2023-03-01 00:36:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 41000 (3 MB)
2023-03-01 00:36:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 42000 (3 MB)
2023-03-01 00:36:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 43000 (3 MB)
2023-03-01 00:36:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 44000 (4 MB)
2023-03-01 00:36:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 45000 (4 MB)
2023-03-01 00:36:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 46000 (4 MB)
2023-03-01 00:36:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 47000 (4 MB)
2023-03-01 00:36:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 48000 (4 MB)
2023-03-01 00:36:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 49000 (4 MB)
2023-03-01 00:36:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 50000 (4 MB)
2023-03-01 00:36:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 51000 (4 MB)
2023-03-01 00:36:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 52000 (4 MB)
2023-03-01 00:36:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 53000 (4 MB)
2023-03-01 00:36:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 54000 (4 MB)
2023-03-01 00:36:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 55000 (4 MB)
2023-03-01 00:36:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 56000 (5 MB)
2023-03-01 00:36:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 57000 (5 MB)
2023-03-01 00:36:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 58000 (5 MB)
2023-03-01 00:36:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 59000 (5 MB)
2023-03-01 00:36:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 60000 (5 MB)
2023-03-01 00:36:30 source > Google Analytics data is not golden. Future requests may return different data.
2023-03-01 00:36:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 61000 (5 MB)
2023-03-01 00:36:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 62000 (5 MB)
2023-03-01 00:36:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 63000 (5 MB)
2023-03-01 00:36:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 64000 (5 MB)
2023-03-01 00:36:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 65000 (5 MB)
2023-03-01 00:36:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 66000 (5 MB)
2023-03-01 00:36:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 67000 (6 MB)
2023-03-01 00:36:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 68000 (6 MB)
2023-03-01 00:36:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 69000 (6 MB)
2023-03-01 00:36:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 70000 (6 MB)
2023-03-01 00:36:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 71000 (6 MB)
2023-03-01 00:36:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 72000 (6 MB)
2023-03-01 00:36:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 73000 (6 MB)
2023-03-01 00:36:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 74000 (6 MB)
2023-03-01 00:36:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 75000 (6 MB)
2023-03-01 00:36:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 76000 (6 MB)
2023-03-01 00:36:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 77000 (6 MB)
2023-03-01 00:36:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 78000 (6 MB)
2023-03-01 00:36:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 79000 (7 MB)
2023-03-01 00:36:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 80000 (7 MB)
2023-03-01 00:36:35 source > Read 38869 records from payment_id_channel stream
2023-03-01 00:36:35 source > Finished syncing payment_id_channel
2023-03-01 00:36:35 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream audience_overview 0:00:00.594878
Syncing stream browser_and_operating_system_overview 0:00:00.924450
Syncing stream campaign_performance 0:00:01.967576
Syncing stream channel_traffic 0:00:00.820344
Syncing stream payment_id_channel 0:00:26.348383
2023-03-01 00:36:35 source > Syncing stream: social_media_acquisitions 
2023-03-01 00:36:35 source > Google Analytics data is not golden. Future requests may return different data.
2023-03-01 00:36:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 81000 (7 MB)
2023-03-01 00:36:35 source > Read 13 records from social_media_acquisitions stream
2023-03-01 00:36:35 source > Finished syncing social_media_acquisitions
2023-03-01 00:36:35 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream audience_overview 0:00:00.594878
Syncing stream browser_and_operating_system_overview 0:00:00.924450
Syncing stream campaign_performance 0:00:01.967576
Syncing stream channel_traffic 0:00:00.820344
Syncing stream payment_id_channel 0:00:26.348383
Syncing stream social_media_acquisitions 0:00:00.731163
2023-03-01 00:36:35 source > Syncing stream: traffic 
2023-03-01 00:36:35 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):76 Starting a new buffer for stream social_media_acquisitions (current state: 1 MB in 5 buffers)
2023-03-01 00:36:41 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):76 Starting a new buffer for stream traffic (current state: 1 MB in 6 buffers)
2023-03-01 00:36:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 82000 (7 MB)
2023-03-01 00:36:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 83000 (7 MB)
2023-03-01 00:36:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 84000 (7 MB)
2023-03-01 00:36:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 85000 (7 MB)
2023-03-01 00:36:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 86000 (7 MB)
2023-03-01 00:36:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 87000 (8 MB)
2023-03-01 00:36:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 88000 (8 MB)
2023-03-01 00:36:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 89000 (8 MB)
2023-03-01 00:36:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 90000 (8 MB)
2023-03-01 00:36:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 91000 (8 MB)
2023-03-01 00:36:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 92000 (8 MB)
2023-03-01 00:36:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 93000 (8 MB)
2023-03-01 00:36:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 94000 (9 MB)
2023-03-01 00:36:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 95000 (9 MB)
2023-03-01 00:36:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 96000 (9 MB)
2023-03-01 00:36:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 97000 (9 MB)
2023-03-01 00:36:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 98000 (9 MB)
2023-03-01 00:36:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 99000 (9 MB)
2023-03-01 00:36:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 100000 (9 MB)
2023-03-01 00:36:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 101000 (10 MB)
2023-03-01 00:36:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 102000 (10 MB)
2023-03-01 00:36:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 103000 (10 MB)
2023-03-01 00:36:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 104000 (10 MB)
2023-03-01 00:36:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 105000 (10 MB)
2023-03-01 00:36:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 106000 (10 MB)
2023-03-01 00:36:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 107000 (10 MB)
2023-03-01 00:36:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 108000 (11 MB)
2023-03-01 00:36:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 109000 (11 MB)
2023-03-01 00:36:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 110000 (11 MB)
2023-03-01 00:36:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 111000 (11 MB)
2023-03-01 00:36:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 112000 (11 MB)
2023-03-01 00:36:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 113000 (11 MB)
2023-03-01 00:36:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 114000 (11 MB)
2023-03-01 00:36:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 115000 (12 MB)
2023-03-01 00:36:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 116000 (12 MB)
2023-03-01 00:36:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 117000 (12 MB)
2023-03-01 00:36:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 118000 (12 MB)
2023-03-01 00:36:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 119000 (12 MB)
2023-03-01 00:36:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 120000 (12 MB)
2023-03-01 00:36:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 121000 (12 MB)
2023-03-01 00:36:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 122000 (13 MB)
2023-03-01 00:36:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 123000 (13 MB)
2023-03-01 00:36:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 124000 (13 MB)
2023-03-01 00:36:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 125000 (13 MB)
2023-03-01 00:36:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 126000 (13 MB)
2023-03-01 00:36:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 127000 (13 MB)
2023-03-01 00:36:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 128000 (13 MB)
2023-03-01 00:36:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 129000 (13 MB)
2023-03-01 00:36:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 130000 (14 MB)
2023-03-01 00:36:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 131000 (14 MB)
2023-03-01 00:36:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 132000 (14 MB)
2023-03-01 00:36:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 133000 (14 MB)
2023-03-01 00:36:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 134000 (14 MB)
2023-03-01 00:36:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 135000 (14 MB)
2023-03-01 00:36:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 136000 (14 MB)
2023-03-01 00:36:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 137000 (15 MB)
2023-03-01 00:36:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 138000 (15 MB)
2023-03-01 00:36:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 139000 (15 MB)
2023-03-01 00:36:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 140000 (15 MB)
2023-03-01 00:36:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 141000 (15 MB)
2023-03-01 00:36:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 142000 (15 MB)
2023-03-01 00:36:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 143000 (15 MB)
2023-03-01 00:36:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 144000 (16 MB)
2023-03-01 00:36:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 145000 (16 MB)
2023-03-01 00:36:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 146000 (16 MB)
2023-03-01 00:36:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 147000 (16 MB)
2023-03-01 00:36:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 148000 (16 MB)
2023-03-01 00:36:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 149000 (16 MB)
2023-03-01 00:36:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 150000 (16 MB)
2023-03-01 00:36:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 151000 (17 MB)
2023-03-01 00:36:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 152000 (17 MB)
2023-03-01 00:36:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 153000 (17 MB)
2023-03-01 00:36:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 154000 (17 MB)
2023-03-01 00:36:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 155000 (17 MB)
2023-03-01 00:36:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 156000 (17 MB)
2023-03-01 00:36:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 157000 (17 MB)
2023-03-01 00:36:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 158000 (18 MB)
2023-03-01 00:36:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 159000 (18 MB)
2023-03-01 00:36:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 160000 (18 MB)
2023-03-01 00:36:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 161000 (18 MB)
2023-03-01 00:36:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 162000 (18 MB)
2023-03-01 00:36:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 163000 (18 MB)
2023-03-01 00:36:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 164000 (18 MB)
2023-03-01 00:36:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 165000 (19 MB)
2023-03-01 00:37:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 166000 (19 MB)
2023-03-01 00:37:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 167000 (19 MB)
2023-03-01 00:37:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 168000 (19 MB)
2023-03-01 00:37:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 169000 (19 MB)
2023-03-01 00:37:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 170000 (19 MB)
2023-03-01 00:37:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 171000 (19 MB)
2023-03-01 00:37:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 172000 (20 MB)
2023-03-01 00:37:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 173000 (20 MB)
2023-03-01 00:37:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 174000 (20 MB)
2023-03-01 00:37:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 175000 (20 MB)
2023-03-01 00:37:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 176000 (20 MB)
2023-03-01 00:37:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 177000 (20 MB)
2023-03-01 00:37:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 178000 (20 MB)
2023-03-01 00:37:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 179000 (21 MB)
2023-03-01 00:37:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 180000 (21 MB)
2023-03-01 00:37:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 181000 (21 MB)
2023-03-01 00:37:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 182000 (21 MB)
2023-03-01 00:37:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 183000 (21 MB)
2023-03-01 00:37:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 184000 (21 MB)
2023-03-01 00:37:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 185000 (21 MB)
2023-03-01 00:37:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 186000 (22 MB)
2023-03-01 00:37:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 187000 (22 MB)
2023-03-01 00:37:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 188000 (22 MB)
2023-03-01 00:37:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 189000 (22 MB)
2023-03-01 00:37:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 190000 (22 MB)
2023-03-01 00:37:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 191000 (22 MB)
2023-03-01 00:37:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 192000 (22 MB)
2023-03-01 00:37:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 193000 (23 MB)
2023-03-01 00:37:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 194000 (23 MB)
2023-03-01 00:37:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 195000 (23 MB)
2023-03-01 00:37:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 196000 (23 MB)
2023-03-01 00:37:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 197000 (23 MB)
2023-03-01 00:37:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 198000 (23 MB)
2023-03-01 00:37:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 199000 (23 MB)
2023-03-01 00:37:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 200000 (23 MB)
2023-03-01 00:37:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 201000 (24 MB)
2023-03-01 00:37:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 202000 (24 MB)
2023-03-01 00:37:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 203000 (24 MB)
2023-03-01 00:37:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 204000 (24 MB)
2023-03-01 00:37:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 205000 (24 MB)
2023-03-01 00:37:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 206000 (24 MB)
2023-03-01 00:37:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 207000 (24 MB)
2023-03-01 00:37:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 208000 (25 MB)
2023-03-01 00:37:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 209000 (25 MB)
2023-03-01 00:37:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 210000 (25 MB)
2023-03-01 00:37:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 211000 (25 MB)
2023-03-01 00:37:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 212000 (25 MB)
2023-03-01 00:37:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 213000 (25 MB)
2023-03-01 00:37:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 214000 (25 MB)
2023-03-01 00:37:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 215000 (26 MB)
2023-03-01 00:37:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 216000 (26 MB)
2023-03-01 00:37:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 217000 (26 MB)
2023-03-01 00:37:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 218000 (26 MB)
2023-03-01 00:37:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 219000 (26 MB)
2023-03-01 00:37:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 220000 (26 MB)
2023-03-01 00:37:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 221000 (26 MB)
2023-03-01 00:37:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 222000 (27 MB)
2023-03-01 00:37:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 223000 (27 MB)
2023-03-01 00:37:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 224000 (27 MB)
2023-03-01 00:37:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 225000 (27 MB)
2023-03-01 00:37:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 226000 (27 MB)
2023-03-01 00:37:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 227000 (27 MB)
2023-03-01 00:37:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 228000 (27 MB)
2023-03-01 00:37:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 229000 (28 MB)
2023-03-01 00:37:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 230000 (28 MB)
2023-03-01 00:37:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 231000 (28 MB)
2023-03-01 00:37:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 232000 (28 MB)
2023-03-01 00:37:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 233000 (28 MB)
2023-03-01 00:37:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 234000 (28 MB)
2023-03-01 00:37:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 235000 (28 MB)
2023-03-01 00:37:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 236000 (28 MB)
2023-03-01 00:37:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 237000 (29 MB)
2023-03-01 00:37:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 238000 (29 MB)
2023-03-01 00:37:18 source > Google Analytics data is not golden. Future requests may return different data.
2023-03-01 00:37:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 239000 (29 MB)
2023-03-01 00:37:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 240000 (29 MB)
2023-03-01 00:37:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 241000 (29 MB)
2023-03-01 00:37:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 242000 (29 MB)
2023-03-01 00:37:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 243000 (29 MB)
2023-03-01 00:37:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 244000 (30 MB)
2023-03-01 00:37:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 245000 (30 MB)
2023-03-01 00:37:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 246000 (30 MB)
2023-03-01 00:37:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 247000 (30 MB)
2023-03-01 00:37:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 248000 (30 MB)
2023-03-01 00:37:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 249000 (30 MB)
2023-03-01 00:37:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 250000 (30 MB)
2023-03-01 00:37:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 251000 (31 MB)
2023-03-01 00:37:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 252000 (31 MB)
2023-03-01 00:37:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 253000 (31 MB)
2023-03-01 00:37:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 254000 (31 MB)
2023-03-01 00:37:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 255000 (31 MB)
2023-03-01 00:37:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 256000 (31 MB)
2023-03-01 00:37:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 257000 (31 MB)
2023-03-01 00:37:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 258000 (32 MB)
2023-03-01 00:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 259000 (32 MB)
2023-03-01 00:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 260000 (32 MB)
2023-03-01 00:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 261000 (32 MB)
2023-03-01 00:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 262000 (32 MB)
2023-03-01 00:37:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 263000 (32 MB)
2023-03-01 00:37:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 264000 (32 MB)
2023-03-01 00:37:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 265000 (33 MB)
2023-03-01 00:37:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 266000 (33 MB)
2023-03-01 00:37:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 267000 (33 MB)
2023-03-01 00:37:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 268000 (33 MB)
2023-03-01 00:37:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 269000 (33 MB)
2023-03-01 00:37:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 270000 (33 MB)
2023-03-01 00:37:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 271000 (33 MB)
2023-03-01 00:37:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 272000 (34 MB)
2023-03-01 00:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 273000 (34 MB)
2023-03-01 00:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 274000 (34 MB)
2023-03-01 00:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 275000 (34 MB)
2023-03-01 00:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 276000 (34 MB)
2023-03-01 00:37:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 277000 (34 MB)
2023-03-01 00:37:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 278000 (34 MB)
2023-03-01 00:37:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 279000 (35 MB)
2023-03-01 00:37:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 280000 (35 MB)
2023-03-01 00:37:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 281000 (35 MB)
2023-03-01 00:37:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 282000 (35 MB)
2023-03-01 00:37:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 283000 (35 MB)
2023-03-01 00:37:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 284000 (35 MB)
2023-03-01 00:37:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 285000 (35 MB)
2023-03-01 00:37:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 286000 (36 MB)
2023-03-01 00:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 287000 (36 MB)
2023-03-01 00:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 288000 (36 MB)
2023-03-01 00:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 289000 (36 MB)
2023-03-01 00:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 290000 (36 MB)
2023-03-01 00:37:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 291000 (36 MB)
2023-03-01 00:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 292000 (36 MB)
2023-03-01 00:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 293000 (36 MB)
2023-03-01 00:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 294000 (37 MB)
2023-03-01 00:37:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 295000 (37 MB)
2023-03-01 00:37:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 296000 (37 MB)
2023-03-01 00:37:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 297000 (37 MB)
2023-03-01 00:37:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 298000 (37 MB)
2023-03-01 00:37:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 299000 (37 MB)
2023-03-01 00:37:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 300000 (37 MB)
2023-03-01 00:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 301000 (38 MB)
2023-03-01 00:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):385 - Records read: 302000 (38 MB)
2023-03-01 00:37:32 source > Read 110659 records from traffic stream
2023-03-01 00:37:32 source > Finished syncing traffic
2023-03-01 00:37:32 source > SourceGoogleAnalyticsV4 runtimes:
Syncing stream audience_overview 0:00:00.594878
Syncing stream browser_and_operating_system_overview 0:00:00.924450
Syncing stream campaign_performance 0:00:01.967576
Syncing stream channel_traffic 0:00:00.820344
Syncing stream payment_id_channel 0:00:26.348383
Syncing stream social_media_acquisitions 0:00:00.731163
Syncing stream traffic 0:00:56.693028
2023-03-01 00:37:32 source > Finished syncing SourceGoogleAnalyticsV4
2023-03-01 00:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):388 - Source has no more messages, closing connection.
2023-03-01 00:37:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):397 - Total records read: 302328 (38 MB)
2023-03-01 00:37:32 INFO i.a.w.g.DefaultReplicationWorker(replicate):252 - One of source or destination thread complete. Waiting on the other.
2023-03-01 00:37:32 destination > INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 Airbyte message consumer: succeeded.
2023-03-01 00:37:32 destination > INFO i.a.i.d.b.BufferedStreamConsumer(close):209 executing on success close procedure.
2023-03-01 00:37:32 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):130 Flushing all 7 current buffers (6 MB in total)
2023-03-01 00:37:32 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):132 Flushing buffer of stream channel_traffic (10 bytes)
2023-03-01 00:37:32 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):208 Flushing buffer for stream channel_traffic (10 bytes) to staging
2023-03-01 00:37:32 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 Wrapping up compression and write GZIP trailer data.
2023-03-01 00:37:32 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 Finished writing data to a70cb882-4807-4d14-bf62-9bb7c34731ea13862265214848940352.csv.gz (2 KB)
2023-03-01 00:37:34 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:37:34 destination > INFO i.a.i.d.s.SnowflakeInternalStagingSqlOperations(uploadRecordsToStage):87 Successfully loaded records to stage 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/ with 0 re-attempt(s)
2023-03-01 00:37:37 destination > INFO i.a.i.d.r.FileBuffer(deleteFile):109 Deleting tempFile data a70cb882-4807-4d14-bf62-9bb7c34731ea13862265214848940352.csv.gz
2023-03-01 00:37:37 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):134 Flushing completed for channel_traffic
2023-03-01 00:37:37 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):132 Flushing buffer of stream traffic (5 MB)
2023-03-01 00:37:37 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):208 Flushing buffer for stream traffic (5 MB) to staging
2023-03-01 00:37:37 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 Wrapping up compression and write GZIP trailer data.
2023-03-01 00:37:37 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 Finished writing data to fc9cc749-2e0c-4659-9239-ba4d9870e8cf11198612730982213797.csv.gz (5 MB)
2023-03-01 00:37:41 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:37:41 destination > INFO i.a.i.d.s.SnowflakeInternalStagingSqlOperations(uploadRecordsToStage):87 Successfully loaded records to stage 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/ with 0 re-attempt(s)
2023-03-01 00:37:46 destination > INFO i.a.i.d.r.FileBuffer(deleteFile):109 Deleting tempFile data fc9cc749-2e0c-4659-9239-ba4d9870e8cf11198612730982213797.csv.gz
2023-03-01 00:37:46 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):134 Flushing completed for traffic
2023-03-01 00:37:46 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):132 Flushing buffer of stream campaign_performance (82 KB)
2023-03-01 00:37:46 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):208 Flushing buffer for stream campaign_performance (82 KB) to staging
2023-03-01 00:37:46 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 Wrapping up compression and write GZIP trailer data.
2023-03-01 00:37:46 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 Finished writing data to 6b17a52e-ef12-417e-b350-e6f852e7050518120840746851538667.csv.gz (94 KB)
2023-03-01 00:37:46 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:37:46 destination > INFO i.a.i.d.s.SnowflakeInternalStagingSqlOperations(uploadRecordsToStage):87 Successfully loaded records to stage 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/ with 0 re-attempt(s)
2023-03-01 00:37:48 destination > INFO i.a.i.d.r.FileBuffer(deleteFile):109 Deleting tempFile data 6b17a52e-ef12-417e-b350-e6f852e7050518120840746851538667.csv.gz
2023-03-01 00:37:48 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):134 Flushing completed for campaign_performance
2023-03-01 00:37:48 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):132 Flushing buffer of stream social_media_acquisitions (10 bytes)
2023-03-01 00:37:48 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):208 Flushing buffer for stream social_media_acquisitions (10 bytes) to staging
2023-03-01 00:37:48 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 Wrapping up compression and write GZIP trailer data.
2023-03-01 00:37:48 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 Finished writing data to 5e671eca-20c0-415d-879e-f863cfc582115745366740029436667.csv.gz (1 KB)
2023-03-01 00:37:48 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:37:48 destination > INFO i.a.i.d.s.SnowflakeInternalStagingSqlOperations(uploadRecordsToStage):87 Successfully loaded records to stage 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/ with 0 re-attempt(s)
2023-03-01 00:37:50 destination > INFO i.a.i.d.r.FileBuffer(deleteFile):109 Deleting tempFile data 5e671eca-20c0-415d-879e-f863cfc582115745366740029436667.csv.gz
2023-03-01 00:37:50 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):134 Flushing completed for social_media_acquisitions
2023-03-01 00:37:50 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):132 Flushing buffer of stream browser_and_operating_system_overview (10 bytes)
2023-03-01 00:37:50 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):208 Flushing buffer for stream browser_and_operating_system_overview (10 bytes) to staging
2023-03-01 00:37:50 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 Wrapping up compression and write GZIP trailer data.
2023-03-01 00:37:50 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 Finished writing data to 8f3d30a7-875b-4d4f-aded-e7ff3ce3613b12541396567908409947.csv.gz (9 KB)
2023-03-01 00:37:51 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:37:51 destination > INFO i.a.i.d.s.SnowflakeInternalStagingSqlOperations(uploadRecordsToStage):87 Successfully loaded records to stage 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/ with 0 re-attempt(s)
2023-03-01 00:37:53 destination > INFO i.a.i.d.r.FileBuffer(deleteFile):109 Deleting tempFile data 8f3d30a7-875b-4d4f-aded-e7ff3ce3613b12541396567908409947.csv.gz
2023-03-01 00:37:53 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):134 Flushing completed for browser_and_operating_system_overview
2023-03-01 00:37:53 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):132 Flushing buffer of stream payment_id_channel (1 MB)
2023-03-01 00:37:53 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):208 Flushing buffer for stream payment_id_channel (1 MB) to staging
2023-03-01 00:37:53 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 Wrapping up compression and write GZIP trailer data.
2023-03-01 00:37:53 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 Finished writing data to 33434e01-3b22-4c8b-9521-8770da9f13504148204676826499544.csv.gz (1 MB)
2023-03-01 00:37:54 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:37:54 destination > INFO i.a.i.d.s.SnowflakeInternalStagingSqlOperations(uploadRecordsToStage):87 Successfully loaded records to stage 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/ with 0 re-attempt(s)
2023-03-01 00:37:55 destination > INFO i.a.i.d.r.FileBuffer(deleteFile):109 Deleting tempFile data 33434e01-3b22-4c8b-9521-8770da9f13504148204676826499544.csv.gz
2023-03-01 00:37:55 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):134 Flushing completed for payment_id_channel
2023-03-01 00:37:55 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):132 Flushing buffer of stream audience_overview (10 bytes)
2023-03-01 00:37:55 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$flushBufferFunction$3):208 Flushing buffer for stream audience_overview (10 bytes) to staging
2023-03-01 00:37:55 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):131 Wrapping up compression and write GZIP trailer data.
2023-03-01 00:37:55 destination > INFO i.a.i.d.r.BaseSerializedBuffer(flush):138 Finished writing data to 43f55c96-7800-4bd9-889e-6404e46dcaa218360886973097748343.csv.gz (470 bytes)
2023-03-01 00:37:55 destination > INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:37:55 destination > INFO i.a.i.d.s.SnowflakeInternalStagingSqlOperations(uploadRecordsToStage):87 Successfully loaded records to stage 2023/03/01/00/C1A2F023-C04F-4B2D-A8E4-2CA405087F5B/ with 0 re-attempt(s)
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.FileBuffer(deleteFile):109 Deleting tempFile data 43f55c96-7800-4bd9-889e-6404e46dcaa218360886973097748343.csv.gz
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(flushAll):134 Flushing completed for audience_overview
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(close):152 Closing buffer for stream channel_traffic
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(close):152 Closing buffer for stream traffic
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(close):152 Closing buffer for stream campaign_performance
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(close):152 Closing buffer for stream social_media_acquisitions
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(close):152 Closing buffer for stream browser_and_operating_system_overview
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(close):152 Closing buffer for stream payment_id_channel
2023-03-01 00:37:56 destination > INFO i.a.i.d.r.SerializedBufferingStrategy(close):152 Closing buffer for stream audience_overview
2023-03-01 00:37:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):286 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@193e2fe[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@f541cbc[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@b6b898e[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@4e691687[name=audience_overview,namespace=<null>,additionalProperties={}],streamState={"ga_date":"2023-02-28"},additionalProperties={}],global=<null>,data={"events_overview":{"ga_date":"2021-05-04"},"biller_traffic":{"ga_date":"2021-03-21"},"browser_and_operating_system_overview":{"ga_date":"2023-02-27"},"channel_traffic":{"ga_date":"2023-02-27"},"social_media_acquisitions":{"ga_date":"2023-02-27"},"campaign_performance":{"ga_date":"2023-02-27"},"audience_overview":{"ga_date":"2023-02-28"},"payment_id_channel":{"ga_date":"2023-02-27"},"traffic":{"ga_date":"2023-02-27"}},additionalProperties={}],trace=<null>,control=<null>,additionalProperties={}]
2023-03-01 00:37:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):286 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@507399a6[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@7feddee8[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@281d0f62[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@2e46e9c8[name=browser_and_operating_system_overview,namespace=<null>,additionalProperties={}],streamState={"ga_date":"2023-02-28"},additionalProperties={}],global=<null>,data={"events_overview":{"ga_date":"2021-05-04"},"biller_traffic":{"ga_date":"2021-03-21"},"browser_and_operating_system_overview":{"ga_date":"2023-02-28"},"channel_traffic":{"ga_date":"2023-02-27"},"social_media_acquisitions":{"ga_date":"2023-02-27"},"campaign_performance":{"ga_date":"2023-02-27"},"audience_overview":{"ga_date":"2023-02-28"},"payment_id_channel":{"ga_date":"2023-02-27"},"traffic":{"ga_date":"2023-02-27"}},additionalProperties={}],trace=<null>,control=<null>,additionalProperties={}]
2023-03-01 00:37:56 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):226 - The message tracker encountered an issue that prevents committed record counts from being reliably computed.
2023-03-01 00:37:56 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):227 - This only impacts metadata and does not indicate a problem with actual sync data.
2023-03-01 00:37:56 WARN i.a.w.i.b.AirbyteMessageTracker(handleDestinationEmittedState):228 - State hash 1970983472 was already committed, likely indicating a state hash collision
io.airbyte.workers.internal.book_keeping.StateDeltaTracker$StateDeltaTrackerException: State hash 1970983472 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.41.0.jar:?]
	at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.handleDestinationEmittedState(AirbyteMessageTracker.java:223) ~[io.airbyte-airbyte-commons-worker-0.41.0.jar:?]
	at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.acceptFromDestination(AirbyteMessageTracker.java:146) ~[io.airbyte-airbyte-commons-worker-0.41.0.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:288) ~[io.airbyte-airbyte-commons-worker-0.41.0.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) ~[?:?]
2023-03-01 00:37:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):286 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@733f633f[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@33190425[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@2a08b327[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@6fa1c9ea[name=campaign_performance,namespace=<null>,additionalProperties={}],streamState={"ga_date":"2023-02-28"},additionalProperties={}],global=<null>,data={"events_overview":{"ga_date":"2021-05-04"},"biller_traffic":{"ga_date":"2021-03-21"},"browser_and_operating_system_overview":{"ga_date":"2023-02-28"},"channel_traffic":{"ga_date":"2023-02-27"},"social_media_acquisitions":{"ga_date":"2023-02-27"},"campaign_performance":{"ga_date":"2023-02-28"},"audience_overview":{"ga_date":"2023-02-28"},"payment_id_channel":{"ga_date":"2023-02-27"},"traffic":{"ga_date":"2023-02-27"}},additionalProperties={}],trace=<null>,control=<null>,additionalProperties={}]
2023-03-01 00:37:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):286 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@678f69ba[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@1ccc6142[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@73b26877[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@12bd1172[name=channel_traffic,namespace=<null>,additionalProperties={}],streamState={"ga_date":"2023-02-28"},additionalProperties={}],global=<null>,data={"events_overview":{"ga_date":"2021-05-04"},"biller_traffic":{"ga_date":"2021-03-21"},"browser_and_operating_system_overview":{"ga_date":"2023-02-28"},"channel_traffic":{"ga_date":"2023-02-28"},"social_media_acquisitions":{"ga_date":"2023-02-27"},"campaign_performance":{"ga_date":"2023-02-28"},"audience_overview":{"ga_date":"2023-02-28"},"payment_id_channel":{"ga_date":"2023-02-27"},"traffic":{"ga_date":"2023-02-27"}},additionalProperties={}],trace=<null>,control=<null>,additionalProperties={}]
2023-03-01 00:37:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):286 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@ee37826[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@71dacec9[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@11cbf155[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@6b87449f[name=payment_id_channel,namespace=<null>,additionalProperties={}],streamState={"ga_date":"2023-02-28"},additionalProperties={}],global=<null>,data={"events_overview":{"ga_date":"2021-05-04"},"biller_traffic":{"ga_date":"2021-03-21"},"browser_and_operating_system_overview":{"ga_date":"2023-02-28"},"channel_traffic":{"ga_date":"2023-02-28"},"social_media_acquisitions":{"ga_date":"2023-02-27"},"campaign_performance":{"ga_date":"2023-02-28"},"audience_overview":{"ga_date":"2023-02-28"},"payment_id_channel":{"ga_date":"2023-02-28"},"traffic":{"ga_date":"2023-02-27"}},additionalProperties={}],trace=<null>,control=<null>,additionalProperties={}]
2023-03-01 00:37:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):286 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@7eb02381[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@593b0618[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@17341533[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@46c608f6[name=social_media_acquisitions,namespace=<null>,additionalProperties={}],streamState={"ga_date":"2023-02-28"},additionalProperties={}],global=<null>,data={"events_overview":{"ga_date":"2021-05-04"},"biller_traffic":{"ga_date":"2021-03-21"},"browser_and_operating_system_overview":{"ga_date":"2023-02-28"},"channel_traffic":{"ga_date":"2023-02-28"},"social_media_acquisitions":{"ga_date":"2023-02-28"},"campaign_performance":{"ga_date":"2023-02-28"},"audience_overview":{"ga_date":"2023-02-28"},"payment_id_channel":{"ga_date":"2023-02-28"},"traffic":{"ga_date":"2023-02-27"}},additionalProperties={}],trace=<null>,control=<null>,additionalProperties={}]
2023-03-01 00:37:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):286 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@39958784[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@381f5d68[type=STREAM,stream=io.airbyte.protocol.models.AirbyteStreamState@f354ad5[streamDescriptor=io.airbyte.protocol.models.StreamDescriptor@79c2627d[name=traffic,namespace=<null>,additionalProperties={}],streamState={"ga_date":"2023-02-28"},additionalProperties={}],global=<null>,data={"events_overview":{"ga_date":"2021-05-04"},"biller_traffic":{"ga_date":"2021-03-21"},"browser_and_operating_system_overview":{"ga_date":"2023-02-28"},"channel_traffic":{"ga_date":"2023-02-28"},"social_media_acquisitions":{"ga_date":"2023-02-28"},"campaign_performance":{"ga_date":"2023-02-28"},"audience_overview":{"ga_date":"2023-02-28"},"payment_id_channel":{"ga_date":"2023-02-28"},"traffic":{"ga_date":"2023-02-28"}},additionalProperties={}],trace=<null>,control=<null>,additionalProperties={}]
2023-03-01 00:37:57 destination > INFO i.a.i.d.j.SqlOperations(onDestinationCloseOperations):149 No onDestinationCloseOperations required for this destination.
2023-03-01 00:37:57 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):267 Finalizing tables in destination completed.
2023-03-01 00:37:57 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):271 Cleaning up destination started for 7 streams
2023-03-01 00:37:57 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):276 Cleaning stage in destination started for stream audience_overview. schema GOOGLE_ANALYTICS, stage: GOOGLE_ANALYTICS_AUDIENCE_OVERVIEW
2023-03-01 00:37:57 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):276 Cleaning stage in destination started for stream browser_and_operating_system_overview. schema GOOGLE_ANALYTICS, stage: GOOGLE_ANALYTICS_BROWSER_AND_OPERATING_SYSTEM_OVERVIEW
2023-03-01 00:37:58 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):276 Cleaning stage in destination started for stream campaign_performance. schema GOOGLE_ANALYTICS, stage: GOOGLE_ANALYTICS_CAMPAIGN_PERFORMANCE
2023-03-01 00:37:58 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):276 Cleaning stage in destination started for stream channel_traffic. schema GOOGLE_ANALYTICS, stage: GOOGLE_ANALYTICS_CHANNEL_TRAFFIC
2023-03-01 00:37:59 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):276 Cleaning stage in destination started for stream payment_id_channel. schema GOOGLE_ANALYTICS, stage: GOOGLE_ANALYTICS_PAYMENT_ID_CHANNEL
2023-03-01 00:37:59 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):276 Cleaning stage in destination started for stream social_media_acquisitions. schema GOOGLE_ANALYTICS, stage: GOOGLE_ANALYTICS_SOCIAL_MEDIA_ACQUISITIONS
2023-03-01 00:38:00 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):276 Cleaning stage in destination started for stream traffic. schema GOOGLE_ANALYTICS, stage: GOOGLE_ANALYTICS_TRAFFIC
2023-03-01 00:38:00 destination > INFO i.a.i.d.s.StagingConsumerFactory(lambda$onCloseFunction$4):281 Cleaning up destination completed.
2023-03-01 00:38:00 destination > INFO i.a.i.b.IntegrationRunner(runInternal):182 Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:38:00 destination > INFO i.a.i.b.a.AdaptiveDestinationRunner$Runner(run):88 Completed destination: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:38:01 INFO i.a.w.g.DefaultReplicationWorker(replicate):254 - Source and destination threads complete.
2023-03-01 00:38:01 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):561 - Source output at least one state message
2023-03-01 00:38:01 INFO i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):567 - State capture: Updated state to: Optional[io.airbyte.config.State@62574d8b[state=[{"type":"STREAM","stream":{"stream_descriptor":{"name":"traffic"},"stream_state":{"ga_date":"2023-02-28"}}}]]]
2023-03-01 00:38:01 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):494 - sync summary: {
  "status" : "completed",
  "recordsSynced" : 151157,
  "bytesSynced" : 40168766,
  "startTime" : 1677630962113,
  "endTime" : 1677631081572,
  "totalStats" : {
    "bytesEmitted" : 40168766,
    "destinationStateMessagesEmitted" : 7,
    "destinationWriteEndTime" : 1677631081571,
    "destinationWriteStartTime" : 1677630962173,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 8,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 111,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 98,
    "recordsEmitted" : 151157,
    "recordsCommitted" : 151157,
    "replicationEndTime" : 1677631081572,
    "replicationStartTime" : 1677630962113,
    "sourceReadEndTime" : 1677631052772,
    "sourceReadStartTime" : 1677630962143,
    "sourceStateMessagesEmitted" : 151171
  },
  "streamStats" : [ {
    "streamName" : "channel_traffic",
    "stats" : {
      "bytesEmitted" : 9911,
      "recordsEmitted" : 24,
      "recordsCommitted" : 24
    }
  }, {
    "streamName" : "traffic",
    "stats" : {
      "bytesEmitted" : 32566066,
      "recordsEmitted" : 110659,
      "recordsCommitted" : 110659
    }
  }, {
    "streamName" : "campaign_performance",
    "stats" : {
      "bytesEmitted" : 481436,
      "recordsEmitted" : 1473,
      "recordsCommitted" : 1473
    }
  }, {
    "streamName" : "browser_and_operating_system_overview",
    "stats" : {
      "bytesEmitted" : 42873,
      "recordsEmitted" : 116,
      "recordsCommitted" : 116
    }
  }, {
    "streamName" : "social_media_acquisitions",
    "stats" : {
      "bytesEmitted" : 4749,
      "recordsEmitted" : 13,
      "recordsCommitted" : 13
    }
  }, {
    "streamName" : "audience_overview",
    "stats" : {
      "bytesEmitted" : 914,
      "recordsEmitted" : 3,
      "recordsCommitted" : 3
    }
  }, {
    "streamName" : "payment_id_channel",
    "stats" : {
      "bytesEmitted" : 7062817,
      "recordsEmitted" : 38869,
      "recordsCommitted" : 38869
    }
  } ]
}
2023-03-01 00:38:01 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):495 - failures: [ ]
2023-03-01 00:38:01 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-03-01 00:38:01 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:38:01 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2023-03-01 00:38:01 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:38:01 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):220 - sync summary: io.airbyte.config.StandardSyncOutput@39623006[standardSyncSummary=io.airbyte.config.StandardSyncSummary@dedea39[status=completed,recordsSynced=151157,bytesSynced=40168766,startTime=1677630962113,endTime=1677631081572,totalStats=io.airbyte.config.SyncStats@50c4f75e[bytesEmitted=40168766,destinationStateMessagesEmitted=7,destinationWriteEndTime=1677631081571,destinationWriteStartTime=1677630962173,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=8,maxSecondsBetweenStateMessageEmittedandCommitted=111,meanSecondsBetweenStateMessageEmittedandCommitted=98,recordsEmitted=151157,recordsCommitted=151157,replicationEndTime=1677631081572,replicationStartTime=1677630962113,sourceReadEndTime=1677631052772,sourceReadStartTime=1677630962143,sourceStateMessagesEmitted=151171,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@6fd2b90e[streamName=channel_traffic,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@471856f2[bytesEmitted=9911,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=24,recordsCommitted=24,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}]], io.airbyte.config.StreamSyncStats@2546c00a[streamName=traffic,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@524fadfb[bytesEmitted=32566066,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=110659,recordsCommitted=110659,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}]], io.airbyte.config.StreamSyncStats@28af6475[streamName=campaign_performance,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@2d850854[bytesEmitted=481436,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=1473,recordsCommitted=1473,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}]], io.airbyte.config.StreamSyncStats@3e50cb7e[streamName=browser_and_operating_system_overview,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@11df993a[bytesEmitted=42873,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=116,recordsCommitted=116,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}]], io.airbyte.config.StreamSyncStats@4200cbb8[streamName=social_media_acquisitions,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@4742bc04[bytesEmitted=4749,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=13,recordsCommitted=13,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}]], io.airbyte.config.StreamSyncStats@7ff184a9[streamName=audience_overview,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@128ac424[bytesEmitted=914,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=3,recordsCommitted=3,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}]], io.airbyte.config.StreamSyncStats@561380c6[streamName=payment_id_channel,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@4e3b49c[bytesEmitted=7062817,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=38869,recordsCommitted=38869,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}]]]],normalizationSummary=<null>,webhookOperationSummary=<null>,state=io.airbyte.config.State@62574d8b[state=[{"type":"STREAM","stream":{"stream_descriptor":{"name":"traffic"},"stream_state":{"ga_date":"2023-02-28"}}}]],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@7744ac65[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@332bed4d[stream=io.airbyte.protocol.models.AirbyteStream@79f45e5e[name=audience_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_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"isDataGolden":{"type":"boolean"},"ga_bounceRate":{"type":["null","number"]},"ga_sessionsPerUser":{"type":["null","number"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@60aa42a8[stream=io.airbyte.protocol.models.AirbyteStream@32dfed5c[name=browser_and_operating_system_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_browser":{"type":["string"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"isDataGolden":{"type":"boolean"},"ga_bounceRate":{"type":["null","number"]},"ga_goalValueAll":{"type":["null","string"]},"ga_operatingSystem":{"type":["string"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_goalCompletionsAll":{"type":["null","integer"]},"ga_pageviewsPerSession":{"type":["null","number"]},"ga_goalConversionRateAll":{"type":["null","number"]}},"additionalProperties":true},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_operatingSystem]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5e722fcf[stream=io.airbyte.protocol.models.AirbyteStream@5af9cf1[name=campaign_performance,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_campaign":{"type":["string"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"isDataGolden":{"type":"boolean"},"ga_bounceRate":{"type":["null","number"]},"ga_goalValueAll":{"type":["null","string"]},"ga_goalCompletionsAll":{"type":["null","integer"]},"ga_pageviewsPerSession":{"type":["null","number"]},"ga_goalConversionRateAll":{"type":["null","number"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_campaign], [ga_date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@372221ee[stream=io.airbyte.protocol.models.AirbyteStream@7a5a9f5b[name=channel_traffic,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_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"isDataGolden":{"type":"boolean"},"ga_bounceRate":{"type":["null","number"]},"ga_goalValueAll":{"type":["null","string"]},"ga_channelGrouping":{"type":["string"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_goalCompletionsAll":{"type":["null","integer"]},"ga_percentNewSessions":{"type":["null","number"]},"ga_pageviewsPerSession":{"type":["null","number"]},"ga_goalConversionRateAll":{"type":["null","number"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[ga_date],destinationSyncMode=append_dedup,primaryKey=[[ga_channelGrouping], [ga_date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3519db88[stream=io.airbyte.protocol.models.AirbyteStream@4c2891ce[name=payment_id_channel,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_medium":{"type":["string"]},"ga_source":{"type":["string"]},"isDataGolden":{"type":"boolean"},"ga_dimension5":{"type":["string"]},"ga_totalEvents":{"type":["null","integer"]}},"additionalProperties":true},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_dimension5], [ga_medium], [ga_source]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@6a23f4f4[stream=io.airbyte.protocol.models.AirbyteStream@44ad0eac[name=social_media_acquisitions,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_newUsers":{"type":["null","integer"]},"ga_sessions":{"type":["null","integer"]},"ga_pageviews":{"type":["null","integer"]},"isDataGolden":{"type":"boolean"},"ga_bounceRate":{"type":["null","number"]},"ga_transactions":{"type":["null","integer"]},"ga_socialNetwork":{"type":["string"]},"ga_avgSessionDuration":{"type":["null","number"]},"ga_percentNewSessions":{"type":["null","number"]},"ga_transactionRevenue":{"type":["null","string"]},"ga_pageviewsPerSession":{"type":["null","number"]},"ga_transactionsPerSession":{"type":["null","number"]}},"additionalProperties":true},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_socialNetwork]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3f13482a[stream=io.airbyte.protocol.models.AirbyteStream@373d18e7[name=traffic,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_entrances":{"type":["null","integer"]},"ga_pageTitle":{"type":["string"]},"ga_pageValue":{"type":["null","string"]},"ga_pageviews":{"type":["null","integer"]},"isDataGolden":{"type":"boolean"},"ga_bounceRate":{"type":["null","number"]},"ga_avgTimeOnPage":{"type":["null","number"]},"ga_uniquePageviews":{"type":["null","integer"]}},"additionalProperties":true},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_pageTitle]],additionalProperties={}]],additionalProperties={}],failures=[]]
2023-03-01 00:38:01 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):225 - Sync summary length: 14056
2023-03-01 00:38:01 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2023-03-01 00:38:01 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state
2023-03-01 00:38:01 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to create or update state
2023-03-01 00:38:01 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):177 - Attempt 0 to create or update state error: io.airbyte.api.client.invoker.generated.ApiException: createOrUpdateState call failed with: 500 - {"message":"Internal Server Error: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","exceptionClassName":"java.lang.IllegalStateException","exceptionStack":["java.lang.IllegalStateException: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","\tat io.airbyte.config.persistence.StatePersistence.updateOrCreateState(StatePersistence.java:94)","\tat io.airbyte.commons.server.handlers.StateHandler.createOrUpdateState(StateHandler.java:37)","\tat io.airbyte.server.apis.StateApiController.lambda$createOrUpdateState$0(StateApiController.java:38)","\tat io.airbyte.server.apis.ApiHelper.execute(ApiHelper.java:23)","\tat io.airbyte.server.apis.StateApiController.createOrUpdateState(StateApiController.java:38)","\tat io.airbyte.server.apis.$StateApiController$Definition$Exec.dispatch(Unknown Source)","\tat io.micronaut.context.AbstractExecutableMethodsDefinition$DispatchedExecutableMethod.invoke(AbstractExecutableMethodsDefinition.java:371)","\tat io.micronaut.context.DefaultBeanContext$4.invoke(DefaultBeanContext.java:594)","\tat io.micronaut.web.router.AbstractRouteMatch.execute(AbstractRouteMatch.java:303)","\tat io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:111)","\tat io.micronaut.http.context.ServerRequestContext.with(ServerRequestContext.java:103)","\tat io.micronaut.http.server.RouteExecutor.lambda$executeRoute$14(RouteExecutor.java:659)","\tat reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:49)","\tat reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)","\tat reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194)","\tat io.micronaut.reactive.reactor.instrument.ReactorInstrumentation.lambda$init$0(ReactorInstrumentation.java:62)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)","\tat io.micronaut.scheduling.instrument.InvocationInstrumenterWrappedCallable.call(InvocationInstrumenterWrappedCallable.java:53)","\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)","\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)","\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)","\tat java.base/java.lang.Thread.run(Thread.java:1589)"]}
2023-03-01 00:38:05 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 1 to create or update state
2023-03-01 00:38:05 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):177 - Attempt 1 to create or update state error: io.airbyte.api.client.invoker.generated.ApiException: createOrUpdateState call failed with: 500 - {"message":"Internal Server Error: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","exceptionClassName":"java.lang.IllegalStateException","exceptionStack":["java.lang.IllegalStateException: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","\tat io.airbyte.config.persistence.StatePersistence.updateOrCreateState(StatePersistence.java:94)","\tat io.airbyte.commons.server.handlers.StateHandler.createOrUpdateState(StateHandler.java:37)","\tat io.airbyte.server.apis.StateApiController.lambda$createOrUpdateState$0(StateApiController.java:38)","\tat io.airbyte.server.apis.ApiHelper.execute(ApiHelper.java:23)","\tat io.airbyte.server.apis.StateApiController.createOrUpdateState(StateApiController.java:38)","\tat io.airbyte.server.apis.$StateApiController$Definition$Exec.dispatch(Unknown Source)","\tat io.micronaut.context.AbstractExecutableMethodsDefinition$DispatchedExecutableMethod.invoke(AbstractExecutableMethodsDefinition.java:371)","\tat io.micronaut.context.DefaultBeanContext$4.invoke(DefaultBeanContext.java:594)","\tat io.micronaut.web.router.AbstractRouteMatch.execute(AbstractRouteMatch.java:303)","\tat io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:111)","\tat io.micronaut.http.context.ServerRequestContext.with(ServerRequestContext.java:103)","\tat io.micronaut.http.server.RouteExecutor.lambda$executeRoute$14(RouteExecutor.java:659)","\tat reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:49)","\tat reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)","\tat reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194)","\tat io.micronaut.reactive.reactor.instrument.ReactorInstrumentation.lambda$init$0(ReactorInstrumentation.java:62)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)","\tat io.micronaut.scheduling.instrument.InvocationInstrumenterWrappedCallable.call(InvocationInstrumenterWrappedCallable.java:53)","\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)","\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)","\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)","\tat java.base/java.lang.Thread.run(Thread.java:1589)"]}
2023-03-01 00:38:11 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 2 to create or update state
2023-03-01 00:38:11 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):177 - Attempt 2 to create or update state error: io.airbyte.api.client.invoker.generated.ApiException: createOrUpdateState call failed with: 500 - {"message":"Internal Server Error: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","exceptionClassName":"java.lang.IllegalStateException","exceptionStack":["java.lang.IllegalStateException: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","\tat io.airbyte.config.persistence.StatePersistence.updateOrCreateState(StatePersistence.java:94)","\tat io.airbyte.commons.server.handlers.StateHandler.createOrUpdateState(StateHandler.java:37)","\tat io.airbyte.server.apis.StateApiController.lambda$createOrUpdateState$0(StateApiController.java:38)","\tat io.airbyte.server.apis.ApiHelper.execute(ApiHelper.java:23)","\tat io.airbyte.server.apis.StateApiController.createOrUpdateState(StateApiController.java:38)","\tat io.airbyte.server.apis.$StateApiController$Definition$Exec.dispatch(Unknown Source)","\tat io.micronaut.context.AbstractExecutableMethodsDefinition$DispatchedExecutableMethod.invoke(AbstractExecutableMethodsDefinition.java:371)","\tat io.micronaut.context.DefaultBeanContext$4.invoke(DefaultBeanContext.java:594)","\tat io.micronaut.web.router.AbstractRouteMatch.execute(AbstractRouteMatch.java:303)","\tat io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:111)","\tat io.micronaut.http.context.ServerRequestContext.with(ServerRequestContext.java:103)","\tat io.micronaut.http.server.RouteExecutor.lambda$executeRoute$14(RouteExecutor.java:659)","\tat reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:49)","\tat reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)","\tat reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194)","\tat io.micronaut.reactive.reactor.instrument.ReactorInstrumentation.lambda$init$0(ReactorInstrumentation.java:62)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)","\tat io.micronaut.scheduling.instrument.InvocationInstrumenterWrappedCallable.call(InvocationInstrumenterWrappedCallable.java:53)","\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)","\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)","\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)","\tat java.base/java.lang.Thread.run(Thread.java:1589)"]}
2023-03-01 00:48:11 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 3 to create or update state
2023-03-01 00:48:11 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):177 - Attempt 3 to create or update state error: io.airbyte.api.client.invoker.generated.ApiException: createOrUpdateState call failed with: 500 - {"message":"Internal Server Error: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","exceptionClassName":"java.lang.IllegalStateException","exceptionStack":["java.lang.IllegalStateException: Unexpected type migration from 'stream' to 'legacy'. Migration of StateType need to go through an explicit reset.","\tat io.airbyte.config.persistence.StatePersistence.updateOrCreateState(StatePersistence.java:94)","\tat io.airbyte.commons.server.handlers.StateHandler.createOrUpdateState(StateHandler.java:37)","\tat io.airbyte.server.apis.StateApiController.lambda$createOrUpdateState$0(StateApiController.java:38)","\tat io.airbyte.server.apis.ApiHelper.execute(ApiHelper.java:23)","\tat io.airbyte.server.apis.StateApiController.createOrUpdateState(StateApiController.java:38)","\tat io.airbyte.server.apis.$StateApiController$Definition$Exec.dispatch(Unknown Source)","\tat io.micronaut.context.AbstractExecutableMethodsDefinition$DispatchedExecutableMethod.invoke(AbstractExecutableMethodsDefinition.java:371)","\tat io.micronaut.context.DefaultBeanContext$4.invoke(DefaultBeanContext.java:594)","\tat io.micronaut.web.router.AbstractRouteMatch.execute(AbstractRouteMatch.java:303)","\tat io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:111)","\tat io.micronaut.http.context.ServerRequestContext.with(ServerRequestContext.java:103)","\tat io.micronaut.http.server.RouteExecutor.lambda$executeRoute$14(RouteExecutor.java:659)","\tat reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:49)","\tat reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)","\tat reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194)","\tat io.micronaut.reactive.reactor.instrument.ReactorInstrumentation.lambda$init$0(ReactorInstrumentation.java:62)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)","\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)","\tat io.micronaut.scheduling.instrument.InvocationInstrumenterWrappedCallable.call(InvocationInstrumenterWrappedCallable.java:53)","\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)","\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)","\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)","\tat java.base/java.lang.Thread.run(Thread.java:1589)"]}
2023-03-01 00:48:13 WARN i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = 6bb950bc-a510-3e92-8337-808cba3bc9ea, ActivityType = Persist, WorkflowId=sync_4629, WorkflowType=SyncWorkflow, RunId=c952568a-a2bb-4262-9dc1-e5bbd48a31bd
io.grpc.StatusRuntimeException: NOT_FOUND: workflow execution already completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.52.1.jar:1.52.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.52.1.jar:1.52.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.52.1.jar:1.52.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:3840) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:303) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:298) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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) ~[?:?]
2023-03-01 00:48:03 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state
2023-03-01 00:48:03 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to set attempt sync config
2023-03-01 00:48:03 INFO i.a.v.j.JsonSchemaValidator(test):120 - JSON schema validation failed. 
errors: $.auth_type: must be a constant value Client, $.client_id: is missing but it is required, $.client_secret: is missing but it is required, $.refresh_token: is missing but it is required
2023-03-01 00:48:03 INFO i.a.v.j.JsonSchemaValidator(test):120 - JSON schema validation failed. 
errors: $.credentials_json: object found, string expected
2023-03-01 00:48:03 INFO i.a.v.j.JsonSchemaValidator(test):120 - JSON schema validation failed. 
errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2023-03-01 00:48:03 INFO i.a.v.j.JsonSchemaValidator(test):120 - JSON schema validation failed. 
errors: $.private_key: is missing but it is required
2023-03-01 00:48:03 INFO i.a.v.j.JsonSchemaValidator(test):120 - JSON schema validation failed. 
errors: $.password: object found, string expected
2023-03-01 00:48:03 INFO i.a.v.j.JsonSchemaValidator(test):120 - JSON schema validation failed. 
errors: $.method: does not have a value in the enumeration [Standard]
2023-03-01 00:48:03 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/4629/1/logs.log
2023-03-01 00:48:03 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.41.0
2023-03-01 00:48:03 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-03-01 00:48:04 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:48:04 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-03-01 00:48:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:48:04 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:48:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:48:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-03-01 00:48:04 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-03-01 00:48:04 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-google-analytics-v4:0.1.34 exists...
2023-03-01 00:48:04 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-google-analytics-v4:0.1.34 was found locally.
2023-03-01 00:48:04 INFO i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-google-analytics-v4-check-4629-1-beahw with resources io.airbyte.config.ResourceRequirements@3b52ff36[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-03-01 00:48:04 INFO i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/4629/1 --log-driver none --name source-google-analytics-v4-check-4629-1-beahw --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=CLOUD -e STRICT_COMPARISON_NORMALIZATION_WORKSPACES= -e WORKER_CONNECTOR_IMAGE=airbyte/source-google-analytics-v4:0.1.34 -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e STRICT_COMPARISON_NORMALIZATION_TAG=strict_comparison2 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=false -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=1 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.41.0 -e WORKER_JOB_ID=4629 airbyte/source-google-analytics-v4:0.1.34 check --config source_config.json
2023-03-01 00:48:04 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0
2023-03-01 00:48:05 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Check succeeded
2023-03-01 00:48:05 INFO i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@1ace8810[status=succeeded,message=<null>]
2023-03-01 00:48:05 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:05 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/4629/1/logs.log
2023-03-01 00:48:05 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.41.0
2023-03-01 00:48:05 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:05 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-03-01 00:48:05 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:05 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:48:05 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-03-01 00:48:05 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-03-01 00:48:05 INFO i.a.c.EnvConfigs(getEnvOrDefault):1208 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-snowflake:0.4.49 exists...
2023-03-01 00:48:05 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-snowflake:0.4.49 was found locally.
2023-03-01 00:48:05 INFO i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-snowflake-check-4629-1-ueekg with resources io.airbyte.config.ResourceRequirements@3b52ff36[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-03-01 00:48:05 INFO i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/4629/1 --log-driver none --name destination-snowflake-check-4629-1-ueekg --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=CLOUD -e STRICT_COMPARISON_NORMALIZATION_WORKSPACES= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.49 -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e STRICT_COMPARISON_NORMALIZATION_TAG=strict_comparison2 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=false -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=1 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.41.0 -e WORKER_JOB_ID=4629 airbyte/destination-snowflake:0.4.49 check --config source_config.json
2023-03-01 00:48:05 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.a.AdaptiveDestinationRunner$Runner(getDestination):74 Running destination under deployment mode: CLOUD
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.a.AdaptiveDestinationRunner$Runner(run):86 Starting destination: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.IntegrationCliParser(parseOptions):126 integration args: {check=null, config=source_config.json}
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.IntegrationRunner(runInternal):105 Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.IntegrationRunner(runInternal):106 Command: CHECK
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.IntegrationRunner(runInternal):107 Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-03-01 00:48:06 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-03-01 00:48:06 WARN i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.d.j.c.SwitchingDestination(check):55 Using destination type: INTERNAL_STAGING
2023-03-01 00:48:06 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO c.z.h.HikariDataSource(getConnection):110 HikariPool-1 - Starting...
2023-03-01 00:48:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO c.z.h.p.HikariPool(checkFailFast):565 HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@656922a0
2023-03-01 00:48:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO c.z.h.HikariDataSource(getConnection):123 HikariPool-1 - Start completed.
2023-03-01 00:48:07 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):115 closing connection
2023-03-01 00:48:08 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.d.s.SnowflakeSqlOperations(insertRecordsInternal):60 actual size of batch: 1
2023-03-01 00:48:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO c.z.h.HikariDataSource(close):350 HikariPool-1 - Shutdown initiated...
2023-03-01 00:48:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO c.z.h.HikariDataSource(close):352 HikariPool-1 - Shutdown completed.
2023-03-01 00:48:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.IntegrationRunner(runInternal):182 Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:48:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - INFO i.a.i.b.a.AdaptiveDestinationRunner$Runner(run):88 Completed destination: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2023-03-01 00:48:14 INFO i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@5f92f8fc[status=succeeded,message=<null>]
2023-03-01 00:48:14 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-03-01 00:48:14 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:14 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-03-01 00:48:14 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-03-01 00:48:15 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/4629/1/logs.log
2023-03-01 00:48:15 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.41.0
2023-03-01 00:48:15 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-03-01 00:48:15 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to datadog
2023-03-01 00:48:15 INFO i.a.w.g.DefaultReplicationWorker(run):152 - start sync worker. job id: 4629 attempt id: 1
2023-03-01 00:48:15 INFO i.a.c.i.LineGobbler(voidCall):114 -