2022-01-19 05:47:09 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.4-alpha
2022-01-19 05:47:09 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Cloud storage job log path: /workspace/854/0/logs.log
2022-01-19 05:47:09 INFO i.a.w.t.TemporalAttemptExecution(get):123 - Executing worker wrapper. Airbyte version: 0.35.4-alpha
2022-01-19 05:47:09 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-01-19 05:47:09 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-01-19 05:47:26 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:25 INFO i.a.i.d.p.PostgresDestination(main):69 - {} - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-01-19 05:47:26 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Starting syncing SourceMailchimp
2022-01-19 05:47:26 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Syncing stream: campaigns 
2022-01-19 05:47:09 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-01-19 05:47:09 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-01-19 05:47:09 INFO i.a.w.DefaultReplicationWorker(run):99 - start sync worker. job id: 854 attempt id: 0
2022-01-19 05:47:09 INFO i.a.w.DefaultReplicationWorker(run):108 - configured sync modes: {null.campaigns=full_refresh - append, null.lists=full_refresh - append, null.email_activity=full_refresh - append}
2022-01-19 05:47:09 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-01-19 05:47:09 INFO i.a.w.p.KubeProcessFactory(create):112 - Attempting to start pod = destination-postgres-sync-854-0-sunno
2022-01-19 05:47:09 INFO i.a.w.p.KubeProcessFactory(create):115 - destination-postgres-sync-854-0-sunno stdoutLocalPort = 9010
2022-01-19 05:47:09 INFO i.a.w.p.KubeProcessFactory(create):118 - destination-postgres-sync-854-0-sunno stderrLocalPort = 9011
2022-01-19 05:47:09 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):506 - Creating stdout socket server...
2022-01-19 05:47:09 INFO i.a.w.p.KubePodProcess(<init>):465 - Creating pod...
2022-01-19 05:47:09 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):517 - Creating stderr socket server...
2022-01-19 05:47:09 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):275 - Waiting for init container to be ready before copying files...
2022-01-19 05:47:09 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):278 - Init container present..
2022-01-19 05:47:12 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):281 - Init container ready..
2022-01-19 05:47:12 INFO i.a.w.p.KubePodProcess(<init>):470 - Copying files...
2022-01-19 05:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):229 - Uploading file: destination_config.json
2022-01-19 05:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):237 - kubectl cp /tmp/1daef006-b6d0-4858-b57b-077e45dda3c0/destination_config.json airbyte/destination-postgres-sync-854-0-sunno:/config/destination_config.json -c init
2022-01-19 05:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Waiting for kubectl cp to complete
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - kubectl cp complete, closing process
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):229 - Uploading file: destination_catalog.json
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):237 - kubectl cp /tmp/94e0b245-9d81-42ee-a98a-bd46a19272aa/destination_catalog.json airbyte/destination-postgres-sync-854-0-sunno:/config/destination_catalog.json -c init
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Waiting for kubectl cp to complete
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - kubectl cp complete, closing process
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):229 - Uploading file: FINISHED_UPLOADING
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):237 - kubectl cp /tmp/bebf9b97-7cc6-4108-aebe-ba3eb7fbdf75/FINISHED_UPLOADING airbyte/destination-postgres-sync-854-0-sunno:/config/FINISHED_UPLOADING -c init
2022-01-19 05:47:13 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Waiting for kubectl cp to complete
2022-01-19 05:47:14 INFO i.a.w.p.KubePodProcess(waitForInitPodToTerminate):292 - Waiting for init container to terminate before checking exit value...
2022-01-19 05:47:15 INFO i.a.w.p.KubePodProcess(waitForInitPodToTerminate):297 - Init container terminated with exit value 0.
2022-01-19 05:47:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - Init was successful; ignoring non-zero kubectl cp exit code for success indicator file.
2022-01-19 05:47:15 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - kubectl cp complete, closing process
2022-01-19 05:47:15 INFO i.a.w.p.KubePodProcess(<init>):473 - Waiting until pod is ready...
2022-01-19 05:47:15 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):508 - Setting stdout...
2022-01-19 05:47:16 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):519 - Setting stderr...
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(<init>):487 - Reading pod IP...
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(<init>):489 - Pod IP: 10.38.0.226
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(<init>):492 - Creating stdin socket...
2022-01-19 05:47:17 INFO i.a.w.p.KubeProcessFactory(create):112 - Attempting to start pod = source-mailchimp-sync-854-0-qdpqw
2022-01-19 05:47:17 INFO i.a.w.p.KubeProcessFactory(create):115 - source-mailchimp-sync-854-0-qdpqw stdoutLocalPort = 9018
2022-01-19 05:47:17 INFO i.a.w.p.KubeProcessFactory(create):118 - source-mailchimp-sync-854-0-qdpqw stderrLocalPort = 9019
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):506 - Creating stdout socket server...
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):517 - Creating stderr socket server...
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(<init>):465 - Creating pod...
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):275 - Waiting for init container to be ready before copying files...
2022-01-19 05:47:17 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):278 - Init container present..
2022-01-19 05:47:21 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):281 - Init container ready..
2022-01-19 05:47:21 INFO i.a.w.p.KubePodProcess(<init>):470 - Copying files...
2022-01-19 05:47:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):229 - Uploading file: source_config.json
2022-01-19 05:47:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):237 - kubectl cp /tmp/f203d572-a93b-428c-98b9-a73914528c51/source_config.json airbyte/source-mailchimp-sync-854-0-qdpqw:/config/source_config.json -c init
2022-01-19 05:47:21 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Waiting for kubectl cp to complete
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - kubectl cp complete, closing process
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):229 - Uploading file: source_catalog.json
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):237 - kubectl cp /tmp/0161b178-4293-4fbd-bde7-457aedb6e90b/source_catalog.json airbyte/source-mailchimp-sync-854-0-qdpqw:/config/source_catalog.json -c init
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Waiting for kubectl cp to complete
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - kubectl cp complete, closing process
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):229 - Uploading file: FINISHED_UPLOADING
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):237 - kubectl cp /tmp/81c9ef3f-d9df-4e8e-b97a-47e6dee4f8c6/FINISHED_UPLOADING airbyte/source-mailchimp-sync-854-0-qdpqw:/config/FINISHED_UPLOADING -c init
2022-01-19 05:47:22 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Waiting for kubectl cp to complete
2022-01-19 05:47:23 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - kubectl cp complete, closing process
2022-01-19 05:47:23 INFO i.a.w.p.KubePodProcess(<init>):473 - Waiting until pod is ready...
2022-01-19 05:47:24 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$7):508 - Setting stdout...
2022-01-19 05:47:24 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):519 - Setting stderr...
2022-01-19 05:47:26 INFO i.a.w.p.KubePodProcess(<init>):487 - Reading pod IP...
2022-01-19 05:47:26 INFO i.a.w.p.KubePodProcess(<init>):489 - Pod IP: 10.38.0.241
2022-01-19 05:47:26 INFO i.a.w.p.KubePodProcess(<init>):496 - Using null stdin output stream...
2022-01-19 05:47:26 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):242 - Destination output thread started.
2022-01-19 05:47:26 INFO i.a.w.DefaultReplicationWorker(run):130 - Waiting for source and destination threads to complete.
2022-01-19 05:47:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Replication thread started.
2022-01-19 05:47:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 1000
2022-01-19 05:48:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 2000
2022-01-19 05:47:26 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:26 INFO i.a.i.b.IntegrationRunner(run):76 - {} - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-01-19 05:47:26 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:26 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-01-19 05:47:26 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:26 INFO i.a.i.b.IntegrationRunner(run):80 - {} - Command: WRITE
2022-01-19 05:47:26 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:26 INFO i.a.i.b.IntegrationRunner(run):81 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-01-19 05:47:27 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:27 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-01-19 05:47:27 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:27 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-01-19 05:47:27 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:27 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-01-19 05:47:27 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:27 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-01-19 05:47:28 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:28 INFO i.a.i.b.s.SshTunnel(getInstance):170 - {} - Starting connection with method: NO_TUNNEL
2022-01-19 05:47:28 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:28 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=campaigns, namespace=null, outputSchemaName=mailchimp, tmpTableName=_airbyte_tmp_ifz_campaigns, outputTableName=_airbyte_raw_campaigns, syncMode=append}
2022-01-19 05:47:28 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:28 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=email_activity, namespace=null, outputSchemaName=mailchimp, tmpTableName=_airbyte_tmp_yik_email_activity, outputTableName=_airbyte_raw_email_activity, syncMode=append}
2022-01-19 05:47:28 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:28 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=lists, namespace=null, outputSchemaName=mailchimp, tmpTableName=_airbyte_tmp_kij_lists, outputTableName=_airbyte_raw_lists, syncMode=append}
2022-01-19 05:47:28 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:28 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):125 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-01-19 05:47:28 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:28 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - {} - Preparing tmp tables in destination started for 3 streams
2022-01-19 05:47:28 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:28 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - {} - Preparing tmp table in destination started for stream campaigns. schema: mailchimp, tmp table name: _airbyte_tmp_ifz_campaigns
2022-01-19 05:47:29 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Read 70 records from campaigns stream
2022-01-19 05:47:29 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Finished syncing SourceMailchimp
2022-01-19 05:47:29 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - SourceMailchimp runtimes:

2022-01-19 05:47:29 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Syncing stream: email_activity 
2022-01-19 05:47:31 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - {} - Preparing tmp table in destination started for stream email_activity. schema: mailchimp, tmp table name: _airbyte_tmp_yik_email_activity
2022-01-19 05:47:31 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - {} - Preparing tmp table in destination started for stream lists. schema: mailchimp, tmp table name: _airbyte_tmp_kij_lists
2022-01-19 05:47:31 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 05:47:31 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - {} - Preparing tables in destination completed.
2022-01-19 05:48:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 3000
2022-01-19 05:48:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 4000
2022-01-19 05:48:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 5000
2022-01-19 05:49:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 6000
2022-01-19 05:49:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 7000
2022-01-19 05:49:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 8000
2022-01-19 05:49:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 9000
2022-01-19 05:50:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 10000
2022-01-19 05:50:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 11000
2022-01-19 05:50:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 12000
2022-01-19 05:50:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 13000
2022-01-19 05:51:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 14000
2022-01-19 05:51:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 15000
2022-01-19 05:51:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 16000
2022-01-19 05:51:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 17000
2022-01-19 05:52:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 18000
2022-01-19 05:52:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 19000
2022-01-19 05:52:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 20000
2022-01-19 05:52:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 21000
2022-01-19 05:53:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 22000
2022-01-19 05:53:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 23000
2022-01-19 05:53:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 24000
2022-01-19 05:54:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 25000
2022-01-19 05:54:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 26000
2022-01-19 05:54:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 27000
2022-01-19 05:54:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 28000
2022-01-19 05:54:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 29000
2022-01-19 05:55:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 30000
2022-01-19 05:55:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 31000
2022-01-19 05:55:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 32000
2022-01-19 05:56:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 33000
2022-01-19 05:56:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 34000
2022-01-19 05:56:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 35000
2022-01-19 05:56:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 36000
2022-01-19 05:58:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 37000
2022-01-19 05:58:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 38000
2022-01-19 05:58:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 39000
2022-01-19 05:59:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 40000
2022-01-19 05:59:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 41000
2022-01-19 05:59:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 42000
2022-01-19 05:59:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 43000
2022-01-19 06:00:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 44000
2022-01-19 06:00:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 45000
2022-01-19 06:00:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 46000
2022-01-19 06:01:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 47000
2022-01-19 06:01:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 48000
2022-01-19 06:01:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 49000
2022-01-19 06:01:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 50000
2022-01-19 06:02:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 51000
2022-01-19 06:02:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 52000
2022-01-19 06:02:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 53000
2022-01-19 06:02:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 54000
2022-01-19 06:03:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 55000
2022-01-19 06:03:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 56000
2022-01-19 06:03:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 57000
2022-01-19 06:03:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 58000
2022-01-19 06:03:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 59000
2022-01-19 06:03:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 60000
2022-01-19 06:04:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 61000
2022-01-19 06:04:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 62000
2022-01-19 06:04:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 63000
2022-01-19 06:04:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 64000
2022-01-19 06:05:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 65000
2022-01-19 06:05:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 66000
2022-01-19 06:05:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 67000
2022-01-19 06:05:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 68000
2022-01-19 06:06:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 69000
2022-01-19 06:06:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 70000
2022-01-19 06:07:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 71000
2022-01-19 06:07:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 72000
2022-01-19 06:07:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 73000
2022-01-19 06:08:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 74000
2022-01-19 06:08:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 75000
2022-01-19 06:08:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 76000
2022-01-19 06:09:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 77000
2022-01-19 06:09:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 78000
2022-01-19 06:10:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 79000
2022-01-19 06:10:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 80000
2022-01-19 06:11:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 81000
2022-01-19 06:11:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 82000
2022-01-19 06:11:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 83000
2022-01-19 06:12:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 84000
2022-01-19 06:12:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 85000
2022-01-19 06:12:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 86000
2022-01-19 06:12:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 87000
2022-01-19 06:13:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 88000
2022-01-19 06:13:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 89000
2022-01-19 06:14:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 90000
2022-01-19 06:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 91000
2022-01-19 06:14:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 92000
2022-01-19 06:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 93000
2022-01-19 06:15:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 94000
2022-01-19 06:15:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 95000
2022-01-19 06:15:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 96000
2022-01-19 06:15:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 97000
2022-01-19 06:15:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 98000
2022-01-19 06:16:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 99000
2022-01-19 06:16:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 100000
2022-01-19 06:16:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 101000
2022-01-19 06:16:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 102000
2022-01-19 06:16:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 103000
2022-01-19 06:17:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 104000
2022-01-19 06:17:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 105000
2022-01-19 06:17:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 106000
2022-01-19 06:17:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 107000
2022-01-19 06:17:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 108000
2022-01-19 06:18:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 109000
2022-01-19 06:18:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 110000
2022-01-19 06:18:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 111000
2022-01-19 06:18:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 112000
2022-01-19 06:18:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 113000
2022-01-19 06:19:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 114000
2022-01-19 06:19:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 115000
2022-01-19 06:19:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 116000
2022-01-19 06:19:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 117000
2022-01-19 06:19:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 118000
2022-01-19 06:20:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 119000
2022-01-19 06:20:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 120000
2022-01-19 06:20:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 121000
2022-01-19 06:20:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 122000
2022-01-19 06:20:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 123000
2022-01-19 06:21:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 124000
2022-01-19 06:21:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 125000
2022-01-19 06:21:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 126000
2022-01-19 06:21:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 127000
2022-01-19 06:21:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 128000
2022-01-19 06:21:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 129000
2022-01-19 06:21:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 130000
2022-01-19 06:22:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 131000
2022-01-19 06:22:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 132000
2022-01-19 06:22:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 133000
2022-01-19 06:22:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 134000
2022-01-19 06:22:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 135000
2022-01-19 06:23:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 136000
2022-01-19 06:23:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 137000
2022-01-19 06:23:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 138000
2022-01-19 06:23:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 139000
2022-01-19 06:23:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 140000
2022-01-19 06:24:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 141000
2022-01-19 06:24:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 142000
2022-01-19 06:24:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 143000
2022-01-19 06:24:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 144000
2022-01-19 06:25:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 145000
2022-01-19 06:25:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 146000
2022-01-19 06:25:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 147000
2022-01-19 06:26:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 148000
2022-01-19 06:26:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 149000
2022-01-19 06:26:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 150000
2022-01-19 06:26:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 151000
2022-01-19 06:27:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 152000
2022-01-19 06:27:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 153000
2022-01-19 06:27:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 154000
2022-01-19 06:27:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 155000
2022-01-19 06:28:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 156000
2022-01-19 06:28:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 157000
2022-01-19 06:28:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 158000
2022-01-19 06:29:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 159000
2022-01-19 06:29:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 160000
2022-01-19 06:29:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 161000
2022-01-19 06:29:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 162000
2022-01-19 06:29:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 163000
2022-01-19 06:30:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 164000
2022-01-19 06:30:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 165000
2022-01-19 06:30:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 166000
2022-01-19 06:31:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 167000
2022-01-19 06:31:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 168000
2022-01-19 06:31:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 169000
2022-01-19 06:31:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 170000
2022-01-19 06:32:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 171000
2022-01-19 06:32:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 172000
2022-01-19 06:32:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 173000
2022-01-19 06:32:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 174000
2022-01-19 06:32:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 175000
2022-01-19 06:33:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 176000
2022-01-19 06:33:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 177000
2022-01-19 06:33:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 178000
2022-01-19 06:33:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 179000
2022-01-19 06:33:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 180000
2022-01-19 06:33:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 181000
2022-01-19 06:34:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 182000
2022-01-19 06:34:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 183000
2022-01-19 06:34:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 184000
2022-01-19 06:34:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 185000
2022-01-19 06:35:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 186000
2022-01-19 06:35:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 187000
2022-01-19 06:35:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 188000
2022-01-19 06:36:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 189000
2022-01-19 06:36:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 190000
2022-01-19 06:36:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 191000
2022-01-19 06:37:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 192000
2022-01-19 06:37:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 193000
2022-01-19 06:37:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 194000
2022-01-19 06:38:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 195000
2022-01-19 06:38:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 196000
2022-01-19 06:38:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 197000
2022-01-19 06:39:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 198000
2022-01-19 06:39:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 199000
2022-01-19 06:39:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 200000
2022-01-19 06:39:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 201000
2022-01-19 06:40:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 202000
2022-01-19 06:40:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 203000
2022-01-19 06:40:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 204000
2022-01-19 06:41:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 205000
2022-01-19 06:41:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 206000
2022-01-19 06:41:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 207000
2022-01-19 06:42:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 208000
2022-01-19 06:42:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 209000
2022-01-19 06:42:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 210000
2022-01-19 06:43:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 211000
2022-01-19 06:43:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 212000
2022-01-19 06:43:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 213000
2022-01-19 06:44:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 214000
2022-01-19 06:44:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 215000
2022-01-19 06:44:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 216000
2022-01-19 06:45:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 217000
2022-01-19 06:45:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 218000
2022-01-19 06:46:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 219000
2022-01-19 06:46:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 220000
2022-01-19 06:46:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 221000
2022-01-19 06:47:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 222000
2022-01-19 06:47:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 223000
2022-01-19 06:47:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 224000
2022-01-19 06:48:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 225000
2022-01-19 06:48:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 226000
2022-01-19 06:49:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 227000
2022-01-19 06:49:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 228000
2022-01-19 06:49:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 229000
2022-01-19 06:49:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 230000
2022-01-19 06:50:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 231000
2022-01-19 06:50:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 232000
2022-01-19 06:50:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 233000
2022-01-19 06:51:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 234000
2022-01-19 06:51:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 235000
2022-01-19 06:51:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 236000
2022-01-19 06:51:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 237000
2022-01-19 06:52:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 238000
2022-01-19 06:52:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 239000
2022-01-19 06:52:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 240000
2022-01-19 06:53:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 241000
2022-01-19 06:53:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 242000
2022-01-19 06:53:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 243000
2022-01-19 06:53:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 244000
2022-01-19 06:54:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 245000
2022-01-19 06:54:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 246000
2022-01-19 06:54:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 247000
2022-01-19 06:54:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 248000
2022-01-19 06:55:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 249000
2022-01-19 06:55:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 250000
2022-01-19 06:55:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 251000
2022-01-19 06:56:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 252000
2022-01-19 06:56:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 253000
2022-01-19 06:56:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 254000
2022-01-19 06:56:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 255000
2022-01-19 06:56:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 256000
2022-01-19 06:56:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 257000
2022-01-19 06:56:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 258000
2022-01-19 06:56:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 259000
2022-01-19 06:57:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 260000
2022-01-19 06:57:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 261000
2022-01-19 06:57:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 262000
2022-01-19 06:57:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 263000
2022-01-19 06:57:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 264000
2022-01-19 06:57:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 265000
2022-01-19 06:58:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 266000
2022-01-19 06:58:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 267000
2022-01-19 06:58:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 268000
2022-01-19 06:58:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 269000
2022-01-19 06:58:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 270000
2022-01-19 06:59:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 271000
2022-01-19 06:59:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 272000
2022-01-19 06:59:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 273000
2022-01-19 06:59:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 274000
2022-01-19 06:59:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 275000
2022-01-19 06:59:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 276000
2022-01-19 07:00:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 277000
2022-01-19 07:00:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 278000
2022-01-19 07:00:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 279000
2022-01-19 07:00:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 280000
2022-01-19 07:01:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 281000
2022-01-19 07:01:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 282000
2022-01-19 07:01:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 283000
2022-01-19 07:01:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 284000
2022-01-19 07:01:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 285000
2022-01-19 07:02:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 286000
2022-01-19 07:02:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 287000
2022-01-19 07:02:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 288000
2022-01-19 07:02:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 289000
2022-01-19 07:02:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 290000
2022-01-19 07:03:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 291000
2022-01-19 07:03:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 292000
2022-01-19 07:03:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 293000
2022-01-19 07:03:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 294000
2022-01-19 07:04:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 295000
2022-01-19 07:04:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 296000
2022-01-19 07:04:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 297000
2022-01-19 07:04:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 298000
2022-01-19 07:04:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 299000
2022-01-19 07:04:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 300000
2022-01-19 07:04:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 301000
2022-01-19 07:05:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 302000
2022-01-19 07:05:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 303000
2022-01-19 07:05:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 304000
2022-01-19 07:05:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 305000
2022-01-19 07:05:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 306000
2022-01-19 07:05:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 307000
2022-01-19 07:06:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 308000
2022-01-19 07:06:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 309000
2022-01-19 07:06:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 310000
2022-01-19 07:06:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 311000
2022-01-19 07:06:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 312000
2022-01-19 07:06:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 313000
2022-01-19 07:06:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 314000
2022-01-19 07:07:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 315000
2022-01-19 07:07:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 316000
2022-01-19 07:07:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 317000
2022-01-19 07:07:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 318000
2022-01-19 07:07:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 319000
2022-01-19 07:07:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 320000
2022-01-19 07:07:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 321000
2022-01-19 07:08:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 322000
2022-01-19 07:08:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 323000
2022-01-19 07:08:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 324000
2022-01-19 07:08:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 325000
2022-01-19 07:08:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 326000
2022-01-19 07:08:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 327000
2022-01-19 07:08:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 328000
2022-01-19 07:09:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 329000
2022-01-19 07:09:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 330000
2022-01-19 07:09:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 331000
2022-01-19 07:09:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 332000
2022-01-19 07:09:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 333000
2022-01-19 07:09:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 334000
2022-01-19 07:10:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 335000
2022-01-19 07:10:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 336000
2022-01-19 07:10:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 337000
2022-01-19 07:10:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 338000
2022-01-19 07:11:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 339000
2022-01-19 07:11:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 340000
2022-01-19 07:11:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 341000
2022-01-19 07:11:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 342000
2022-01-19 07:11:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 343000
2022-01-19 07:12:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 344000
2022-01-19 07:12:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 345000
2022-01-19 07:12:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 346000
2022-01-19 07:12:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 347000
2022-01-19 07:12:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 348000
2022-01-19 07:13:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 349000
2022-01-19 07:13:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 350000
2022-01-19 07:13:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 351000
2022-01-19 07:13:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 352000
2022-01-19 07:14:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 353000
2022-01-19 07:14:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 354000
2022-01-19 07:14:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 355000
2022-01-19 07:14:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 356000
2022-01-19 07:14:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 357000
2022-01-19 07:15:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 358000
2022-01-19 07:15:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 359000
2022-01-19 07:15:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 360000
2022-01-19 07:16:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 361000
2022-01-19 07:16:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 362000
2022-01-19 07:16:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 363000
2022-01-19 07:16:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 364000
2022-01-19 07:17:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 365000
2022-01-19 07:17:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 366000
2022-01-19 07:17:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 367000
2022-01-19 07:17:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 368000
2022-01-19 07:18:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 369000
2022-01-19 07:18:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 370000
2022-01-19 07:18:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 371000
2022-01-19 07:18:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 372000
2022-01-19 07:19:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 373000
2022-01-19 07:19:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 374000
2022-01-19 07:19:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 375000
2022-01-19 07:19:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 376000
2022-01-19 07:19:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 377000
2022-01-19 07:19:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 378000
2022-01-19 07:20:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 379000
2022-01-19 07:20:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 380000
2022-01-19 07:20:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 381000
2022-01-19 07:20:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 382000
2022-01-19 07:20:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 383000
2022-01-19 07:20:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 384000
2022-01-19 07:20:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 385000
2022-01-19 07:21:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 386000
2022-01-19 07:21:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 387000
2022-01-19 07:21:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 388000
2022-01-19 07:21:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 389000
2022-01-19 07:21:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 390000
2022-01-19 07:21:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 391000
2022-01-19 07:21:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 392000
2022-01-19 07:21:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 393000
2022-01-19 07:22:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 394000
2022-01-19 07:22:15 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 395000
2022-01-19 07:22:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 396000
2022-01-19 07:22:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 397000
2022-01-19 07:22:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 398000
2022-01-19 07:22:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 399000
2022-01-19 07:22:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 400000
2022-01-19 07:22:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 401000
2022-01-19 07:22:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 402000
2022-01-19 07:23:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 403000
2022-01-19 07:23:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 404000
2022-01-19 07:23:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 405000
2022-01-19 07:23:26 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 406000
2022-01-19 07:23:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 407000
2022-01-19 07:23:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 408000
2022-01-19 07:23:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 409000
2022-01-19 07:23:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 410000
2022-01-19 07:23:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 411000
2022-01-19 07:24:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 412000
2022-01-19 07:24:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 413000
2022-01-19 07:24:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 414000
2022-01-19 07:24:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 415000
2022-01-19 07:24:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 416000
2022-01-19 07:24:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 417000
2022-01-19 07:24:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 418000
2022-01-19 07:25:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 419000
2022-01-19 07:25:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 420000
2022-01-19 07:26:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 421000
2022-01-19 07:26:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 422000
2022-01-19 07:26:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 423000
2022-01-19 07:26:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 424000
2022-01-19 07:27:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 425000
2022-01-19 07:27:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 426000
2022-01-19 07:28:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 427000
2022-01-19 07:28:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 428000
2022-01-19 07:28:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 429000
2022-01-19 07:29:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 430000
2022-01-19 07:29:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 431000
2022-01-19 07:29:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 432000
2022-01-19 07:30:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 433000
2022-01-19 07:30:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 434000
2022-01-19 07:31:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 435000
2022-01-19 07:31:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 436000
2022-01-19 07:31:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 437000
2022-01-19 07:31:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 438000
2022-01-19 07:32:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 439000
2022-01-19 07:32:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 440000
2022-01-19 07:32:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 441000
2022-01-19 07:32:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 442000
2022-01-19 07:32:51 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 443000
2022-01-19 07:32:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 444000
2022-01-19 07:33:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 445000
2022-01-19 07:33:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 446000
2022-01-19 07:33:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 447000
2022-01-19 07:33:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 448000
2022-01-19 07:33:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 449000
2022-01-19 07:34:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 450000
2022-01-19 07:34:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 451000
2022-01-19 07:34:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 452000
2022-01-19 07:34:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 453000
2022-01-19 07:34:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 454000
2022-01-19 07:35:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 455000
2022-01-19 07:35:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 456000
2022-01-19 07:35:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 457000
2022-01-19 07:35:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 458000
2022-01-19 07:36:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 459000
2022-01-19 07:36:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 460000
2022-01-19 07:36:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 461000
2022-01-19 07:36:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 462000
2022-01-19 07:36:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 463000
2022-01-19 07:37:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 464000
2022-01-19 07:37:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 465000
2022-01-19 07:37:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 466000
2022-01-19 07:37:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 467000
2022-01-19 07:37:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 468000
2022-01-19 07:38:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 469000
2022-01-19 07:38:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 470000
2022-01-19 07:38:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 471000
2022-01-19 07:38:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 472000
2022-01-19 07:38:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 473000
2022-01-19 07:39:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 474000
2022-01-19 07:39:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 475000
2022-01-19 07:39:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 476000
2022-01-19 07:39:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 477000
2022-01-19 07:39:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 478000
2022-01-19 07:40:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 479000
2022-01-19 07:40:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 480000
2022-01-19 07:40:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 481000
2022-01-19 07:40:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 482000
2022-01-19 07:40:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 483000
2022-01-19 07:41:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 484000
2022-01-19 07:41:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 485000
2022-01-19 07:41:27 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 486000
2022-01-19 07:41:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 487000
2022-01-19 07:41:38 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 488000
2022-01-19 07:41:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 489000
2022-01-19 07:41:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 490000
2022-01-19 07:41:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 491000
2022-01-19 07:42:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 492000
2022-01-19 07:42:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 493000
2022-01-19 07:42:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 494000
2022-01-19 07:42:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 495000
2022-01-19 07:42:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 496000
2022-01-19 07:42:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 497000
2022-01-19 07:42:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 498000
2022-01-19 07:42:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 499000
2022-01-19 07:43:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 500000
2022-01-19 07:43:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 501000
2022-01-19 07:43:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 502000
2022-01-19 07:43:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 503000
2022-01-19 07:43:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 504000
2022-01-19 07:43:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 505000
2022-01-19 07:43:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 506000
2022-01-19 07:43:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 507000
2022-01-19 07:43:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 508000
2022-01-19 07:44:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 509000
2022-01-19 07:44:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 510000
2022-01-19 07:44:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 511000
2022-01-19 07:44:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 512000
2022-01-19 07:45:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 513000
2022-01-19 07:45:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 514000
2022-01-19 07:45:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 515000
2022-01-19 07:45:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 516000
2022-01-19 07:46:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 517000
2022-01-19 07:46:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 518000
2022-01-19 07:46:46 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 519000
2022-01-19 07:47:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 520000
2022-01-19 07:47:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 521000
2022-01-19 07:47:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 522000
2022-01-19 07:47:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 523000
2022-01-19 07:48:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 524000
2022-01-19 07:48:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 525000
2022-01-19 07:48:37 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 526000
2022-01-19 07:48:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 527000
2022-01-19 07:49:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 528000
2022-01-19 07:49:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 529000
2022-01-19 07:49:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 530000
2022-01-19 07:49:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 531000
2022-01-19 07:50:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 532000
2022-01-19 07:50:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 533000
2022-01-19 07:50:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 534000
2022-01-19 07:51:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 535000
2022-01-19 07:51:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 536000
2022-01-19 07:51:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 537000
2022-01-19 07:51:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 538000
2022-01-19 07:52:02 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 539000
2022-01-19 07:52:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 540000
2022-01-19 07:52:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 541000
2022-01-19 07:52:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 542000
2022-01-19 07:52:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 543000
2022-01-19 07:52:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 544000
2022-01-19 07:53:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 545000
2022-01-19 07:53:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 546000
2022-01-19 07:53:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 547000
2022-01-19 07:53:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 548000
2022-01-19 07:53:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 549000
2022-01-19 07:53:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 550000
2022-01-19 07:54:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 551000
2022-01-19 07:54:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 552000
2022-01-19 07:54:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 553000
2022-01-19 07:54:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 554000
2022-01-19 07:54:49 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 555000
2022-01-19 07:54:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 556000
2022-01-19 07:55:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 557000
2022-01-19 07:55:22 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 558000
2022-01-19 07:55:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 559000
2022-01-19 07:55:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 560000
2022-01-19 07:55:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 561000
2022-01-19 07:56:01 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 562000
2022-01-19 07:56:12 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 563000
2022-01-19 07:56:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 564000
2022-01-19 07:56:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 565000
2022-01-19 07:56:39 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 566000
2022-01-19 07:56:48 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 567000
2022-01-19 07:56:56 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 568000
2022-01-19 07:57:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 569000
2022-01-19 07:57:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 570000
2022-01-19 07:57:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 571000
2022-01-19 07:57:42 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 572000
2022-01-19 07:57:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 573000
2022-01-19 07:58:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 574000
2022-01-19 07:58:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 575000
2022-01-19 07:58:29 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 576000
2022-01-19 07:58:40 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 577000
2022-01-19 07:58:54 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 578000
2022-01-19 07:59:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 579000
2022-01-19 07:59:17 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 580000
2022-01-19 07:59:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 581000
2022-01-19 07:59:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 582000
2022-01-19 07:59:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 583000
2022-01-19 08:00:03 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 584000
2022-01-19 08:00:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 585000
2022-01-19 08:00:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 586000
2022-01-19 08:00:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 587000
2022-01-19 08:00:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 588000
2022-01-19 08:01:09 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 589000
2022-01-19 08:01:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 590000
2022-01-19 08:01:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 591000
2022-01-19 08:01:47 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 592000
2022-01-19 08:01:59 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 593000
2022-01-19 08:02:11 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 594000
2022-01-19 08:02:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 595000
2022-01-19 08:02:32 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 596000
2022-01-19 08:02:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 597000
2022-01-19 08:02:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 598000
2022-01-19 08:02:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 599000
2022-01-19 08:03:05 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 600000
2022-01-19 08:03:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 601000
2022-01-19 08:03:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 602000
2022-01-19 08:03:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 603000
2022-01-19 08:03:31 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 604000
2022-01-19 08:03:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 605000
2022-01-19 08:03:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 606000
2022-01-19 08:03:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 607000
2022-01-19 08:04:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 608000
2022-01-19 08:04:07 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 609000
2022-01-19 08:04:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 610000
2022-01-19 08:04:33 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 611000
2022-01-19 08:05:00 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 612000
2022-01-19 08:05:28 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 613000
2022-01-19 08:05:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 614000
2022-01-19 08:06:21 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 615000
2022-01-19 08:06:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 616000
2022-01-19 08:07:10 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 617000
2022-01-19 08:07:34 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 618000
2022-01-19 08:07:57 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 619000
2022-01-19 08:08:19 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 620000
2022-01-19 08:08:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 621000
2022-01-19 08:08:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 622000
2022-01-19 08:09:08 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 623000
2022-01-19 08:09:25 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 624000
2022-01-19 08:09:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 625000
2022-01-19 08:09:52 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 626000
2022-01-19 08:09:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 627000
2022-01-19 08:10:06 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 628000
2022-01-19 08:11:09 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Read 636853 records from email_activity stream
2022-01-19 08:10:13 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 629000
2022-01-19 08:10:24 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 630000
2022-01-19 08:10:30 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 631000
2022-01-19 08:10:36 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 632000
2022-01-19 08:10:43 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 633000
2022-01-19 08:10:50 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 634000
2022-01-19 08:10:58 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 635000
2022-01-19 08:11:04 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):216 - Records read: 636000
2022-01-19 08:11:09 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Finished syncing SourceMailchimp
2022-01-19 08:11:09 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - SourceMailchimp runtimes:

2022-01-19 08:11:09 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Syncing stream: lists 
2022-01-19 08:11:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Read 4 records from lists stream
2022-01-19 08:11:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Finished syncing SourceMailchimp
2022-01-19 08:11:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - SourceMailchimp runtimes:

2022-01-19 08:11:10 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(internalLog):97 - Finished syncing SourceMailchimp
2022-01-19 08:11:41 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:41 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - {} - Airbyte message consumer: succeeded.
2022-01-19 08:11:41 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:41 INFO i.a.i.d.b.BufferedStreamConsumer(close):200 - {} - executing on success close procedure.
2022-01-19 08:11:46 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - {} - Finalizing tables in destination started for 3 streams
2022-01-19 08:11:46 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - {} - Finalizing stream campaigns. schema mailchimp, tmp table _airbyte_tmp_ifz_campaigns, final table _airbyte_raw_campaigns
2022-01-19 08:11:46 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - {} - Finalizing stream email_activity. schema mailchimp, tmp table _airbyte_tmp_yik_email_activity, final table _airbyte_raw_email_activity
2022-01-19 08:11:46 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - {} - Finalizing stream lists. schema mailchimp, tmp table _airbyte_tmp_kij_lists, final table _airbyte_raw_lists
2022-01-19 08:11:46 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:46 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - {} - Executing finalization of tables.
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - {} - Finalizing tables in destination completed.
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - {} - Cleaning tmp tables in destination started for 3 streams
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Cleaning tmp table in destination started for stream campaigns. schema mailchimp, tmp table name: _airbyte_tmp_ifz_campaigns
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Cleaning tmp table in destination started for stream email_activity. schema mailchimp, tmp table name: _airbyte_tmp_yik_email_activity
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Cleaning tmp table in destination started for stream lists. schema mailchimp, tmp table name: _airbyte_tmp_kij_lists
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - {} - Cleaning tmp tables in destination completed.
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.b.IntegrationRunner(run):133 - {} - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-01-19 08:11:58 INFO i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-01-19 08:11:58 INFO i.a.i.d.p.PostgresDestination(main):71 - {} - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-01-19 08:12:10 INFO i.a.w.t.TemporalAttemptExecution(get):120 - Cloud storage job log path: /workspace/854/0/logs.log
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(getReturnCode):676 - Exit code for pod destination-postgres-sync-854-0-sunno is 0
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(exitValue):691 - Closed all resources for pod destination-postgres-sync-854-0-sunno
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(exitValue):691 - Closed all resources for pod destination-postgres-sync-854-0-sunno
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(exitValue):691 - Closed all resources for pod destination-postgres-sync-854-0-sunno
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(exitValue):691 - Closed all resources for pod destination-postgres-sync-854-0-sunno
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(exitValue):691 - Closed all resources for pod destination-postgres-sync-854-0-sunno
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(exitValue):691 - Closed all resources for pod destination-postgres-sync-854-0-sunno
2022-01-19 08:12:10 INFO i.a.w.p.KubePodProcess(exitValue):691 - Closed all resources for pod destination-postgres-sync-854-0-sunno
2022-01-19 08:12:10 ERROR i.a.w.DefaultReplicationWorker(run):141 - Sync worker failed.
java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.RuntimeException: Cannot find pod while trying to retrieve exit code. This probably means the Pod was not correctly created.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:134) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:49) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: java.lang.RuntimeException: Cannot find pod while trying to retrieve exit code. This probably means the Pod was not correctly created.
		at io.airbyte.workers.process.KubePodProcess.getReturnCode(KubePodProcess.java:657) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
		at io.airbyte.workers.process.KubePodProcess.exitValue(KubePodProcess.java:684) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
		at java.lang.Process.hasExited(Process.java:584) ~[?:?]
		at java.lang.Process.isAlive(Process.java:574) ~[?:?]
		at io.airbyte.workers.WorkerUtils.gentleClose(WorkerUtils.java:36) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:128) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:118) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:49) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Cannot find pod while trying to retrieve exit code. This probably means the Pod was not correctly created.
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$2(DefaultReplicationWorker.java:230) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
Caused by: java.lang.RuntimeException: Cannot find pod while trying to retrieve exit code. This probably means the Pod was not correctly created.
	at io.airbyte.workers.process.KubePodProcess.getReturnCode(KubePodProcess.java:657) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.process.KubePodProcess.exitValue(KubePodProcess.java:684) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at java.lang.Process.hasExited(Process.java:584) ~[?:?]
	at java.lang.Process.isAlive(Process.java:574) ~[?:?]
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.isFinished(DefaultAirbyteSource.java:98) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$2(DefaultReplicationWorker.java:206) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-01-19 08:12:10 INFO i.a.w.DefaultReplicationWorker(run):165 - sync summary: io.airbyte.config.ReplicationAttemptSummary@28d81e29[status=failed,recordsSynced=636927,bytesSynced=608850380,startTime=1642571229741,endTime=1642579930628]
2022-01-19 08:12:10 INFO i.a.w.DefaultReplicationWorker(run):174 - Source did not output any state messages
2022-01-19 08:12:10 WARN i.a.w.DefaultReplicationWorker(run):185 - State capture: No state retained.
2022-01-19 08:12:10 INFO i.a.w.t.TemporalAttemptExecution(get):144 - Stopping cancellation check scheduling...
2022-01-19 08:12:10 INFO i.a.w.t.s.ReplicationActivityImpl(replicate):144 - sync summary: io.airbyte.config.StandardSyncOutput@3039b022[standardSyncSummary=io.airbyte.config.StandardSyncSummary@3fd38725[status=failed,recordsSynced=636927,bytesSynced=608850380,startTime=1642571229741,endTime=1642579930628],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@670b2047[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@71a6039[stream=io.airbyte.protocol.models.AirbyteStream@7a5f7858[name=campaigns,jsonSchema={"type":"object","title":"Campaign","properties":{"id":{"type":"string","title":"Campaign ID","readOnly":true,"description":"A string that uniquely identifies this campaign."},"type":{"enum":["regular","plaintext","absplit","rss","variate"],"type":"string","title":"Campaign Type","description":"There are four types of [campaigns](https://mailchimp.com/help/getting-started-with-campaigns/) you can create in Mailchimp. A/B Split campaigns have been deprecated and variate campaigns should be used instead."},"status":{"enum":["save","paused","schedule","sending","sent","canceled","canceling","archived"],"type":"string","title":"Campaign Status","readOnly":true,"description":"The current status of the campaign."},"web_id":{"type":"integer","title":"Campaign Web ID","readOnly":true,"description":"The ID used in the Mailchimp web application. View this campaign in your Mailchimp account at `https://{dc}.admin.mailchimp.com/campaigns/show/?id={web_id}`."},"rss_opts":{"type":"object","title":"RSS Options","properties":{"feed_url":{"type":"string","title":"Feed URL","format":"uri","description":"The URL for the RSS feed."},"schedule":{"type":"object","title":"Sending Schedule","properties":{"hour":{"type":"integer","title":"Sending Hour","maximum":23,"minimum":0,"description":"The hour to send the campaign in local time. Acceptable hours are 0-23. For example, '4' would be 4am in [your account's default time zone](https://mailchimp.com/help/set-account-defaults/)."},"daily_send":{"type":"object","title":"Daily Sending Days","properties":{"friday":{"type":"boolean","title":"Friday","description":"Sends the daily RSS Campaign on Fridays."},"monday":{"type":"boolean","title":"Monday","description":"Sends the daily RSS Campaign on Mondays."},"sunday":{"type":"boolean","title":"Sunday","description":"Sends the daily RSS Campaign on Sundays."},"tuesday":{"type":"boolean","title":"tuesday","description":"Sends the daily RSS Campaign on Tuesdays."},"saturday":{"type":"boolean","title":"Saturday","description":"Sends the daily RSS Campaign on Saturdays."},"thursday":{"type":"boolean","title":"Thursday","description":"Sends the daily RSS Campaign on Thursdays."},"wednesday":{"type":"boolean","title":"Monday","description":"Sends the daily RSS Campaign on Wednesdays."}},"description":"The days of the week to send a daily RSS Campaign."},"weekly_send_day":{"enum":["sunday","monday","tuesday","wednesday","thursday","friday","saturday"],"type":"string","title":"Weekly Sending Day","description":"The day of the week to send a weekly RSS Campaign."},"monthly_send_date":{"type":"number","title":"Monthly Sending Day","maximum":31,"minimum":0,"description":"The day of the month to send a monthly RSS Campaign. Acceptable days are 0-31, where '0' is always the last day of a month. Months with fewer than the selected number of days will not have an RSS campaign sent out that day. For example, RSS Campaigns set to send on the 30th will not go out in February."}},"description":"The schedule for sending the RSS Campaign."},"frequency":{"enum":["daily","weekly","monthly"],"type":"string","title":"Frequency","description":"The frequency of the RSS Campaign."},"last_sent":{"type":"string","title":"Last Sent","readOnly":true,"description":"The date the campaign was last sent."},"constrain_rss_img":{"type":"boolean","title":"Constrain RSS Images","description":"Whether to add CSS to images in the RSS feed to constrain their width in campaigns."}},"description":"[RSS](https://mailchimp.com/help/share-your-blog-posts-with-mailchimp/) options for a campaign."},"settings":{"type":"object","title":"Campaign Settings","properties":{"title":{"type":"string","title":"Campaign Title","description":"The title of the campaign."},"to_name":{"type":"string","title":"To Name","description":"The campaign's custom 'To' name. Typically the first name [merge field](https://mailchimp.com/help/getting-started-with-merge-tags/)."},"reply_to":{"type":"string","title":"Reply To Address","description":"The reply-to email address for the campaign."},"timewarp":{"type":"boolean","title":"Timewarp Send","readOnly":true,"description":"Send this campaign using [Timewarp](https://mailchimp.com/help/use-timewarp/)."},"folder_id":{"type":"string","title":"Folder ID","description":"If the campaign is listed in a folder, the id for that folder."},"from_name":{"type":"string","title":"From Name","description":"The 'from' name on the campaign (not an email address)."},"auto_tweet":{"type":"boolean","title":"Auto-Tweet","description":"Automatically tweet a link to the [campaign archive](https://mailchimp.com/help/about-email-campaign-archives-and-pages/) page when the campaign is sent."},"inline_css":{"type":"boolean","title":"Inline CSS","description":"Automatically inline the CSS included with the campaign content."},"auto_footer":{"type":"boolean","title":"Auto-Footer","description":"Automatically append Mailchimp's [default footer](https://mailchimp.com/help/about-campaign-footers/) to the campaign."},"fb_comments":{"type":"boolean","title":"Facebook Comments","description":"Allows Facebook comments on the campaign (also force-enables the Campaign Archive toolbar). Defaults to `true`."},"template_id":{"type":"integer","title":"Template ID","readOnly":false,"description":"The id for the template used in this campaign."},"authenticate":{"type":"boolean","title":"Authentication","description":"Whether Mailchimp [authenticated](https://mailchimp.com/help/about-email-authentication/) the campaign. Defaults to `true`."},"auto_fb_post":{"type":"array","items":{"type":"string"},"title":"Auto Post to Facebook","description":"An array of [Facebook](https://mailchimp.com/help/connect-or-disconnect-the-facebook-integration/) page ids to auto-post to."},"preview_text":{"type":"string","title":"Campaign Preview Text","description":"The preview text for the campaign."},"subject_line":{"type":"string","title":"Campaign Subject Line","description":"The subject line for the campaign."},"drag_and_drop":{"type":"boolean","title":"Drag And Drop Campaign","readOnly":true,"description":"Whether the campaign uses the drag-and-drop editor."},"use_conversation":{"type":"boolean","title":"Conversation","description":"Use Mailchimp Conversation feature to manage out-of-office replies."}},"description":"The settings for your campaign, including subject, from name, reply-to address, and more."},"tracking":{"type":"object","title":"Campaign Tracking Options","properties":{"opens":{"type":"boolean","title":"Opens","description":"Whether to [track opens](https://mailchimp.com/help/about-open-tracking/). Defaults to `true`. Cannot be set to false for variate campaigns."},"capsule":{"type":"object","title":"Capsule CRM Tracking","properties":{"notes":{"type":"boolean","title":"Capsule Note","description":"Update contact notes for a campaign based on subscriber email addresses."}},"description":"Capsule tracking options for a campaign. Must be using Mailchimp's built-in Capsule integration."},"ecomm360":{"type":"boolean","title":"E-commerce Tracking","description":"Whether to enable [eCommerce360](https://mailchimp.com/help/connect-your-online-store-to-mailchimp/) tracking."},"clicktale":{"type":"string","title":"ClickTale Analytics Tracking","description":"The custom slug for [ClickTale](https://mailchimp.com/help/additional-tracking-options-for-campaigns/) tracking (max of 50 bytes)."},"salesforce":{"type":"object","title":"Salesforce CRM Tracking","properties":{"notes":{"type":"boolean","title":"Salesforce Note","description":"Update contact notes for a campaign based on subscriber email addresses."},"campaign":{"type":"boolean","title":"Salesforce Campaign","description":"Create a campaign in a connected Salesforce account."}},"description":"Salesforce tracking options for a campaign. Must be using Mailchimp's built-in [Salesforce integration](https://mailchimp.com/help/integrate-salesforce-with-mailchimp/)."},"html_clicks":{"type":"boolean","title":"HTML Click Tracking","description":"Whether to [track clicks](https://mailchimp.com/help/enable-and-view-click-tracking/) in the HTML version of the campaign. Defaults to `true`. Cannot be set to false for variate campaigns."},"text_clicks":{"type":"boolean","title":"Plain-Text Click Tracking","description":"Whether to [track clicks](https://mailchimp.com/help/enable-and-view-click-tracking/) in the plain-text version of the campaign. Defaults to `true`. Cannot be set to false for variate campaigns."},"goal_tracking":{"type":"boolean","title":"Mailchimp Goal Tracking","description":"Whether to enable [Goal](https://mailchimp.com/help/about-connected-sites/) tracking."},"google_analytics":{"type":"string","title":"Google Analytics Tracking","description":"The custom slug for [Google Analytics](https://mailchimp.com/help/integrate-google-analytics-with-mailchimp/) tracking (max of 50 bytes)."}},"description":"The tracking options for a campaign."},"send_time":{"type":"string","title":"Send Time","readOnly":true,"description":"The date and time a campaign was sent."},"recipients":{"type":"object","title":"List","properties":{"list_id":{"type":"string","title":"List ID","description":"The unique list id."},"list_name":{"type":"string","title":"List Name","readOnly":true,"description":"The name of the list."},"segment_opts":{"type":"object","title":"Segment Options","properties":{"match":{"enum":["any","all"],"type":"string","title":"Match Type","description":"Segment match type."},"conditions":{"type":"array","items":{"oneOf":[{"type":"object","title":"Aim Segment","properties":{"op":{"enum":["open","click","sent","noopen","noclick","nosent"],"type":"string","title":"Segment Operator","example":"open","description":"The status of the member with regard to their campaign interaction. One of the following: opened, clicked, was sent, didn't open, didn't click, or was not sent."},"field":{"enum":["aim"],"type":"string","title":"Segment Field","example":"aim","description":"Segment by interaction with a specific campaign."},"value":{"type":"string","title":"Segment Data","example":"any","description":"Either the web id value for a specific campaign or 'any' to account for subscribers who have/have not interacted with any campaigns."},"condition_type":{"enum":["Aim"],"type":"string","x-value":"Aim"}},"description":"Segment by interaction with a specific campaign."},{"type":"object","title":"Automation Segment","required":["field","op","value"],"properties":{"op":{"enum":["started","completed","not_started","not_completed"],"type":"string","title":"Segment Operator","example":"started","description":"The status of the member with regard to the automation workflow. One of the following: has started the workflow, has completed the workflow, has not started the workflow, or has not completed the workflow."},"field":{"enum":["automation"],"type":"string","title":"Segment Field","example":"automation","description":"Segment by interaction with an Automation workflow."},"value":{"type":"string","title":"Segment Data","example":"2135217","description":"The web id for the automation workflow to segment against."},"condition_type":{"enum":["Automation"],"type":"string","x-value":"Automation"}},"description":"Segment by interaction with an Automation workflow."},{"type":"object","title":"Poll Activity Segment","required":["field","op","value"],"properties":{"op":{"enum":["member","notmember"],"type":"string","title":"Segment Operator","example":"member","description":"Members have/have not interacted with a specific poll in a Mailchimp email."},"field":{"enum":["poll"],"type":"string","title":"Segment Field","example":"poll","description":"Segment by poll activity."},"value":{"type":"number","title":"Segment Operator","example":409,"description":"The id for the poll."},"condition_type":{"enum":["CampaignPoll"],"type":"string","x-value":"CampaignPoll"}},"description":"Segment by poll activity."},{"type":"object","title":"Conversation Segment","required":["field","op","value"],"properties":{"op":{"enum":["member","notmember"],"type":"string","title":"Segment Operator","example":"member","description":"The status of a member's interaction with a conversation. One of the following: has replied or has not replied."},"field":{"enum":["conversation"],"type":"string","title":"Segment Field","example":"conversation","description":"Segment by interaction with a campaign via Conversations."},"value":{"type":"string","title":"Segment Data","example":"any","description":"The web id value for a specific campaign or 'any' to account for subscribers who have/have not interacted with any campaigns."},"condition_type":{"enum":["Conversation"],"type":"string","x-value":"Conversation"}},"description":"Segment by interaction with a campaign via Conversations."},{"type":"object","title":"Date Segment","required":["field","op","value"],"properties":{"op":{"enum":["greater","less","is","not","blank","blank_not","within","notwithin"],"type":"string","title":"Segment Operator","example":"greater","description":"When the event took place:  Before, after, is a specific date, is not a specific date, is blank, or is not blank."},"extra":{"type":"string","title":"Segment Extra Value","example":"2015-01-30","description":"When segmenting on 'date' or 'campaign', the date for the segment formatted as YYYY-MM-DD or the web id for the campaign."},"field":{"enum":["timestamp_opt","info_changed","ecomm_date"],"type":"string","title":"Segment Field","example":"timestamp_opt","description":"The type of date field to segment on: The opt-in time for a signup, the date the subscriber was last updated, or the date of their last ecomm purchase."},"value":{"type":"string","title":"Segment Data","example":"date","description":"What type of data to segment on: a specific date, a specific campaign, or the last campaign sent."},"condition_type":{"enum":["Date"],"type":"string","x-value":"Date"}},"description":"Segment by a specific date field."},{"type":"object","title":"Email Client Segment","required":["field","op","value"],"properties":{"op":{"enum":["client_is","client_not"],"type":"string","title":"Segment Operator","example":"client_is","description":"The operation to determine whether we select clients that match the value, or clients that do not match the value."},"field":{"enum":["email_client"],"type":"string","title":"Segment Field","example":"email_client","description":"Segment by use of a particular email client."},"value":{"type":"string","title":"Segment Data","example":"Gmail","description":"The name of the email client."},"condition_type":{"enum":["EmailClient"],"type":"string","x-value":"EmailClient"}},"description":"Segment by use of a particular email client."},{"type":"object","title":"Language Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","not"],"type":"string","title":"Segment Operator","example":"is","description":"Whether the member's language is or is not set to a specific language."},"field":{"enum":["language"],"type":"string","title":"Segment Field","example":"language","description":"Segmenting based off of a subscriber's language."},"value":{"type":"string","title":"Segment Data","example":"en","description":"A two-letter language identifier."},"condition_type":{"enum":["Language"],"type":"string","x-value":"Language"}},"description":"Segment by language."},{"type":"object","title":"Member Rating Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","not","greater","less"],"type":"string","title":"Segment Operator","example":"greater","description":"Members who have have a rating that is/not exactly a given number or members who have a rating greater/less than a given number."},"field":{"enum":["rating"],"type":"string","title":"Segment Field","example":"rating","description":"Segment by member rating."},"value":{"type":"number","title":"Segment Operator","example":4,"description":"The star rating number to segment against."},"condition_type":{"enum":["MemberRating"],"type":"string","x-value":"MemberRating"}},"description":"Segment by member rating."},{"type":"object","title":"Signup Source Segment","required":["field","condition_type","op"],"properties":{"op":{"enum":["source_is","source_not"],"type":"string","title":"Segment Operator","example":"source_is","description":"Whether the member's signup source was/was not a particular value."},"field":{"enum":["source"],"type":"string","title":"Segment Field","example":"source"},"value":{"type":"string","title":"Segment Data","example":"List Import","description":"The signup source."},"condition_type":{"enum":["SignupSource"],"type":"string","title":"Type","x-value":"SignupSource"}},"description":"Segment by signup source."},{"type":"object","title":"SurveyMonkey Segment","required":["field","op","value"],"properties":{"op":{"enum":["started","completed","not_started","not_completed"],"type":"string","title":"Segment Operator","example":"started","description":"The status of the member with regard to the survey. One of the following: has started the survey, has completed the survey, has not started the survey, or has not completed the survey."},"field":{"enum":["survey_monkey"],"type":"string","title":"Segment Field","example":"survey_monkey","description":"Segment by interaction with a SurveyMonkey survey."},"value":{"type":"string","title":"Survey ID","example":"32179586","description":"The unique ID of the SurveyMonkey survey."},"condition_type":{"enum":["SurveyMonkey"],"type":"string","x-value":"SurveyMonkey"}},"description":"Segment by interaction with a SurveyMonkey survey."},{"type":"object","title":"VIP Segment","required":["field","op"],"properties":{"op":{"enum":["member","notmember"],"type":"string","title":"Segment Operator","example":"member","description":"Whether the member is or is not marked as VIP."},"field":{"enum":["gmonkey"],"type":"string","title":"Segment Field","example":"gmonkey","description":"Segment by VIP status."},"condition_type":{"enum":["VIP"],"type":"string","x-value":"VIP"}},"description":"Segment by VIP status."},{"type":"object","title":"Interests Segment","properties":{"op":{"enum":["interestcontains","interestcontainsall","interestnotcontains"],"type":"string","title":"Segment Operator","example":"interestcontains","description":"Whether the member is a part of one, all, or none of the groups."},"field":{"type":"string","title":"Segment Field","example":"interests-123","description":"Segmenting based on interest group information. This should start with 'interests-' followed by the grouping id. Ex. 'interests-123'."},"value":{"type":"array","items":{"type":"string","example":["44401","44405","44409"]},"title":"Segment Value","description":"An array containing strings, each representing a group id."},"condition_type":{"enum":["Interests"],"type":"string","x-value":"Interests"}},"description":"Segment by an interest group merge field."},{"type":"object","title":"Ecommerce Category Segment","properties":{"op":{"enum":["is","not","contains","notcontain","starts","ends"],"type":"string","title":"Segment Operator","example":"is","description":"A member who has purchased from a category/specific item that is/is not a specific name, where the category/item name contains/doesn't contain a specific phrase or string, or a category/item name that starts/ends with a string."},"field":{"enum":["ecomm_cat","ecomm_prod"],"type":"string","title":"Segment Field","example":"ecomm_cat","description":"Segment by purchases in specific items or categories."},"value":{"type":"string","title":"Segment Data","example":"Product","description":"The ecommerce category/item information."},"condition_type":{"enum":["EcommCategory"],"type":"string","x-value":"EcommCategory"}},"description":"Segment by purchases in specific items or categories."},{"type":"object","title":"Ecommerce Number Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","not","greater","less"],"type":"string","title":"Segment Operator","example":"greater","description":"Members who have spent exactly, have not spent exactly, spent more, or spent less than the segment value."},"field":{"enum":["ecomm_spent_avg","ecomm_orders","ecomm_prod_all","ecomm_avg_ord"],"type":"string","title":"Segment Field","example":"ecomm_orders","description":"Segment by average spent total, number of orders, total number of products purchased, or average number of products per order."},"value":{"type":"number","title":"Segment Operator","example":42,"description":"Members who have spent exactly, have not spent exactly, spent more, or spent less than this amount."},"condition_type":{"enum":["EcommNumber"],"type":"string","x-value":"EcommNumber"}},"description":"Segment by average spent total, number of orders, total number of products purchased, or average number of products per order."},{"type":"object","title":"Ecommerce Purchased Segment","properties":{"op":{"enum":["member","notmember"],"type":"string","title":"Segment Operator","example":"member","description":"Members who have have ('member') or have not ('notmember') purchased."},"field":{"enum":["ecomm_purchased"],"type":"string","title":"Segment Field","example":"ecomm_purchased","description":"Segment by whether someone has purchased anything."},"condition_type":{"enum":["EcommPurchased"],"type":"string","x-value":"EcommPurchased"}},"description":"Segment by whether someone has purchased anything."},{"type":"object","title":"Ecommerce Spent Segment","properties":{"op":{"enum":["greater","less"],"type":"string","title":"Segment Operator","example":"greater","description":"Members who have spent 'more' or 'less' than then specified value."},"field":{"enum":["ecomm_spent_one","ecomm_spent_all"],"type":"string","title":"Segment Field","example":"ecomm_spent_one","description":"Segment by amount spent on a single order or across all orders."},"value":{"type":"integer","title":"Segment Data","example":42,"description":"The total amount a member spent."},"condition_type":{"enum":["EcommSpent"],"type":"string","x-value":"EcommSpent"}},"description":"Segment by amount spent on a single order or across all orders."},{"type":"object","title":"Ecommerce Purchased Store Segment","properties":{"op":{"enum":["is","not"],"type":"string","title":"Segment Operator","example":"is","description":"Members who have or have not purchased from a specific store."},"field":{"enum":["ecomm_store"],"type":"string","title":"Segment Field","example":"ecomm_store","description":"Segment by purchases from a specific store."},"value":{"type":"string","title":"Segment Operator","example":"289","description":"The store id to segment against."},"condition_type":{"enum":["EcommStore"],"type":"string","x-value":"EcommStore"}},"description":"Segment by purchases from a specific store."},{"type":"object","title":"Goal Activity Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","goal_not","contains","goal_notcontain","starts","ends"],"type":"string","title":"Segment Operator","example":"is","description":"Whether the website URL is/not exactly, contains/doesn't contain, starts with/ends with a string."},"field":{"enum":["goal"],"type":"string","title":"Segment Field","example":"goal","description":"Segment by Goal activity."},"value":{"type":"string","title":"Segment Value","description":"The URL to check Goal activity against."},"condition_type":{"enum":["GoalActivity"],"type":"string","x-value":"GoalActivity"}},"description":"Segment by Goal activity."},{"type":"object","title":"Goal Timestamp Segment","required":["field","op","value"],"properties":{"op":{"enum":["greater","less","is"],"type":"string","title":"Segment Operator","example":"greater","description":"Whether the website activity happened after, before, or at a given timestamp."},"field":{"enum":["goal_last_visited"],"type":"string","title":"Segment Field","example":"goal_last_visited","description":"Segment by most recent interaction with a website."},"value":{"type":"string","title":"Segment Value","example":"2015-07-20 19:45:21","description":"The date to check Goal activity against."},"condition_type":{"enum":["GoalTimestamp"],"type":"string","x-value":"GoalTimestamp"}},"description":"Segment by most recent interaction with a website."},{"type":"object","title":"Similar Subscribers Segment Member Segment","required":["field","op","value"],"properties":{"op":{"enum":["fuzzy_is","fuzzy_not"],"type":"string","title":"Segment Operator","example":"fuzzy_is","description":"Members who are/are not apart of a 'similar subscribers' segment."},"field":{"enum":["fuzzy_segment"],"type":"string","title":"Segment Field","example":"fuzzy_segment","description":"Segment by similar subscribers."},"value":{"type":"number","title":"Segment Operator","example":48433,"description":"The id for the 'similar subscribers' segment."},"condition_type":{"enum":["FuzzySegment"],"type":"string","x-value":"FuzzySegment"}},"description":"Segment by similar subscribers."},{"type":"object","title":"Static Segment Member Segment","required":["field","op","value"],"properties":{"op":{"enum":["static_is","static_not"],"type":"string","title":"Segment Operator","example":"static_is","description":"Members who are/are not apart of a static segment."},"field":{"enum":["static_segment"],"type":"string","title":"Segment Field","example":"static_segment","description":"Segment by a given static segment."},"value":{"type":"number","title":"Segment Operator","example":48433,"description":"The id for the static segment."},"condition_type":{"enum":["StaticSegment"],"type":"string","x-value":"StaticSegment"}},"description":"Segment by a given static segment."},{"type":"object","title":"Location-Based Segment","required":["field","op","value"],"properties":{"op":{"enum":["ipgeocountry","ipgeonotcountry","ipgeostate","ipgeonotstate"],"type":"string","title":"Segment Operator","example":"ipgeocountry","description":"Segment members who are within a specific country or US state."},"field":{"enum":["ipgeo"],"type":"string","title":"Segment Field","example":"ipgeo","description":"Segmenting subscribers who are within a specific location."},"value":{"type":"string","title":"Segment Data","example":"US","description":"The two-letter country code or US state abbreviation."},"condition_type":{"enum":["IPGeoCountryState"],"type":"string","x-value":"IPGeoCountryState"}},"description":"Segment by a specific country or US state."},{"type":"object","title":"Geolocation Segment","required":["field","op","value","addr","lat","lng"],"properties":{"op":{"enum":["ipgeoin","ipgeonotin"],"type":"string","title":"Segment Operator","example":"ipgeoin","description":"Segment members who are within a specific geographic region."},"lat":{"type":"string","title":"Segment Location Latitude","example":"33.7489954","description":"The latitude of the target location."},"lng":{"type":"string","title":"Segment Location Longitude","example":"-84.3879824","description":"The longitude of the target location."},"addr":{"type":"string","title":"Segment Location Address","example":"Atlanta, GA, USA","description":"The address of the target location."},"field":{"enum":["ipgeo"],"type":"string","title":"Segment Field","example":"ipgeo","description":"Segmenting subscribers who are within a specific location."},"value":{"type":"integer","title":"Segment Data","example":42,"description":"The radius of the target location."},"condition_type":{"enum":["IPGeoIn"],"type":"string","x-value":"IPGeoIn"}},"description":"Segment by a specific geographic region."},{"type":"object","title":"US Zip Code Segment","required":["field","op","value","extra"],"properties":{"op":{"enum":["ipgeoinzip"],"type":"string","title":"Segment Operator","example":"ipgeoinzip","description":"Segment members who are within a specific US zip code."},"extra":{"type":"integer","title":"Extra Data","example":30318,"description":"The zip code to segment against."},"field":{"enum":["ipgeo"],"type":"string","title":"Segment Field","example":"ipgeo","description":"Segmenting subscribers who are within a specific location."},"value":{"type":"integer","title":"Segment Data","example":25,"description":"The radius of the target location."},"condition_type":{"enum":["IPGeoInZip"],"type":"string","x-value":"IPGeoInZip"}},"description":"Segment by a specific US ZIP code."},{"type":"object","title":"Unknown Location-Based Segment","required":["field","op"],"properties":{"op":{"enum":["ipgeounknown"],"type":"string","title":"Segment Operator","example":"ipgeounknown","description":"Segment members for which location information is unknown."},"field":{"enum":["ipgeo"],"type":"string","title":"Segment Field","example":"ipgeo","description":"Segmenting subscribers who are within a specific location."},"condition_type":{"enum":["IPGeoUnknown"],"type":"string","x-value":"IPGeoUnknown"}},"description":"Segment members whose location information is unknown."},{"type":"object","title":"Zip Code Location-Based Segment","required":["field","op","value"],"properties":{"op":{"enum":["ipgeoiszip","ipgeonotzip"],"type":"string","title":"Segment Operator","example":"ipgeonotzip","description":"Segment members who are/are not within a specific US zip code."},"field":{"enum":["ipgeo"],"type":"string","title":"Segment Field","example":"ipgeo","description":"Segmenting subscribers who are within a specific location."},"value":{"type":"integer","title":"Segment Data","example":30318,"description":"The 5-digit zip code."},"condition_type":{"enum":["IPGeoZip"],"type":"string","x-value":"IPGeoZip"}},"description":"Segment by a specific US ZIP code."},{"type":"object","title":"Social Profiles Age Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","not"],"type":"string","title":"Segment Operator","example":"is","description":"Members who are/not the exact criteria listed."},"field":{"enum":["social_age"],"type":"string","title":"Segment Field","example":"social_age","description":"Segment by age ranges in Social Profiles data."},"value":{"enum":["18-24","25-34","35-54","55+"],"type":"string","title":"Segment Operator","example":"35-54","description":"The age range to segment."},"condition_type":{"enum":["SocialAge"],"type":"string","x-value":"SocialAge"}},"description":"Segment by age ranges in Social Profiles data."},{"type":"object","title":"Social Profiles Gender Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","not"],"type":"string","title":"Segment Operator","example":"is","description":"Members who are/not the exact criteria listed."},"field":{"enum":["social_gender"],"type":"string","title":"Segment Field","example":"social_gender","description":"Segment by listed gender in Social Profiles data."},"value":{"enum":["male","female"],"type":"string","title":"Segment Operator","example":"female","description":"The Social Profiles gender to segment."},"condition_type":{"enum":["SocialGender"],"type":"string","x-value":"SocialGender"}},"description":"Segment by listed gender in Social Profiles data."},{"type":"object","title":"Social Profiles Influence Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","not","greater","less"],"type":"string","title":"Segment Operator","example":"greater","description":"Members who have a rating that is/not or greater/less than the rating provided."},"field":{"enum":["social_influence"],"type":"string","title":"Segment Field","example":"social_influence","description":"Segment by influence rating in Social Profiles data."},"value":{"type":"number","title":"Segment Operator","example":2,"description":"The Social Profiles influence rating to segment."},"condition_type":{"enum":["SocialInfluence"],"type":"string","x-value":"SocialInfluence"}},"description":"Segment by influence rating in Social Profiles data."},{"type":"object","title":"Social Profiles Social Network Segment","required":["field","op","value"],"properties":{"op":{"enum":["member","notmember"],"type":"string","title":"Segment Operator","example":"member","description":"Members who are/not on a given social network."},"field":{"enum":["social_network"],"type":"string","title":"Segment Field","example":"social_network","description":"Segment by social network in Social Profiles data."},"value":{"enum":["twitter","facebook","linkedin","flickr","foursquare","lastfm","myspace","quora","vimeo","yelp","youtube"],"type":"string","title":"Segment Operator","example":"twitter","description":"The social network to segment against."},"condition_type":{"enum":["SocialNetworkMember"],"type":"string","x-value":"SocialNetworkMember"}},"description":"Segment by social network in Social Profiles data."},{"type":"object","title":"Social Profiles Social Network Follow Segment","required":["field","op","value"],"properties":{"op":{"enum":["follow","notfollow"],"type":"string","title":"Segment Operator","example":"follow","description":"Members who are/not following a linked account on a given social network."},"field":{"enum":["social_network"],"type":"string","title":"Segment Field","example":"social_network","description":"Segment by social network in Social Profiles data."},"value":{"enum":["twitter_follow"],"type":"string","title":"Segment Operator","example":"twitter_follow","description":"The social network to segment against."},"condition_type":{"enum":["SocialNetworkFollow"],"type":"string","x-value":"SocialNetworkFollow"}},"description":"Segment by social network in Social Profiles data."},{"type":"object","title":"Address Merge Field Segment","required":["field","op"],"properties":{"op":{"enum":["contains","notcontain","blank","blank_not"],"type":"string","title":"Segment Operator","example":"contains","description":"Whether the member's address merge field contains/does not contain a value or is/is not blank."},"field":{"type":"string","title":"Segment Field","example":"MMERGE3","description":"An address-type merge field to segment."},"value":{"type":"string","title":"Segment Value","example":"Atlanta","description":"The value to segment a text merge field with."},"condition_type":{"enum":["AddressMerge"],"type":"string","x-value":"AddressMerge"}},"description":"Segment by an address-type merge field."},{"type":"object","title":"Address/Zip Merge Field Segment","required":["field","op","value","extra"],"properties":{"op":{"enum":["geoin"],"type":"string","title":"Segment Operator","example":"geoin","description":"Whether the member's address merge field is within a given distance from a city or zip."},"extra":{"type":"string","title":"Segment Extra","example":"30318","description":"The city or the zip being used to segment against."},"field":{"type":"string","title":"Segment Field","example":"MMERGE2","description":"An address or zip-type merge field to segment."},"value":{"type":"string","title":"Segment Value","example":"25","description":"The distance from the city/zip."},"condition_type":{"enum":["ZipMerge"],"type":"string","x-value":"ZipMerge"}},"description":"Segment by an address-type merge field within a given distance."},{"type":"object","title":"Birthday Merge Field Segment","required":["field","op"],"properties":{"op":{"enum":["is","not","blank","blank_not"],"type":"string","title":"Segment Operator","example":"is","description":"Whether the member's birthday merge information is/is not a certain date or is/is not blank."},"field":{"type":"string","title":"Segment Field","example":"MMERGE4","description":"A date merge field to segment."},"value":{"type":"string","title":"Segment Value","example":"01/30","description":"A date to segment against (mm/dd)."},"condition_type":{"enum":["BirthdayMerge"],"type":"string","x-value":"BirthdayMerge"}},"description":"Segment by a contact's birthday."},{"type":"object","title":"Date Merge Field Segment","required":["field","op"],"properties":{"op":{"enum":["is","not","less","blank","blank_not","greater"],"type":"string","title":"Segment Operator","example":"is","description":"Whether the member's merge information is/is not, is greater/less than a value or is/is not blank."},"field":{"type":"string","title":"Segment Field","example":"MMERGE5","description":"A date merge field to segment."},"value":{"type":"string","title":"Segment Value","example":"01/30/2015","description":"A date to segment against."},"condition_type":{"enum":["DateMerge"],"type":"string","x-value":"DateMerge"}},"description":"Segment by a given date merge field."},{"type":"object","title":"Dropdown/Radio Merge Field Segment","required":["field","op"],"properties":{"op":{"enum":["is","not","blank","blank_not","notcontain","contains"],"type":"string","title":"Segment Operator","example":"is","description":"Whether the member's merge information is/is not a value or is/is not blank."},"field":{"type":"string","title":"Segment Field","example":"MMERGE6","description":"A merge field to segment."},"value":{"type":"string","title":"Segment Value","example":"Second Choice","description":"The value to segment a text merge field with."},"condition_type":{"enum":["SelectMerge"],"type":"string","x-value":"SelectMerge"}},"description":"An individual segment condition"},{"type":"object","title":"Text or Number Merge Field Segment","required":["field","op"],"properties":{"op":{"enum":["is","not","contains","notcontain","starts","ends","greater","less","blank","blank_not"],"type":"string","title":"Segment Operator","example":"contains","description":"Whether the member's merge information is/is not, contains/does not contain, starts/ends with, or is greater/less than a value"},"field":{"type":"string","title":"Segment Field","example":"MMERGE7","description":"A text or number merge field to segment."},"value":{"type":"string","title":"Segment Value","example":"Freddie's Jokes","description":"The value to segment a text or number merge field with."},"condition_type":{"enum":["TextMerge"],"type":"string","x-value":"TextMerge"}},"description":"Segment by a given text or number merge field."},{"type":"object","title":"Email Segment","required":["field","op"],"properties":{"op":{"enum":["is","not","contains","notcontain","starts","ends","greater","less"],"type":"string","title":"Segment Operator","description":"Whether the email address is/not exactly, contains/doesn't contain, starts/ends with a string."},"field":{"enum":["merge0","EMAIL"],"type":"string","title":"Segment Field","example":"EMAIL","description":"Segmenting based off of a subscriber's email address."},"value":{"type":"string","title":"Segment Value","example":"urist.mcvankab@freddiesjokes.com","description":"The value to compare the email against."},"condition_type":{"enum":["EmailAddress"],"type":"string","x-value":"EmailAddress"}},"description":"Segment by email address."},{"type":"object","title":"Predicted Gender Segment","required":["field","op","value"],"properties":{"op":{"enum":["is","not"],"type":"string","title":"Segment Operator","example":"is","description":"Members who are/not the exact criteria listed."},"field":{"enum":["predicted_gender"],"type":"string","title":"Segment Field","description":"Segment by predicted gender."},"value":{"enum":["male","female"],"type":"string","title":"Segment Operator","example":"female","description":"The predicted gender to segment."},"condition_type":{"enum":["PredictedGender"],"type":"string","x-value":"PredictedGender"}},"description":"Segment by predicted gender."},{"type":"object","title":"Predicted Age Segment","required":["field","op","value"],"properties":{"op":{"enum":["is"],"type":"string","title":"Segment Operator","example":"is","description":"Members who are/not the exact criteria listed."},"field":{"enum":["predicted_age_range"],"type":"string","title":"Segment Field","description":"Segment by predicted age."},"value":{"enum":["18-24","25-34","35-44","45-54","55-64","65+"],"type":"string","title":"Segment Operator","example":"female","description":"The predicted age to segment."},"condition_type":{"enum":["PredictedAge"],"type":"string","x-value":"PredictedAge"}},"description":"Segment by predicted age."},{"type":"object","title":"New Subscribers Prebuilt Segment","properties":{"op":{"enum":["date_within"],"type":"string","title":"Segment Operator","description":"Whe the event took place, namely within a time frame."},"field":{"enum":["timestamp_opt"],"type":"string","title":"Segment Field","description":"Segment by when people subscribed."},"value":{"type":"string","title":"Segment Data","description":"What type of data to segment on: a specific date, a specific campaign, or the last campaign sent."},"condition_type":{"enum":["NewSubscribers"],"type":"string","x-value":"NewSubscribers"}},"description":"Segment by when people subscribed."}],"x-discriminator":{"type":"string","propertyName":"condition_type"}},"title":"Segment Type","description":"Segment match conditions. There are multiple possible types, see the [condition types documentation](https://mailchimp.com/developer/marketing/docs/alternative-schemas/#segment-condition-schemas)."},"saved_segment_id":{"type":"integer","title":"Saved Segment ID","description":"The id for an existing saved segment."},"prebuilt_segment_id":{"type":"string","title":"Prebuilt Segment Id","example":"subscribers-female","description":"The prebuilt segment id, if a prebuilt segment has been designated for this campaign."}},"description":"An object representing all segmentation options. This object should contain a `saved_segment_id` to use an existing segment, or you can create a new segment by including both `match` and `conditions` options."},"segment_text":{"type":"string","title":"Segment Text","readOnly":true,"description":"A description of the [segment](https://mailchimp.com/help/create-and-send-to-a-segment/) used for the campaign. Formatted as a string marked up with HTML."},"list_is_active":{"type":"boolean","title":"List Status","readOnly":true,"description":"The status of the list used, namely if it's deleted or disabled."},"recipient_count":{"type":"integer","title":"Recipient Count","readOnly":true,"description":"Count of the recipients on the associated list. Formatted as an integer."}},"description":"List settings for the campaign."},"resendable":{"type":"boolean","title":"Resendable","readOnly":true,"description":"Determines if the campaign qualifies to be resent to non-openers."},"archive_url":{"type":"string","title":"Archive URL","readOnly":true,"description":"The link to the campaign's archive version in ISO 8601 format."},"create_time":{"type":"string","title":"Create Time","readOnly":true,"description":"The date and time the campaign was created in ISO 8601 format."},"emails_sent":{"type":"integer","title":"Emails Sent","readOnly":true,"description":"The total number of emails sent for this campaign."},"social_card":{"type":"object","title":"Campaign Social Card","properties":{"title":{"type":"string","title":"Title","description":"The title for the card. Typically the subject line of the campaign."},"image_url":{"type":"string","title":"Image URL","description":"The url for the header image for the card."},"description":{"type":"string","title":"Campaign Description","description":"A short summary of the campaign to display."}},"description":"The preview for the campaign, rendered by social networks like Facebook and Twitter. [Learn more](https://mailchimp.com/help/enable-and-customize-social-cards/)."},"content_type":{"enum":["template","html","url","multichannel"],"type":"string","title":"Content Type","description":"How the campaign's content is put together."},"ab_split_opts":{"type":"object","title":"A/B Testing Options","readOnly":true,"properties":{"subject_a":{"type":"string","title":"Subject Line Group A","description":"For campaigns split on 'Subject Line', the subject line for Group A."},"subject_b":{"type":"string","title":"Subject Line Group B","description":"For campaigns split on 'Subject Line', the subject line for Group B."},"wait_time":{"type":"integer","title":"Wait Time","description":"The amount of time to wait before picking a winner. This cannot be changed after a campaign is sent."},"split_size":{"type":"integer","title":"Split Size","maximum":50,"minimum":1,"description":"The size of the split groups. Campaigns split based on 'schedule' are forced to have a 50/50 split. Valid split integers are between 1-50."},"split_test":{"enum":["subject","from_name","schedule"],"type":"string","title":"Split Test","description":"The type of AB split to run."},"wait_units":{"enum":["hours","days"],"type":"string","title":"Wait Time","description":"How unit of time for measuring the winner ('hours' or 'days'). This cannot be changed after a campaign is sent."},"from_name_a":{"type":"string","title":"From Name Group A","description":"For campaigns split on 'From Name', the name for Group A."},"from_name_b":{"type":"string","title":"From Name Group B","description":"For campaigns split on 'From Name', the name for Group B."},"pick_winner":{"enum":["opens","clicks","manual"],"type":"string","title":"Pick Winner","description":"How we should evaluate a winner. Based on 'opens', 'clicks', or 'manual'."},"send_time_a":{"type":"string","title":"Send Time Group A","description":"The send time for Group A."},"send_time_b":{"type":"string","title":"Send Time Group B","description":"The send time for Group B."},"reply_email_a":{"type":"string","title":"Reply Email Group A","description":"For campaigns split on 'From Name', the reply-to address for Group A."},"reply_email_b":{"type":"string","title":"Reply Email Group B","description":"For campaigns split on 'From Name', the reply-to address for Group B."},"send_time_winner":{"type":"string","title":"Send Time Winner","description":"The send time for the winning version."}},"description":"[A/B Testing](https://mailchimp.com/help/about-ab-testing-campaigns/) options for a campaign."},"report_summary":{"type":"object","title":"Campaign Report Summary","properties":{"opens":{"type":"integer","title":"Automation Opens","readOnly":true,"description":"The total number of opens for a campaign."},"clicks":{"type":"integer","title":"Total Clicks","readOnly":true,"description":"The total number of clicks for an campaign."},"ecommerce":{"type":"object","title":"E-Commerce Report","properties":{"total_spent":{"type":"number","title":"Total Spent","readOnly":true,"description":"The total spent for a campaign. Calculated as the sum of all order totals with no deductions."},"total_orders":{"type":"integer","title":"Total Orders","readOnly":true,"description":"The total orders for a campaign."},"total_revenue":{"type":"number","title":"Total Revenue","readOnly":true,"description":"The total revenue for a campaign. Calculated as the sum of all order totals minus shipping and tax totals."}},"description":"E-Commerce stats for a campaign."},"open_rate":{"type":"number","title":"Open Rate","readOnly":true,"description":"The number of unique opens divided by the total number of successful deliveries."},"click_rate":{"type":"number","title":"Click Rate","readOnly":true,"description":"The number of unique clicks divided by the total number of successful deliveries."},"unique_opens":{"type":"integer","title":"Unique Opens","readOnly":true,"description":"The number of unique opens."},"subscriber_clicks":{"type":"integer","title":"Unique Subscriber Clicks","readOnly":true,"description":"The number of unique clicks."}},"description":"For sent campaigns, a summary of opens, clicks, and e-commerce data."},"delivery_status":{"type":"object","title":"Campaign Delivery Status","properties":{"status":{"enum":["delivering","delivered","canceling","canceled"],"type":"string","title":"Campaign Delivery Status","readOnly":true,"description":"The current state of a campaign delivery."},"enabled":{"type":"boolean","title":"Delivery Status Enabled","readOnly":true,"description":"Whether Campaign Delivery Status is enabled for this account and campaign."},"can_cancel":{"type":"boolean","title":"Campaign Cancelable","readOnly":true,"description":"Whether a campaign send can be canceled."},"emails_sent":{"type":"integer","title":"Emails Sent","readOnly":true,"description":"The total number of emails confirmed sent for this campaign so far."},"emails_canceled":{"type":"integer","title":"Emails Canceled","readOnly":true,"description":"The total number of emails canceled for this campaign."}},"description":"Updates on campaigns in the process of sending."},"long_archive_url":{"type":"string","title":"Long Archive URL","readOnly":true,"description":"The original link to the campaign's archive version."},"variate_settings":{"type":"object","title":"A/B Test Options","properties":{"contents":{"type":"array","items":{"type":"string"},"title":"Content Descriptions","readOnly":true,"description":"Descriptions of possible email contents. To set campaign contents, make a PUT request to /campaigns/{campaign_id}/content with the field 'variate_contents'."},"test_size":{"type":"integer","title":"Test Size","description":"The percentage of recipients to send the test combinations to, must be a value between 10 and 100."},"wait_time":{"type":"integer","title":"Wait Time","description":"The number of minutes to wait before choosing the winning campaign. The value of wait_time must be greater than 0 and in whole hours, specified in minutes."},"from_names":{"type":"array","items":{"type":"string"},"title":"From Names","description":"The possible from names. The number of from_names provided must match the number of reply_to_addresses. If no from_names are provided, settings.from_name will be used."},"send_times":{"type":"array","items":{"type":"string"},"title":"Send Times","description":"The possible send times to test. The times provided should be in the format YYYY-MM-DD HH:MM:SS. If send_times are provided to test, the test_size will be set to 100% and winner_criteria will be ignored."},"combinations":{"type":"array","items":{"type":"object","properties":{"id":{"type":"string","title":"ID","description":"Unique ID for the combination."},"reply_to":{"type":"integer","title":"Reply To","description":"The index of `variate_settings.reply_to_addresses` used."},"from_name":{"type":"integer","title":"From Name","description":"The index of `variate_settings.from_names` used."},"send_time":{"type":"integer","title":"Send Time","description":"The index of `variate_settings.send_times` used."},"recipients":{"type":"integer","title":"Recipients","description":"The number of recipients for this combination."},"subject_line":{"type":"integer","title":"Subject Line","description":"The index of `variate_settings.subject_lines` used."},"content_description":{"type":"integer","title":"Content Description","description":"The index of `variate_settings.contents` used."}}},"title":"Combinations","readOnly":true,"description":"Combinations of possible variables used to build emails."},"subject_lines":{"type":"array","items":{"type":"string"},"title":"Subject Lines","description":"The possible subject lines to test. If no subject lines are provided, settings.subject_line will be used."},"winner_criteria":{"enum":["opens","clicks","manual","total_revenue"],"type":"string","title":"Winning Criteria","description":"The combination that performs the best. This may be determined automatically by click rate, open rate, or total revenue -- or you may choose manually based on the reporting data you find the most valuable. For Multivariate Campaigns testing send_time, winner_criteria is ignored. For Multivariate Campaigns with 'manual' as the winner_criteria, the winner must be chosen in the Mailchimp web application."},"reply_to_addresses":{"type":"array","items":{"type":"string"},"title":"Reply To Addresses","description":"The possible reply-to addresses. The number of reply_to_addresses provided must match the number of from_names. If no reply_to_addresses are provided, settings.reply_to will be used."},"winning_campaign_id":{"type":"string","title":"Winning Campaign ID","readOnly":true,"description":"ID of the campaign that was sent to the remaining recipients based on the winning combination."},"winning_combination_id":{"type":"string","title":"Winning Combination ID","readOnly":true,"description":"ID for the winning combination."}},"description":"The settings specific to A/B test campaigns."},"parent_campaign_id":{"type":"string","title":"Parent Campaign ID","readOnly":true,"description":"If this campaign is the child of another campaign, this identifies the parent campaign. For Example, for RSS or Automation children."},"needs_block_refresh":{"type":"boolean","title":"Needs Block Refresh","readOnly":true,"description":"Determines if the campaign needs its blocks refreshed by opening the web-based campaign editor. Deprecated and will always return false."}},"description":"A summary of an individual campaign's settings and content."},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[create_time],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[create_time],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@59962299[stream=io.airbyte.protocol.models.AirbyteStream@67a128f4[name=email_activity,jsonSchema={"type":"object","title":"Email Activity","properties":{"ip":{"type":["string","null"],"title":"Action ip address","description":"The IP address recorded for the action."},"url":{"type":["string","null"],"title":"The IP address.","description":"The IP address recorded for the action."},"type":{"enum":["hard","soft"],"type":["string","null"],"title":"Type","description":"If the action is a 'bounce', the type of bounce received: 'hard', 'soft'."},"action":{"enum":["open","click","bounce"],"type":["string","null"],"title":"action","description":"One of the following actions: 'open', 'click', or 'bounce'"},"list_id":{"type":"string","title":"The unique id for the list.","description":"The unique id for the list."},"email_id":{"type":"string","title":"email MD5 hash.","description":"The MD5 hash of the lowercase version of the list member's email address."},"timestamp":{"type":["string","null"],"title":"Action date and time","format":"date-time","description":"The date and time recorded for the action in ISO 8601 format."},"campaign_id":{"type":"string","title":"The unique id for the campaign.","description":"The unique id for the campaign."},"email_address":{"type":"string","title":"Email address for a subscriber.","description":"Email address for a subscriber."},"list_is_active":{"type":"boolean","title":"The status of the list used.","description":"The status of the list used, namely if it's deleted or disabled."}},"description":"A list of member's subscriber activity in a specific campaign."},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[timestamp],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[timestamp],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@336e8791[stream=io.airbyte.protocol.models.AirbyteStream@32f2a41c[name=lists,jsonSchema={"type":"object","title":"Subscriber List","properties":{"id":{"type":"string","title":"List ID","readOnly":true,"description":"A string that uniquely identifies this list."},"name":{"type":"string","title":"List Name","description":"The name of the list."},"stats":{"type":"object","title":"Statistics","readOnly":true,"properties":{"open_rate":{"type":"number","title":"Open Rate","readOnly":true,"description":"The average open rate (a percentage represented as a number between 0 and 100) per campaign for the list (not returned if we haven't calculated it yet)."},"click_rate":{"type":"number","title":"Click Rate","readOnly":true,"description":"The average click rate (a percentage represented as a number between 0 and 100) per campaign for the list (not returned if we haven't calculated it yet)."},"avg_sub_rate":{"type":"number","title":"Average Subscription Rate","readOnly":true,"description":"The average number of subscriptions per month for the list (not returned if we haven't calculated it yet)."},"member_count":{"type":"integer","title":"Member Count","readOnly":true,"description":"The number of active members in the list."},"cleaned_count":{"type":"integer","title":"Cleaned Count","readOnly":true,"description":"The number of members cleaned from the list."},"last_sub_date":{"type":"string","title":"Date of Last List Subscribe","readOnly":true,"description":"The date and time of the last time someone subscribed to this list in ISO 8601 format."},"avg_unsub_rate":{"type":"number","title":"Average Unsubscription Rate","readOnly":true,"description":"The average number of unsubscriptions per month for the list (not returned if we haven't calculated it yet)."},"campaign_count":{"type":"integer","title":"Campaign Count","readOnly":true,"description":"The number of campaigns in any status that use this list."},"total_contacts":{"type":"integer","title":"Total Contacts","readOnly":true,"description":"The number of contacts in the list, including subscribed, unsubscribed, pending, cleaned, deleted, transactional, and those that need to be reconfirmed."},"last_unsub_date":{"type":"string","title":"Date of Last List Unsubscribe","readOnly":true,"description":"The date and time of the last time someone unsubscribed from this list in ISO 8601 format."},"target_sub_rate":{"type":"number","title":"Average Subscription Rate","readOnly":true,"description":"The target number of subscriptions per month for the list to keep it growing (not returned if we haven't calculated it yet)."},"merge_field_count":{"type":"integer","title":"Merge Var Count","readOnly":true,"description":"The number of merge vars for this list (not EMAIL, which is required)."},"unsubscribe_count":{"type":"integer","title":"Unsubscribe Count","readOnly":true,"description":"The number of members who have unsubscribed from the list."},"campaign_last_sent":{"type":"string","title":"Campaign Last Sent","readOnly":true,"description":"The date and time the last campaign was sent to this list in ISO 8601 format. This is updated when a campaign is sent to 10 or more recipients."},"member_count_since_send":{"type":"integer","title":"Member Count Since Send","readOnly":true,"description":"The number of active members in the list since the last campaign was sent."},"cleaned_count_since_send":{"type":"integer","title":"Cleaned Count Since Send","readOnly":true,"description":"The number of members cleaned from the list since the last campaign was sent."},"unsubscribe_count_since_send":{"type":"integer","title":"Unsubscribe Count Since Send","readOnly":true,"description":"The number of members who have unsubscribed since the last campaign was sent."}},"description":"Stats for the list. Many of these are cached for at least five minutes."},"web_id":{"type":"integer","title":"List Web ID","readOnly":true,"description":"The ID used in the Mailchimp web application. View this list in your Mailchimp account at `https://{dc}.admin.mailchimp.com/lists/members/?id={web_id}`."},"contact":{"type":"object","title":"List Contact","properties":{"zip":{"type":"string","title":"Postal Code","description":"The postal or zip code for the list contact."},"city":{"type":"string","title":"City","description":"The city for the list contact."},"phone":{"type":"string","title":"Phone Number","description":"The phone number for the list contact."},"state":{"type":"string","title":"State","description":"The state for the list contact."},"company":{"type":"string","title":"Company Name","description":"The company name for the list."},"country":{"type":"string","title":"Country Code","description":"A two-character ISO3166 country code. Defaults to US if invalid."},"address1":{"type":"string","title":"Address","description":"The street address for the list contact."},"address2":{"type":"string","title":"Address","description":"The street address for the list contact."}},"description":"[Contact information displayed in campaign footers](https://mailchimp.com/help/about-campaign-footers/) to comply with international spam laws."},"modules":{"type":"array","items":{"type":"string"},"title":"Modules","readOnly":true,"description":"Any list-specific modules installed for this list."},"visibility":{"enum":["pub","prv"],"type":"string","title":"Visibility","description":"Whether this list is [public or private](https://mailchimp.com/help/about-list-publicity/)."},"has_welcome":{"type":"boolean","title":"Has Welcome","default":false,"example":false,"description":"Whether or not this list has a welcome automation connected. Welcome Automations: welcomeSeries, singleWelcome, emailFollowup."},"list_rating":{"type":"integer","title":"List Rating","readOnly":true,"description":"An auto-generated activity score for the list (0-5)."},"date_created":{"type":"string","title":"Creation Date","format":"date-time","readOnly":true,"description":"The date and time that this list was created in ISO 8601 format."},"double_optin":{"type":"boolean","title":"Double Opt In","default":false,"description":"Whether or not to require the subscriber to confirm subscription via email."},"beamer_address":{"type":"string","title":"Beamer Address","readOnly":true,"description":"The list's [Email Beamer](https://mailchimp.com/help/use-email-beamer-to-create-a-campaign/) address."},"use_archive_bar":{"type":"boolean","title":"Use Archive Bar","default":false,"description":"Whether campaigns for this list use the [Archive Bar](https://mailchimp.com/help/about-email-campaign-archives-and-pages/) in archives by default."},"campaign_defaults":{"type":"object","title":"Campaign Defaults","properties":{"subject":{"type":"string","title":"Subject","description":"The default subject line for campaigns sent to this list."},"language":{"type":"string","title":"Language","description":"The default language for this lists's forms."},"from_name":{"type":"string","title":"Sender's Name","description":"The default from name for campaigns sent to this list."},"from_email":{"type":"string","title":"Sender's Email Address","description":"The default from email for campaigns sent to this list."}},"description":"[Default values for campaigns](https://mailchimp.com/help/edit-your-emails-subject-preview-text-from-name-or-from-email-address/) created for this list."},"email_type_option":{"type":"boolean","title":"Email Type Option","description":"Whether the list supports [multiple formats for emails](https://mailchimp.com/help/change-list-name-and-defaults/). When set to `true`, subscribers can choose whether they want to receive HTML or plain-text emails. When set to `false`, subscribers will receive HTML emails, with a plain-text alternative backup."},"subscribe_url_long":{"type":"string","title":"Subscribe URL Long","readOnly":true,"description":"The full version of this list's subscribe form (host will vary)."},"notify_on_subscribe":{"type":"string","title":"Notify on Subscribe","default":false,"description":"The email address to send [subscribe notifications](https://mailchimp.com/help/change-subscribe-and-unsubscribe-notifications/) to."},"permission_reminder":{"type":"string","title":"Permission Reminder","description":"The [permission reminder](https://mailchimp.com/help/edit-the-permission-reminder/) for the list."},"subscribe_url_short":{"type":"string","title":"Subscribe URL Short","readOnly":true,"description":"Our [EepURL shortened](https://mailchimp.com/help/share-your-signup-form/) version of this list's subscribe form."},"marketing_permissions":{"type":"boolean","title":"Marketing Permissions","default":false,"description":"Whether or not the list has marketing permissions (eg. GDPR) enabled."},"notify_on_unsubscribe":{"type":"string","title":"Notify on Unsubscribe","default":false,"description":"The email address to send [unsubscribe notifications](https://mailchimp.com/help/change-subscribe-and-unsubscribe-notifications/) to."}},"description":"Information about a specific list."},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[date_created],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[date_created],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}]]
2022-01-19 08:12:10 INFO i.a.w.t.TemporalAttemptExecution(get):123 - Executing worker wrapper. Airbyte version: 0.35.4-alpha
2022-01-19 08:12:10 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-01-19 08:12:10 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-01-19 08:12:10 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-01-19 08:12:10 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-01-19 08:12:10 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-01-19 08:12:10 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.63
2022-01-19 08:12:10 INFO i.a.w.p.KubeProcessFactory(create):112 - Attempting to start pod = normalization-sync-854-0-eqmri
2022-01-19 08:22:10 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):177 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.WorkerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:153) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:55) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	... 3 more
Caused by: java.lang.NullPointerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:114) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:55) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	... 3 more
2022-01-19 08:22:10 INFO i.a.w.t.TemporalAttemptExecution(get):144 - Stopping cancellation check scheduling...
2022-01-19 08:22:10 WARN i.t.i.s.POJOActivityTaskHandler(activityFailureToResult):363 - Activity failure. ActivityId=14a5fabe-8971-34a9-9d39-73b26143940e, activityType=Normalize, attempt=1
java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:142) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:98) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at jdk.internal.reflect.GeneratedMethodAccessor423.invoke(Unknown Source) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:286) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:252) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:209) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:193) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:151) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:73) ~[temporal-sdk-1.6.0.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: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.WorkerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:153) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:55) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	... 1 more
Caused by: java.lang.NullPointerException: Cannot invoke "java.lang.Integer.intValue()" because the return value of "io.airbyte.workers.process.KubePortManagerSingleton.take()" is null
	at io.airbyte.workers.process.KubeProcessFactory.create(KubeProcessFactory.java:114) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:55) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.4-alpha.jar:?]
	... 1 more