2022-07-27 10:47:07 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-07-27 10:47:07 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/308/0/logs.log
2022-07-27 10:47:11 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-27 10:47:07 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-07-27 10:47:07 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 308 attempt id: 0
2022-07-27 10:47:07 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.coupons=incremental - append}
2022-07-27 10:47:07 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-27 10:47:07 INFO i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:07 INFO i.a.w.p.KubeProcessFactory(create):114 - destination-redshift-sync-308-0-elkcg stdoutLocalPort = 9018
2022-07-27 10:47:07 INFO i.a.w.p.KubeProcessFactory(create):117 - destination-redshift-sync-308-0-elkcg stderrLocalPort = 9019
2022-07-27 10:47:07 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-07-27 10:47:07 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-07-27 10:47:07 INFO i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-07-27 10:47:07 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-07-27 10:47:07 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-07-27 10:47:08 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-07-27 10:47:08 INFO i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-07-27 10:47:08 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_config.json
2022-07-27 10:47:08 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/75719c61-6b25-4bc9-b85b-566e847ea2a9/destination_config.json dev/destination-redshift-sync-308-0-elkcg:/config/destination_config.json -c init
2022-07-27 10:47:08 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_catalog.json
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/1d177649-969b-4880-a876-4e1fcad83e6a/destination_catalog.json dev/destination-redshift-sync-308-0-elkcg:/config/destination_catalog.json -c init
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/787b0647-18e3-48a4-a22b-b73d6a5bbf90/FINISHED_UPLOADING dev/destination-redshift-sync-308-0-elkcg:/config/FINISHED_UPLOADING -c init
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:09 INFO i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-07-27 10:47:10 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-07-27 10:47:10 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 15.0.3.12
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(<init>):507 - Creating stdin socket...
2022-07-27 10:47:11 INFO i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = source-stripe-sync-308-0-vktfa
2022-07-27 10:47:11 INFO i.a.w.p.KubeProcessFactory(create):114 - source-stripe-sync-308-0-vktfa stdoutLocalPort = 9012
2022-07-27 10:47:11 INFO i.a.w.p.KubeProcessFactory(create):117 - source-stripe-sync-308-0-vktfa stderrLocalPort = 9013
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-07-27 10:47:11 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: source_config.json
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/39eba2da-7209-49b1-bfe0-503aefe5c401/source_config.json dev/source-stripe-sync-308-0-vktfa:/config/source_config.json -c init
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: source_catalog.json
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/263404ab-6993-4458-a3ad-b68b9c4c4894/source_catalog.json dev/source-stripe-sync-308-0-vktfa:/config/source_catalog.json -c init
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/8e3a2251-2936-4009-bd38-e02fe9b52d65/FINISHED_UPLOADING dev/source-stripe-sync-308-0-vktfa:/config/FINISHED_UPLOADING -c init
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:12 INFO i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-07-27 10:47:13 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-07-27 10:47:13 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-07-27 10:47:14 INFO i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-07-27 10:47:14 INFO i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 15.0.3.46
2022-07-27 10:47:14 INFO i.a.w.p.KubePodProcess(<init>):511 - Using null stdin output stream...
2022-07-27 10:47:14 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-07-27 10:47:14 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):338 - Destination output thread started.
2022-07-27 10:47:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-07-27 10:47:14 INFO i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod source-stripe-sync-308-0-vktfa is 0
2022-07-27 10:47:14 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-308-0-vktfa
2022-07-27 10:47:14 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):304 - Total records read: 2
2022-07-27 10:47:14 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-308-0-vktfa
2022-07-27 10:47:14 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-308-0-vktfa
2022-07-27 10:47:14 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-07-27 10:47:19 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):348 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@1d30826e[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@5356598e[data={"coupons":{"created":1658387065}},additionalProperties={}],additionalProperties={}]
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod destination-redshift-sync-308-0-elkcg is 0
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:49 INFO i.a.w.DefaultReplicationWorker(run):164 - Source and destination threads complete.
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-308-0-vktfa
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-308-0-vktfa
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-308-0-vktfa
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-308-0-vktfa
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-308-0-elkcg
2022-07-27 10:47:49 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@e880597[status=completed,recordsSynced=1,bytesSynced=270,startTime=1658918827583,endTime=1658918869613,totalStats=io.airbyte.config.SyncStats@282950e4[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=1,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@2b659a8d[streamName=coupons,stats=io.airbyte.config.SyncStats@1e910b89[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=<null>,recordsCommitted=1]]]]
2022-07-27 10:47:49 INFO i.a.w.DefaultReplicationWorker(run):247 - Source output at least one state message
2022-07-27 10:47:49 INFO i.a.w.DefaultReplicationWorker(run):253 - State capture: Updated state to: Optional[io.airbyte.config.State@2b22f52a[state={"coupons":{"created":1658387065}}]]
2022-07-27 10:47:49 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-07-27 10:47:49 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):144 - sync summary: io.airbyte.config.StandardSyncOutput@a55cd16[standardSyncSummary=io.airbyte.config.StandardSyncSummary@53c32775[status=completed,recordsSynced=1,bytesSynced=270,startTime=1658918827583,endTime=1658918869613,totalStats=io.airbyte.config.SyncStats@282950e4[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=1,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@2b659a8d[streamName=coupons,stats=io.airbyte.config.SyncStats@1e910b89[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=<null>,recordsCommitted=1]]]],state=io.airbyte.config.State@2b22f52a[state={"coupons":{"created":1658387065}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@76afb061[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5b0791dc[stream=io.airbyte.protocol.models.AirbyteStream@7f9ecad7[name=coupons,jsonSchema={"type":["null","object"],"properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"valid":{"type":["null","boolean"]},"object":{"type":["null","string"]},"created":{"type":["null","integer"]},"currency":{"type":["null","string"]},"duration":{"type":["null","string"]},"livemode":{"type":["null","boolean"]},"metadata":{"type":["null","object"],"properties":{}},"redeem_by":{"type":["null","string"]},"amount_off":{"type":["null","integer"]},"percent_off":{"type":["null","number"]},"times_redeemed":{"type":["null","integer"]},"max_redemptions":{"type":["null","integer"]},"duration_in_months":{"type":["null","integer"]},"percent_off_precise":{"type":["null","number"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[created],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[created],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-07-27 10:47:49 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-07-27 10:47:49 INFO i.a.c.p.ConfigRepository(updateConnectionState):551 - Updating connection 2938cde0-b9d3-4589-9a2f-ac1ae884e174 state: io.airbyte.config.State@10cb1ac1[state={"coupons":{"created":1658387065}}]
2022-07-27 10:47:49 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/308/0/logs.log
2022-07-27 10:47:49 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-07-27 10:47:49 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-07-27 10:47:49 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.67
2022-07-27 10:47:49 INFO i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = normalization-sync-308-0-buych
2022-07-27 10:47:49 INFO i.a.w.p.KubeProcessFactory(create):114 - normalization-sync-308-0-buych stdoutLocalPort = 9016
2022-07-27 10:47:49 INFO i.a.w.p.KubeProcessFactory(create):117 - normalization-sync-308-0-buych stderrLocalPort = 9017
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-07-27 10:47:49 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_config.json
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/c1b302f2-73e7-4670-8bb7-12d22818368b/destination_config.json dev/normalization-sync-308-0-buych:/config/destination_config.json -c init
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_catalog.json
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/df4ca912-de9c-4ef1-9045-7e89f42f27b6/destination_catalog.json dev/normalization-sync-308-0-buych:/config/destination_catalog.json -c init
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/16cfd584-a5be-4963-b7f9-345140c7264c/FINISHED_UPLOADING dev/normalization-sync-308-0-buych:/config/FINISHED_UPLOADING -c init
2022-07-27 10:47:51 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:47:52 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:47:52 INFO i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-07-27 10:47:52 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-07-27 10:47:52 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-07-27 10:47:53 INFO i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-07-27 10:47:53 INFO i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 15.0.3.72
2022-07-27 10:47:53 INFO i.a.w.p.KubePodProcess(<init>):511 - Using null stdin output stream...
2022-07-27 10:47:59 INFO i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod normalization-sync-308-0-buych is 0
2022-07-27 10:47:59 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-308-0-buych
2022-07-27 10:47:59 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-308-0-buych
2022-07-27 10:47:59 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-308-0-buych
2022-07-27 10:47:59 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-308-0-buych
2022-07-27 10:47:59 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-308-0-buych
2022-07-27 10:47:59 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-308-0-buych
2022-07-27 10:47:59 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 9 seconds.
2022-07-27 10:47:59 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-07-27 10:47:59 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-07-27 10:47:11 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-27 10:47:11 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-27 10:47:11 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-27 10:47:11 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-27 10:47:14 destination > 2022-07-27 10:47:10 INFO i.a.i.d.r.RedshiftDestination(main):77 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-07-27 10:47:14 destination > 2022-07-27 10:47:10 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-27 10:47:14 destination > 2022-07-27 10:47:10 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-07-27 10:47:14 destination > 2022-07-27 10:47:10 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: WRITE
2022-07-27 10:47:14 destination > 2022-07-27 10:47:10 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INSERT
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=coupons, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_asp_coupons, outputTableName=_airbyte_raw_coupons, syncMode=append}
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):140 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 1 streams
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream coupons. schema: public, tmp table name: _airbyte_tmp_asp_coupons
2022-07-27 10:47:14 source > Starting syncing SourceStripe
2022-07-27 10:47:14 destination > 2022-07-27 10:47:11 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed.
2022-07-27 10:47:14 source > Syncing stream: coupons 
2022-07-27 10:47:14 source > Setting state of coupons stream to {'created': 1658387065}
2022-07-27 10:47:14 source > Read 1 records from coupons stream
2022-07-27 10:47:14 source > Finished syncing SourceStripe
2022-07-27 10:47:14 source > SourceStripe runtimes:

2022-07-27 10:47:14 source > Finished syncing SourceStripe
2022-07-27 10:47:14 destination > 2022-07-27 10:47:14 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: succeeded.
2022-07-27 10:47:14 destination > 2022-07-27 10:47:14 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-07-27 10:47:14 destination > 2022-07-27 10:47:14 INFO i.a.i.d.r.RedshiftSqlOperations(insertRecordsInternal):42 - actual size of batch: 1
2022-07-27 10:47:14 destination > 2022-07-27 10:47:14 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 1 streams
2022-07-27 10:47:14 destination > 2022-07-27 10:47:14 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream coupons. schema public, tmp table _airbyte_tmp_asp_coupons, final table _airbyte_raw_coupons
2022-07-27 10:47:15 destination > 2022-07-27 10:47:15 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables.
2022-07-27 10:47:19 destination > 2022-07-27 10:47:19 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed.
2022-07-27 10:47:19 destination > 2022-07-27 10:47:19 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 1 streams
2022-07-27 10:47:19 destination > 2022-07-27 10:47:19 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream coupons. schema public, tmp table name: _airbyte_tmp_asp_coupons
2022-07-27 10:47:19 destination > 2022-07-27 10:47:19 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed.
2022-07-27 10:47:19 destination > 2022-07-27 10:47:19 INFO i.a.i.b.IntegrationRunner(runInternal):153 - Completed integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-07-27 10:47:19 destination > 2022-07-27 10:47:19 INFO i.a.i.d.r.RedshiftDestination(main):79 - completed destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-07-27 10:47:53 normalization > Running: transform-config --config destination_config.json --integration-type redshift --out /config
2022-07-27 10:47:53 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.redshift: 'redshift'>, out='/config')
2022-07-27 10:47:53 normalization > transform_redshift
2022-07-27 10:47:53 normalization > Running: transform-catalog --integration-type redshift --profile-config-dir /config --catalog destination_catalog.json --out /config/models/generated/ --json-column _airbyte_data
2022-07-27 10:47:53 normalization > Processing destination_catalog.json...
2022-07-27 10:47:53 normalization >   Generating airbyte_ctes/public/coupons_ab1.sql from coupons
2022-07-27 10:47:53 normalization >   Generating airbyte_ctes/public/coupons_ab2.sql from coupons
2022-07-27 10:47:53 normalization >   Generating airbyte_ctes/public/coupons_ab3.sql from coupons
2022-07-27 10:47:53 normalization >   Generating airbyte_incremental/public/coupons.sql from coupons
2022-07-27 10:47:53 normalization >   Ignoring stream 'metadata' from coupons/metadata because properties list is empty
2022-07-27 10:47:53 normalization > detected no config file for ssh, assuming ssh is off.
2022-07-27 10:47:54 normalization > Running with dbt=0.21.1
2022-07-27 10:47:54 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found
2022-07-27 10:47:55 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-07-27 10:47:55 normalization > There are 2 unused configuration paths:
2022-07-27 10:47:55 normalization > - models.airbyte_utils.generated.airbyte_views
2022-07-27 10:47:55 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-07-27 10:47:55 normalization > 
2022-07-27 10:47:55 normalization > Found 4 models, 0 tests, 0 snapshots, 0 analyses, 520 macros, 0 operations, 0 seed files, 1 source, 0 exposures
2022-07-27 10:47:55 normalization > 
2022-07-27 10:47:56 normalization > 10:47:55 | Concurrency: 4 threads (target='prod')
2022-07-27 10:47:56 normalization > 10:47:55 | 
2022-07-27 10:47:56 normalization > 10:47:56 | 1 of 1 START incremental model public.coupons................................................................ [RUN]
2022-07-27 10:47:58 normalization > 10:47:58 | 1 of 1 OK created incremental model public.coupons........................................................... [INSERT 0 2 in 2.19s]
2022-07-27 10:47:58 normalization > 10:47:58 | 
2022-07-27 10:47:58 normalization > 10:47:58 | Finished running 1 incremental model in 3.22s.
2022-07-27 10:47:58 normalization > 
2022-07-27 10:47:58 normalization > Completed successfully
2022-07-27 10:47:58 normalization > 
2022-07-27 10:47:58 normalization > Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1