2022-07-04 18:18:10 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.access_token: is missing but it is required, $.refresh_token: is missing but it is required
2022-07-04 18:18:10 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.password: object found, string expected
2022-07-04 18:18:10 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.method: does not have a value in the enumeration [Standard]
2022-07-04 18:18:10 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/485/0/logs.log
2022-07-04 18:18:10 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.32-alpha
2022-07-04 18:18:10 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-04 18:18:10 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-04 18:18:10 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-04 18:18:10 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 485
2022-07-04 18:18:10 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/485/0 --log-driver none --name source-mixpanel-check-485-0-fycxn --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=485 airbyte/source-mixpanel:0.1.17 check --config source_config.json
2022-07-04 18:18:11 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-07-04 18:18:11 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-04 18:18:11 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/485/0/logs.log
2022-07-04 18:18:11 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.32-alpha
2022-07-04 18:18:11 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-04 18:18:11 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-04 18:18:11 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-04 18:18:11 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 485
2022-07-04 18:18:11 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/485/0 --log-driver none --name destination-snowflake-check-485-0-idjqv --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=485 airbyte/destination-snowflake:0.4.30 check --config source_config.json
2022-07-04 18:18:12 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-07-04 18:18:12 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-04 18:18:12 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-04 18:18:12 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-04 18:18:12 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-04 18:18:12 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-04 18:18:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:12 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-07-04 18:18:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:12 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-04 18:18:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:12 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-07-04 18:18:12 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:12 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-07-04 18:18:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:13 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:13 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:13 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:13 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:13 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: INTERNAL_STAGING
2022-07-04 18:18:13 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:13 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-04 18:18:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:14 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@df921b1
2022-07-04 18:18:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:14 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-04 18:18:14 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:14 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:15 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:15 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-07-04 18:18:15 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-07-04 18:18:15 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-07-04 18:18:16 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-04 18:18:16 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/485/0/logs.log
2022-07-04 18:18:16 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.32-alpha
2022-07-04 18:18:16 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 485 attempt id: 0
2022-07-04 18:18:16 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.engage=full_refresh - append, null.export=incremental - append_dedup, null.cohort_members=full_refresh - append, null.annotations=full_refresh - append, null.funnels=incremental - append_dedup, null.cohorts=incremental - append_dedup, null.revenue=incremental - append_dedup}
2022-07-04 18:18:16 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-04 18:18:16 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-04 18:18:16 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.30 exists...
2022-07-04 18:18:16 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.30 was found locally.
2022-07-04 18:18:16 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 485
2022-07-04 18:18:16 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/485/0 --log-driver none --name destination-snowflake-write-485-0-ledgg --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/destination-snowflake:0.4.30 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=485 airbyte/destination-snowflake:0.4.30 write --config destination_config.json --catalog destination_catalog.json
2022-07-04 18:18:16 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-07-04 18:18:16 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mixpanel:0.1.17 exists...
2022-07-04 18:18:16 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mixpanel:0.1.17 was found locally.
2022-07-04 18:18:16 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 485
2022-07-04 18:18:16 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/485/0 --log-driver none --name source-mixpanel-read-485-0-uepqj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_CONNECTOR_IMAGE=airbyte/source-mixpanel:0.1.17 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.32-alpha -e WORKER_JOB_ID=485 airbyte/source-mixpanel:0.1.17 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-07-04 18:18:16 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-07-04 18:18:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-07-04 18:18:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-07-04 18:18:16 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-04 18:18:16 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-04 18:18:16 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-04 18:18:16 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-04 18:18:16 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-04 18:18:17 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-04 18:18:17 source > Starting syncing SourceMixpanel
2022-07-04 18:18:17 source > Using start_date: 2022-06-05, end_date: 2022-07-04
2022-07-04 18:18:17 source > Syncing stream: annotations 
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-04 18:18:17 destination > 2022-07-04 18:18:17 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=annotations, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_bps_annotations, outputTableName=_airbyte_raw_annotations, syncMode=append}
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=cohort_members, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_rzt_cohort_members, outputTableName=_airbyte_raw_cohort_members, syncMode=append}
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=cohorts, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_xby_cohorts, outputTableName=_airbyte_raw_cohorts, syncMode=append_dedup}
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=engage, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_hwh_engage, outputTableName=_airbyte_raw_engage, syncMode=append}
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=export, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_zoc_export, outputTableName=_airbyte_raw_export, syncMode=append_dedup}
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=funnels, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_sbn_funnels, outputTableName=_airbyte_raw_funnels, syncMode=append_dedup}
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$toWriteConfig$0):99 - Write config: WriteConfig{streamName=revenue, namespace=null, outputSchemaName=AIRBYTE_SCHEMA, tmpTableName=_airbyte_tmp_ypx_revenue, outputTableName=_airbyte_raw_revenue, syncMode=append_dedup}
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):117 - Preparing tmp tables in destination started for 7 streams
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema AIRBYTE_SCHEMA stream annotations: tmp table: _airbyte_tmp_bps_annotations, stage: 2022/07/04/18/472175B2-2399-45E6-B0A3-CCB8C979C4AE/
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO c.z.h.HikariDataSource(getConnection):110 - HikariPool-1 - Starting...
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO c.z.h.p.HikariPool(checkFailFast):565 - HikariPool-1 - Added connection net.snowflake.client.jdbc.SnowflakeConnectionV1@4ecd00b5
2022-07-04 18:18:18 destination > 2022-07-04 18:18:18 INFO c.z.h.HikariDataSource(getConnection):123 - HikariPool-1 - Start completed.
2022-07-04 18:18:19 destination > 2022-07-04 18:18:19 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:19 destination > 2022-07-04 18:18:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema AIRBYTE_SCHEMA stream annotations
2022-07-04 18:18:19 destination > 2022-07-04 18:18:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema AIRBYTE_SCHEMA stream cohort_members: tmp table: _airbyte_tmp_rzt_cohort_members, stage: 2022/07/04/18/472175B2-2399-45E6-B0A3-CCB8C979C4AE/
2022-07-04 18:18:19 destination > 2022-07-04 18:18:19 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:19 destination > 2022-07-04 18:18:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema AIRBYTE_SCHEMA stream cohort_members
2022-07-04 18:18:19 destination > 2022-07-04 18:18:19 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema AIRBYTE_SCHEMA stream cohorts: tmp table: _airbyte_tmp_xby_cohorts, stage: 2022/07/04/18/472175B2-2399-45E6-B0A3-CCB8C979C4AE/
2022-07-04 18:18:19 destination > 2022-07-04 18:18:19 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:20 destination > 2022-07-04 18:18:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema AIRBYTE_SCHEMA stream cohorts
2022-07-04 18:18:20 destination > 2022-07-04 18:18:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema AIRBYTE_SCHEMA stream engage: tmp table: _airbyte_tmp_hwh_engage, stage: 2022/07/04/18/472175B2-2399-45E6-B0A3-CCB8C979C4AE/
2022-07-04 18:18:20 destination > 2022-07-04 18:18:20 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:20 destination > 2022-07-04 18:18:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema AIRBYTE_SCHEMA stream engage
2022-07-04 18:18:20 destination > 2022-07-04 18:18:20 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema AIRBYTE_SCHEMA stream export: tmp table: _airbyte_tmp_zoc_export, stage: 2022/07/04/18/472175B2-2399-45E6-B0A3-CCB8C979C4AE/
2022-07-04 18:18:20 destination > 2022-07-04 18:18:20 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema AIRBYTE_SCHEMA stream export
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema AIRBYTE_SCHEMA stream funnels: tmp table: _airbyte_tmp_sbn_funnels, stage: 2022/07/04/18/472175B2-2399-45E6-B0A3-CCB8C979C4AE/
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema AIRBYTE_SCHEMA stream funnels
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):125 - Preparing staging area in destination started for schema AIRBYTE_SCHEMA stream revenue: tmp table: _airbyte_tmp_ypx_revenue, stage: 2022/07/04/18/472175B2-2399-45E6-B0A3-CCB8C979C4AE/
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.d.j.DefaultJdbcDatabase(lambda$unsafeQuery$1):105 - closing connection
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):136 - Preparing staging area in destination completed for schema AIRBYTE_SCHEMA stream revenue
2022-07-04 18:18:21 destination > 2022-07-04 18:18:21 INFO i.a.i.d.s.StagingConsumerFactory(lambda$onStartFunction$2):139 - Preparing tmp tables in destination completed.
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-06-14 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-06-14 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-06-14 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-06-22 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-06-22 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-06-22 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-07-04 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-07-04 00:00:00
2022-07-04 18:20:17 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on 2022-07-04 00:00:00
2022-07-04 18:20:17 source > Read 3 records from annotations stream
2022-07-04 18:20:17 source > Finished syncing annotations
2022-07-04 18:20:17 source > SourceMixpanel runtimes:
Syncing stream annotations 0:02:00.500168
2022-07-04 18:20:17 source > Syncing stream: cohort_members 
2022-07-04 18:21:20 destination > 2022-07-04 18:21:20 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):48 - Starting a new buffer for stream annotations (current state: 0 bytes in 0 buffers)
2022-07-04 18:21:20 destination > 2022-07-04 18:21:20 INFO i.a.i.d.r.SerializedBufferingStrategy(lambda$addRecord$0):48 - Starting a new buffer for stream cohort_members (current state: 0 bytes in 1 buffers)
2022-07-04 18:21:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 ERROR c.n.s.DateTimeValidator(isLegalDateTime):70 - Failed to apply RFC3339 pattern on <null>
2022-07-04 18:21:21 source > [18750] is not of type 'null', 'number'
2022-07-04 18:21:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:21:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:21:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 1000 (588 KB)
2022-07-04 18:22:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:22:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:23:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 2000 (1 MB)
2022-07-04 18:23:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:23:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:24:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 3000 (1 MB)
2022-07-04 18:25:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 4000 (2 MB)
2022-07-04 18:26:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 5000 (2 MB)
2022-07-04 18:27:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:27:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 6000 (3 MB)
2022-07-04 18:28:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:28:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 7000 (3 MB)
2022-07-04 18:28:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:28:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:28:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:28:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:29:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:29:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 8000 (4 MB)
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 9000 (5 MB)
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:30:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:31:33 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:31:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 10000 (5 MB)
2022-07-04 18:31:33 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:32:34 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:32:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 11000 (6 MB)
2022-07-04 18:33:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 12000 (6 MB)
2022-07-04 18:33:35 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:34:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 13000 (7 MB)
2022-07-04 18:35:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 14000 (7 MB)
2022-07-04 18:35:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:36:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 15000 (8 MB)
2022-07-04 18:36:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:37:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:37:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:37:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 16000 (8 MB)
2022-07-04 18:37:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:37:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:37:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:38:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 17000 (9 MB)
2022-07-04 18:39:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 18000 (9 MB)
2022-07-04 18:40:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:40:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 19000 (10 MB)
2022-07-04 18:41:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:41:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:41:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 20000 (11 MB)
2022-07-04 18:41:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:42:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 21000 (11 MB)
2022-07-04 18:43:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:43:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:43:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 22000 (12 MB)
2022-07-04 18:44:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 23000 (12 MB)
2022-07-04 18:45:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:45:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:45:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:45:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:45:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 24000 (13 MB)
2022-07-04 18:45:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:45:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:46:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 25000 (13 MB)
2022-07-04 18:47:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:47:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:47:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 26000 (14 MB)
2022-07-04 18:48:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 27000 (14 MB)
2022-07-04 18:49:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 28000 (15 MB)
2022-07-04 18:50:54 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:50:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 29000 (15 MB)
2022-07-04 18:51:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:51:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:51:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 30000 (16 MB)
2022-07-04 18:52:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 31000 (17 MB)
2022-07-04 18:52:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:52:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 32000 (17 MB)
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:53:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:54:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 33000 (18 MB)
2022-07-04 18:55:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 34000 (18 MB)
2022-07-04 18:57:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 35000 (19 MB)
2022-07-04 18:57:00 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:58:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:58:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 36000 (19 MB)
2022-07-04 18:58:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:59:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 18:59:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 37000 (20 MB)
2022-07-04 19:00:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 38000 (20 MB)
2022-07-04 19:01:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:01:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:01:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 39000 (21 MB)
2022-07-04 19:01:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:01:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:01:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:01:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:02:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 40000 (21 MB)
2022-07-04 19:03:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 41000 (22 MB)
2022-07-04 19:03:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:04:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 42000 (23 MB)
2022-07-04 19:05:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 43000 (23 MB)
2022-07-04 19:06:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 44000 (24 MB)
2022-07-04 19:06:10 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:07:11 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:07:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 45000 (24 MB)
2022-07-04 19:07:11 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:07:11 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:08:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 46000 (25 MB)
2022-07-04 19:08:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 47000 (25 MB)
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:09:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:10:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 48000 (26 MB)
2022-07-04 19:11:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 49000 (26 MB)
2022-07-04 19:12:16 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:12:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 50000 (27 MB)
2022-07-04 19:13:17 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:13:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 51000 (28 MB)
2022-07-04 19:14:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 52000 (28 MB)
2022-07-04 19:14:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:15:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:15:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 53000 (29 MB)
2022-07-04 19:15:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:16:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:16:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:16:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:16:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:16:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 54000 (29 MB)
2022-07-04 19:16:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:17:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 55000 (30 MB)
2022-07-04 19:17:24 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:18:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 56000 (30 MB)
2022-07-04 19:19:26 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:19:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 57000 (31 MB)
2022-07-04 19:20:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 58000 (31 MB)
2022-07-04 19:21:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:21:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 59000 (32 MB)
2022-07-04 19:21:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:22:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:22:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 60000 (32 MB)
2022-07-04 19:23:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:23:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:23:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:23:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 61000 (33 MB)
2022-07-04 19:24:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:24:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:24:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 62000 (34 MB)
2022-07-04 19:24:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:24:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:24:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:25:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 63000 (34 MB)
2022-07-04 19:26:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 64000 (35 MB)
2022-07-04 19:27:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 65000 (35 MB)
2022-07-04 19:28:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 66000 (36 MB)
2022-07-04 19:29:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:29:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:29:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 67000 (36 MB)
2022-07-04 19:29:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:29:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:29:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:30:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 68000 (37 MB)
2022-07-04 19:31:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:31:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:31:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:31:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 69000 (37 MB)
2022-07-04 19:31:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:32:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 70000 (38 MB)
2022-07-04 19:33:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 71000 (38 MB)
2022-07-04 19:34:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 72000 (39 MB)
2022-07-04 19:35:43 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:35:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 73000 (40 MB)
2022-07-04 19:36:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 74000 (40 MB)
2022-07-04 19:36:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:37:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:37:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 75000 (41 MB)
2022-07-04 19:37:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:38:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 76000 (41 MB)
2022-07-04 19:39:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:39:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:39:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:39:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 77000 (42 MB)
2022-07-04 19:39:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:39:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:40:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 78000 (42 MB)
2022-07-04 19:41:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:41:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 79000 (43 MB)
2022-07-04 19:42:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:42:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 80000 (43 MB)
2022-07-04 19:43:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 81000 (44 MB)
2022-07-04 19:44:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:44:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 82000 (44 MB)
2022-07-04 19:45:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:45:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:45:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 83000 (45 MB)
2022-07-04 19:45:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:46:54 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:46:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:46:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:46:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 84000 (45 MB)
2022-07-04 19:46:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:46:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:46:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:46:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:47:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 85000 (46 MB)
2022-07-04 19:48:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 86000 (47 MB)
2022-07-04 19:48:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:48:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:49:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 87000 (47 MB)
2022-07-04 19:50:59 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:50:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 88000 (48 MB)
2022-07-04 19:50:59 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:52:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 89000 (48 MB)
2022-07-04 19:53:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:53:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:53:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 90000 (49 MB)
2022-07-04 19:54:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:54:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:54:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:54:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 91000 (49 MB)
2022-07-04 19:55:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:55:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:55:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 92000 (50 MB)
2022-07-04 19:55:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:55:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:56:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 93000 (50 MB)
2022-07-04 19:57:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 94000 (51 MB)
2022-07-04 19:58:06 source > 'nil' is not of type 'null', 'number'
2022-07-04 19:58:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 95000 (52 MB)
2022-07-04 19:59:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 96000 (52 MB)
2022-07-04 20:00:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 97000 (53 MB)
2022-07-04 20:01:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 98000 (53 MB)
2022-07-04 20:01:10 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:02:11 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:02:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 99000 (54 MB)
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 100000 (54 MB)
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:03:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:04:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:04:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 101000 (55 MB)
2022-07-04 20:04:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:05:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 102000 (55 MB)
2022-07-04 20:06:15 source > [] is not of type 'null', 'number'
2022-07-04 20:06:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:06:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 103000 (56 MB)
2022-07-04 20:06:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:07:16 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:07:16 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:07:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 104000 (57 MB)
2022-07-04 20:07:16 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:08:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 105000 (57 MB)
2022-07-04 20:09:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 106000 (58 MB)
2022-07-04 20:10:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:10:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:10:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 107000 (58 MB)
2022-07-04 20:10:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:10:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:10:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:10:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:11:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 108000 (59 MB)
2022-07-04 20:12:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 109000 (59 MB)
2022-07-04 20:12:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:13:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:13:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 110000 (60 MB)
2022-07-04 20:14:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 111000 (60 MB)
2022-07-04 20:15:25 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:15:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 112000 (61 MB)
2022-07-04 20:16:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 113000 (61 MB)
2022-07-04 20:17:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:17:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 114000 (62 MB)
2022-07-04 20:17:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:17:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 115000 (63 MB)
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:18:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:19:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 116000 (63 MB)
2022-07-04 20:20:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 117000 (64 MB)
2022-07-04 20:21:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 118000 (64 MB)
2022-07-04 20:22:33 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:22:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 119000 (65 MB)
2022-07-04 20:23:34 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:23:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 120000 (65 MB)
2022-07-04 20:24:35 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:24:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 121000 (66 MB)
2022-07-04 20:25:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 122000 (66 MB)
2022-07-04 20:25:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:25:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:26:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 123000 (67 MB)
2022-07-04 20:27:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 124000 (67 MB)
2022-07-04 20:27:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:28:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:28:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 125000 (68 MB)
2022-07-04 20:29:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:29:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 126000 (69 MB)
2022-07-04 20:30:41 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:30:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 127000 (69 MB)
2022-07-04 20:30:41 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:31:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 128000 (70 MB)
2022-07-04 20:32:43 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:32:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 129000 (70 MB)
2022-07-04 20:32:43 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 130000 (71 MB)
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:33:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:34:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 131000 (71 MB)
2022-07-04 20:35:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:35:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 132000 (72 MB)
2022-07-04 20:36:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 133000 (72 MB)
2022-07-04 20:36:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:37:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 134000 (73 MB)
2022-07-04 20:38:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:38:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 135000 (73 MB)
2022-07-04 20:38:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:39:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:39:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:39:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 136000 (74 MB)
2022-07-04 20:39:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:40:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:40:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:40:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:40:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 137000 (74 MB)
2022-07-04 20:40:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:41:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 138000 (75 MB)
2022-07-04 20:42:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 139000 (75 MB)
2022-07-04 20:43:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:43:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 140000 (76 MB)
2022-07-04 20:45:00 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:45:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 141000 (77 MB)
2022-07-04 20:46:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 142000 (77 MB)
2022-07-04 20:47:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:47:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 143000 (78 MB)
2022-07-04 20:47:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:48:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 144000 (78 MB)
2022-07-04 20:48:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:48:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:48:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 145000 (79 MB)
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:50:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 146000 (79 MB)
2022-07-04 20:51:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 147000 (80 MB)
2022-07-04 20:52:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 148000 (81 MB)
2022-07-04 20:53:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 149000 (81 MB)
2022-07-04 20:54:10 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:54:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 150000 (82 MB)
2022-07-04 20:54:10 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:55:11 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:55:11 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:55:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 151000 (82 MB)
2022-07-04 20:55:11 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:56:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:56:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:56:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:56:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 152000 (83 MB)
2022-07-04 20:56:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:56:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:56:12 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 20:57:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 153000 (83 MB)
2022-07-04 20:58:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 154000 (84 MB)
2022-07-04 20:59:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 155000 (84 MB)
2022-07-04 21:00:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 156000 (85 MB)
2022-07-04 21:00:17 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:01:17 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:01:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 157000 (85 MB)
2022-07-04 21:02:18 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:02:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 158000 (86 MB)
2022-07-04 21:03:19 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:03:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:03:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 159000 (86 MB)
2022-07-04 21:03:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:03:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:20 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 160000 (87 MB)
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:04:21 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:05:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 161000 (88 MB)
2022-07-04 21:06:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 162000 (88 MB)
2022-07-04 21:07:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 163000 (89 MB)
2022-07-04 21:08:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 164000 (89 MB)
2022-07-04 21:09:25 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:09:26 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:09:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 165000 (90 MB)
2022-07-04 21:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 166000 (90 MB)
2022-07-04 21:10:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:11:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:11:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:11:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:11:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 167000 (91 MB)
2022-07-04 21:11:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:12:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 168000 (91 MB)
2022-07-04 21:13:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 169000 (92 MB)
2022-07-04 21:14:31 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:14:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 170000 (92 MB)
2022-07-04 21:15:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 171000 (93 MB)
2022-07-04 21:16:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 172000 (94 MB)
2022-07-04 21:17:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 173000 (94 MB)
2022-07-04 21:18:35 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:18:35 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:18:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 174000 (95 MB)
2022-07-04 21:19:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 175000 (95 MB)
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:19:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:36 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:20:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 176000 (96 MB)
2022-07-04 21:21:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 177000 (96 MB)
2022-07-04 21:22:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:22:39 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:22:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 178000 (97 MB)
2022-07-04 21:23:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 179000 (97 MB)
2022-07-04 21:24:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 180000 (98 MB)
2022-07-04 21:24:41 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:25:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:25:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:25:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 181000 (98 MB)
2022-07-04 21:25:42 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:26:43 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:26:43 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:26:43 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:26:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 182000 (99 MB)
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:27:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 183000 (100 MB)
2022-07-04 21:28:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 184000 (100 MB)
2022-07-04 21:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:29:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 185000 (101 MB)
2022-07-04 21:30:47 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:30:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 186000 (101 MB)
2022-07-04 21:31:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:31:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:31:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 187000 (102 MB)
2022-07-04 21:32:49 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:32:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 188000 (102 MB)
2022-07-04 21:33:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:33:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 189000 (103 MB)
2022-07-04 21:34:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:34:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 190000 (103 MB)
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:35:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 191000 (104 MB)
2022-07-04 21:36:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 192000 (104 MB)
2022-07-04 21:37:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 193000 (105 MB)
2022-07-04 21:38:55 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:38:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 194000 (106 MB)
2022-07-04 21:39:56 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 195000 (106 MB)
2022-07-04 21:39:56 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:40:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:40:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 196000 (107 MB)
2022-07-04 21:41:58 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:41:58 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:41:58 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:41:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 197000 (107 MB)
2022-07-04 21:41:58 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:42:59 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:42:59 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:42:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 198000 (108 MB)
2022-07-04 21:42:59 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:42:59 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:42:59 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:44:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 199000 (108 MB)
2022-07-04 21:44:00 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:45:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:45:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 200000 (109 MB)
2022-07-04 21:46:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 201000 (109 MB)
2022-07-04 21:46:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:46:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:47:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 202000 (110 MB)
2022-07-04 21:47:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:47:03 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:48:04 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:48:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 203000 (110 MB)
2022-07-04 21:48:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:49:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:49:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 204000 (111 MB)
2022-07-04 21:50:06 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:50:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 205000 (112 MB)
2022-07-04 21:50:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:51:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 206000 (112 MB)
2022-07-04 21:52:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 207000 (113 MB)
2022-07-04 21:53:10 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 208000 (113 MB)
2022-07-04 21:54:11 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 209000 (114 MB)
2022-07-04 21:55:12 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 210000 (114 MB)
2022-07-04 21:56:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:56:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:56:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:56:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 211000 (115 MB)
2022-07-04 21:56:13 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:57:14 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:57:14 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 212000 (115 MB)
2022-07-04 21:57:14 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 213000 (116 MB)
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:58:15 source > 'nil' is not of type 'null', 'number'
2022-07-04 21:59:16 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 214000 (116 MB)
2022-07-04 21:59:16 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:00:17 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 215000 (117 MB)
2022-07-04 22:01:18 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 216000 (118 MB)
2022-07-04 22:01:18 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:02:19 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 217000 (118 MB)
2022-07-04 22:03:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 218000 (119 MB)
2022-07-04 22:04:21 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 219000 (119 MB)
2022-07-04 22:05:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:05:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:05:22 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:05:22 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 220000 (120 MB)
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:06:23 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 221000 (120 MB)
2022-07-04 22:07:24 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 222000 (121 MB)
2022-07-04 22:08:25 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 223000 (121 MB)
2022-07-04 22:08:25 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:08:25 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:09:26 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:09:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 224000 (122 MB)
2022-07-04 22:10:27 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 225000 (123 MB)
2022-07-04 22:10:27 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:11:28 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:11:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 226000 (123 MB)
2022-07-04 22:12:29 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:12:29 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 227000 (124 MB)
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 228000 (124 MB)
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:13:30 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:14:31 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 229000 (125 MB)
2022-07-04 22:15:32 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:15:32 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 230000 (125 MB)
2022-07-04 22:16:33 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 231000 (126 MB)
2022-07-04 22:16:33 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:17:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 232000 (126 MB)
2022-07-04 22:18:35 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:18:35 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 233000 (127 MB)
2022-07-04 22:18:35 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:19:36 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 234000 (127 MB)
2022-07-04 22:20:37 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:20:37 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 235000 (128 MB)
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:21:38 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 236000 (128 MB)
2022-07-04 22:22:39 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 237000 (129 MB)
2022-07-04 22:23:40 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:23:40 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 238000 (130 MB)
2022-07-04 22:24:41 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 239000 (130 MB)
2022-07-04 22:24:41 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:25:42 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 240000 (131 MB)
2022-07-04 22:26:43 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 241000 (131 MB)
2022-07-04 22:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:27:44 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:27:44 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 242000 (132 MB)
2022-07-04 22:28:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:28:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:28:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 243000 (132 MB)
2022-07-04 22:28:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:28:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:28:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:28:45 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:29:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 244000 (133 MB)
2022-07-04 22:30:47 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 245000 (133 MB)
2022-07-04 22:31:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:31:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 246000 (134 MB)
2022-07-04 22:31:48 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:32:49 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 247000 (135 MB)
2022-07-04 22:33:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:33:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:33:50 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:33:50 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 248000 (135 MB)
2022-07-04 22:34:51 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:34:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 249000 (136 MB)
2022-07-04 22:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:35:52 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 250000 (136 MB)
2022-07-04 22:35:52 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:36:53 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 251000 (137 MB)
2022-07-04 22:37:54 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 252000 (137 MB)
2022-07-04 22:37:54 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:37:54 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:38:55 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 253000 (138 MB)
2022-07-04 22:39:57 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 254000 (138 MB)
2022-07-04 22:40:57 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:40:58 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 255000 (139 MB)
2022-07-04 22:41:59 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 256000 (139 MB)
2022-07-04 22:43:00 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:43:00 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:43:00 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 257000 (140 MB)
2022-07-04 22:43:00 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:44:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:44:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:44:01 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 258000 (141 MB)
2022-07-04 22:44:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:44:01 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:45:02 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 259000 (141 MB)
2022-07-04 22:46:03 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 260000 (142 MB)
2022-07-04 22:47:04 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 261000 (142 MB)
2022-07-04 22:48:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:48:05 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 262000 (143 MB)
2022-07-04 22:48:05 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:49:06 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 263000 (143 MB)
2022-07-04 22:50:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:50:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:50:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 264000 (144 MB)
2022-07-04 22:50:07 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:51:08 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:51:08 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:51:08 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:51:08 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:51:08 source > 'nil' is not of type 'null', 'number'
2022-07-04 22:51:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):324 - Records read: 265000 (144 MB)
2022-07-04 22:51:56 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):194 - Running sync worker cancellation...
2022-07-04 22:51:56 INFO i.a.w.g.DefaultReplicationWorker(cancel):443 - Cancelling replication worker...
2022-07-04 22:52:06 INFO i.a.w.g.DefaultReplicationWorker(cancel):451 - Cancelling destination...
2022-07-04 22:52:06 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2022-07-04 22:52:06 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2022-07-04 22:52:06 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other.
2022-07-04 22:52:06 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-destination gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-07-04 22:52:06 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2022-07-04 22:52:06 INFO i.a.w.g.DefaultReplicationWorker(cancel):458 - Cancelling source...
2022-07-04 22:52:06 INFO i.a.w.i.DefaultAirbyteSource(cancel):142 - Attempting to cancel source process...
2022-07-04 22:52:06 INFO i.a.w.i.DefaultAirbyteSource(cancel):147 - Source process exists, cancelling...
2022-07-04 22:52:06 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete.
2022-07-04 22:52:06 INFO i.a.w.i.DefaultAirbyteSource(cancel):149 - Cancelled source process!
2022-07-04 22:52:06 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):198 - Interrupting worker thread...
2022-07-04 22:52:06 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):201 - Cancelling completable future...
2022-07-04 22:52:06 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-07-04 22:52:06 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-07-04 22:52:06 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2022-07-04 22:52:06 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...
2022-07-04 22:52:06 ERROR i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:178) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: java.io.IOException: Stream closed
		at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
		at java.io.OutputStream.write(OutputStream.java:162) ~[?:?]
		at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) ~[?:?]
		at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:320) ~[?:?]
		at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?]
		at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.notifyEndOfInput(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:137) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-07-04 22:52:06 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=e6036d80-b094-318c-9760-557c7552e2f3, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:289) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:115) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.util.concurrent.CancellationException
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:204) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:207) ~[io.airbyte-airbyte-workers-0.39.32-alpha.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	... 3 more
2022-07-04 22:52:06 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@661ee644[status=cancelled,recordsSynced=265310,bytesSynced=152027994,startTime=1656958696416,endTime=1656975126501,totalStats=io.airbyte.config.SyncStats@7063b1db[recordsEmitted=265310,bytesEmitted=152027994,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@73309849[streamName=cohort_members,stats=io.airbyte.config.SyncStats@52aa5b16[recordsEmitted=265307,bytesEmitted=152027690,stateMessagesEmitted=<null>,recordsCommitted=<null>]], io.airbyte.config.StreamSyncStats@4397bbc1[streamName=annotations,stats=io.airbyte.config.SyncStats@2e973701[recordsEmitted=3,bytesEmitted=304,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-07-04 22:52:06 INFO i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-07-04 22:52:06 WARN i.a.w.g.DefaultReplicationWorker(run):276 - State capture: No new state, falling back on input state: io.airbyte.config.State@5992004a[state={}]