2022-08-18 09:02:19 [32mINFO[m i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-08-18 09:02:20 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/30199/0/logs.log
2022-08-18 09:02:23 [43mdestination[0m > SLF4J: Class path contains multiple SLF4J bindings.
2022-08-18 09:02:20 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-08-18 09:02:20 [32mINFO[m i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 30199 attempt id: 0
2022-08-18 09:02:20 [32mINFO[m i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.campaigns=full_refresh - append}
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = destination-postgres-sync-30199-0-cmgom
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubeProcessFactory(create):114 - destination-postgres-sync-30199-0-cmgom stdoutLocalPort = 9024
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubeProcessFactory(create):117 - destination-postgres-sync-30199-0-cmgom stderrLocalPort = 9028
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-08-18 09:02:20 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-08-18 09:02:21 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-08-18 09:02:21 [32mINFO[m i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-08-18 09:02:21 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_config.json
2022-08-18 09:02:21 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/f63800e1-2450-44c1-a9b6-b8788e4e2ca3/destination_config.json dev/destination-postgres-sync-30199-0-cmgom:/config/destination_config.json -c init
2022-08-18 09:02:21 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_catalog.json
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/908236cf-b309-4c98-9ddb-aa9d2cc3ebc9/destination_catalog.json dev/destination-postgres-sync-30199-0-cmgom:/config/destination_catalog.json -c init
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/45d96a11-086b-4d16-b0b3-6e3624faffd1/FINISHED_UPLOADING dev/destination-postgres-sync-30199-0-cmgom:/config/FINISHED_UPLOADING -c init
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-08-18 09:02:22 [32mINFO[m i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 10.0.4.86
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(<init>):507 - Creating stdin socket...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = source-mailchimp-sync-30199-0-rkiph
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubeProcessFactory(create):114 - source-mailchimp-sync-30199-0-rkiph stdoutLocalPort = 9020
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubeProcessFactory(create):117 - source-mailchimp-sync-30199-0-rkiph stderrLocalPort = 9021
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-08-18 09:02:23 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-08-18 09:02:24 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-08-18 09:02:25 [32mINFO[m i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-08-18 09:02:25 [32mINFO[m i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-08-18 09:02:25 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: source_config.json
2022-08-18 09:02:25 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/2f37dea4-14b0-4eb5-832f-27ee5dad9219/source_config.json dev/source-mailchimp-sync-30199-0-rkiph:/config/source_config.json -c init
2022-08-18 09:02:25 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: source_catalog.json
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/a28fd04f-4a55-4331-ba6d-d1b161721f76/source_catalog.json dev/source-mailchimp-sync-30199-0-rkiph:/config/source_catalog.json -c init
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/ad90c241-9324-461c-92b2-3a8666641b86/FINISHED_UPLOADING dev/source-mailchimp-sync-30199-0-rkiph:/config/FINISHED_UPLOADING -c init
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-08-18 09:02:26 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-08-18 09:02:27 [32mINFO[m i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-08-18 09:02:27 [32mINFO[m i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-08-18 09:02:27 [32mINFO[m i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 10.0.3.176
2022-08-18 09:02:27 [32mINFO[m i.a.w.p.KubePodProcess(<init>):511 - Using null stdin output stream...
2022-08-18 09:02:27 [32mINFO[m i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-08-18 09:02:27 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):338 - Destination output thread started.
2022-08-18 09:02:27 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-08-18 09:02:58 [32mINFO[m i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod source-mailchimp-sync-30199-0-rkiph is 0
2022-08-18 09:02:58 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-mailchimp-sync-30199-0-rkiph
2022-08-18 09:02:58 [32mINFO[m i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):304 - Total records read: 5
2022-08-18 09:02:58 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-mailchimp-sync-30199-0-rkiph
2022-08-18 09:02:58 [32mINFO[m i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-mailchimp-sync-30199-0-rkiph
2022-08-18 09:02:58 [32mINFO[m i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-08-18 09:02:23 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.16.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-18 09:02:23 [43mdestination[0m > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-08-18 09:02:23 [43mdestination[0m > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-08-18 09:02:23 [43mdestination[0m > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [32mINFO[m i.a.i.d.p.PostgresDestination(main):69 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [32mINFO[m i.a.i.b.IntegrationRunner(run):76 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [32mINFO[m i.a.i.b.IntegrationRunner(run):80 - Command: WRITE
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [32mINFO[m i.a.i.b.IntegrationRunner(run):81 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-08-18 09:02:27 [44msource[0m > Starting syncing SourceMailchimp
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [33mWARN[m 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-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [33mWARN[m 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-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [33mWARN[m 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-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:23 [33mWARN[m 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-08-18 09:02:27 [44msource[0m > Syncing stream: campaigns 
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:24 [32mINFO[m i.a.i.b.s.SshTunnel(getInstance):172 - Starting connection with method: NO_TUNNEL
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:24 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=campaigns, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_klv_campaigns, outputTableName=_airbyte_raw_campaigns, syncMode=append}
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:24 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):125 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:24 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 1 streams
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:24 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream campaigns. schema: public, tmp table name: _airbyte_tmp_klv_campaigns
2022-08-18 09:02:27 [43mdestination[0m > 2022-08-18 09:02:24 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed.
2022-08-18 09:02:28 [44msource[0m > Read 5 records from campaigns stream
2022-08-18 09:02:28 [44msource[0m > Finished syncing SourceMailchimp
2022-08-18 09:02:28 [44msource[0m > SourceMailchimp runtimes:

2022-08-18 09:02:28 [44msource[0m > Finished syncing SourceMailchimp
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - Airbyte message consumer: succeeded.
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(close):201 - executing on success close procedure.
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 1 streams
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream campaigns. schema public, tmp table _airbyte_tmp_klv_campaigns, final table _airbyte_raw_campaigns
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables.
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed.
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 1 streams
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream campaigns. schema public, tmp table name: _airbyte_tmp_klv_campaigns
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed.
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.b.IntegrationRunner(run):133 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-08-18 09:02:58 [43mdestination[0m > 2022-08-18 09:02:58 [32mINFO[m i.a.i.d.p.PostgresDestination(main):71 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination