2022-07-27 10:48:37 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-07-27 10:48:37 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/309/0/logs.log
2022-07-27 10:48:41 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-07-27 10:48:37 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-07-27 10:48:37 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 309 attempt id: 0
2022-07-27 10:48:37 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.coupons=incremental - append}
2022-07-27 10:48:37 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-07-27 10:48:37 INFO i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = destination-redshift-sync-309-0-detra
2022-07-27 10:48:37 INFO i.a.w.p.KubeProcessFactory(create):114 - destination-redshift-sync-309-0-detra stdoutLocalPort = 9034
2022-07-27 10:48:37 INFO i.a.w.p.KubeProcessFactory(create):117 - destination-redshift-sync-309-0-detra stderrLocalPort = 9035
2022-07-27 10:48:37 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-07-27 10:48:37 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-07-27 10:48:37 INFO i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-07-27 10:48:37 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-07-27 10:48:37 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_config.json
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/253389d6-d6f5-458a-96f9-321496670491/destination_config.json dev/destination-redshift-sync-309-0-detra:/config/destination_config.json -c init
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_catalog.json
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/0ced3f2d-6865-47de-b00c-1d7e02630f99/destination_catalog.json dev/destination-redshift-sync-309-0-detra:/config/destination_catalog.json -c init
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/4206a289-0632-49d8-9d1f-03c609795593/FINISHED_UPLOADING dev/destination-redshift-sync-309-0-detra:/config/FINISHED_UPLOADING -c init
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:48:39 INFO i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-07-27 10:48:40 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-07-27 10:48:40 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 15.0.3.72
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(<init>):507 - Creating stdin socket...
2022-07-27 10:48:41 INFO i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = source-stripe-sync-309-0-ndmkc
2022-07-27 10:48:41 INFO i.a.w.p.KubeProcessFactory(create):114 - source-stripe-sync-309-0-ndmkc stdoutLocalPort = 9036
2022-07-27 10:48:41 INFO i.a.w.p.KubeProcessFactory(create):117 - source-stripe-sync-309-0-ndmkc stderrLocalPort = 9037
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-07-27 10:48:41 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: input_state.json
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/56518fd6-c12b-41f5-8aa8-3ffd7edff09f/input_state.json dev/source-stripe-sync-309-0-ndmkc:/config/input_state.json -c init
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: source_config.json
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/a73db744-743e-41cb-a560-2790753d26df/source_config.json dev/source-stripe-sync-309-0-ndmkc:/config/source_config.json -c init
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: source_catalog.json
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/abd85367-9e74-4a9a-86c8-8322ca4cd2f1/source_catalog.json dev/source-stripe-sync-309-0-ndmkc:/config/source_catalog.json -c init
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/67cf1e1e-853b-434c-a952-8db5293832d6/FINISHED_UPLOADING dev/source-stripe-sync-309-0-ndmkc:/config/FINISHED_UPLOADING -c init
2022-07-27 10:48:42 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:48:43 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:48:43 INFO i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-07-27 10:48:43 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-07-27 10:48:43 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-07-27 10:48:44 INFO i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-07-27 10:48:44 INFO i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 15.0.3.12
2022-07-27 10:48:44 INFO i.a.w.p.KubePodProcess(<init>):511 - Using null stdin output stream...
2022-07-27 10:48:44 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):338 - Destination output thread started.
2022-07-27 10:48:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-07-27 10:48:44 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-07-27 10:48:44 INFO i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod source-stripe-sync-309-0-ndmkc is 0
2022-07-27 10:48:44 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-309-0-ndmkc
2022-07-27 10:48:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):304 - Total records read: 2
2022-07-27 10:48:44 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-309-0-ndmkc
2022-07-27 10:48:44 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-309-0-ndmkc
2022-07-27 10:48:44 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-07-27 10:48:45 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):348 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@28902033[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@692e6476[data={"coupons":{"created":1658387065}},additionalProperties={}],additionalProperties={}]
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod destination-redshift-sync-309-0-detra is 0
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-309-0-detra
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-309-0-detra
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-309-0-detra
2022-07-27 10:49:15 INFO i.a.w.DefaultReplicationWorker(run):164 - Source and destination threads complete.
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-309-0-ndmkc
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-309-0-ndmkc
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-309-0-ndmkc
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod source-stripe-sync-309-0-ndmkc
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-309-0-detra
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-309-0-detra
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-309-0-detra
2022-07-27 10:49:15 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod destination-redshift-sync-309-0-detra
2022-07-27 10:49:15 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@40c3d4e7[status=completed,recordsSynced=1,bytesSynced=270,startTime=1658918917752,endTime=1658918955996,totalStats=io.airbyte.config.SyncStats@72613639[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=1,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@42d0115c[streamName=coupons,stats=io.airbyte.config.SyncStats@4f8834ce[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=<null>,recordsCommitted=1]]]]
2022-07-27 10:49:15 INFO i.a.w.DefaultReplicationWorker(run):247 - Source output at least one state message
2022-07-27 10:49:15 INFO i.a.w.DefaultReplicationWorker(run):253 - State capture: Updated state to: Optional[io.airbyte.config.State@22beca44[state={"coupons":{"created":1658387065}}]]
2022-07-27 10:49:15 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-07-27 10:49:15 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):144 - sync summary: io.airbyte.config.StandardSyncOutput@40ac704[standardSyncSummary=io.airbyte.config.StandardSyncSummary@367b1c98[status=completed,recordsSynced=1,bytesSynced=270,startTime=1658918917752,endTime=1658918955996,totalStats=io.airbyte.config.SyncStats@72613639[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=1,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@42d0115c[streamName=coupons,stats=io.airbyte.config.SyncStats@4f8834ce[recordsEmitted=1,bytesEmitted=270,stateMessagesEmitted=<null>,recordsCommitted=1]]]],state=io.airbyte.config.State@22beca44[state={"coupons":{"created":1658387065}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@46b9d239[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@17eec5b9[stream=io.airbyte.protocol.models.AirbyteStream@458e02a7[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:49:15 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-07-27 10:49:16 INFO i.a.c.p.ConfigRepository(updateConnectionState):551 - Updating connection 2938cde0-b9d3-4589-9a2f-ac1ae884e174 state: io.airbyte.config.State@51b4b281[state={"coupons":{"created":1658387065}}]
2022-07-27 10:49:16 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/309/0/logs.log
2022-07-27 10:49:16 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.31-alpha
2022-07-27 10:49:16 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-07-27 10:49:16 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.67
2022-07-27 10:49:16 INFO i.a.w.p.KubeProcessFactory(create):111 - Attempting to start pod = normalization-sync-309-0-qoyvq
2022-07-27 10:49:16 INFO i.a.w.p.KubeProcessFactory(create):114 - normalization-sync-309-0-qoyvq stdoutLocalPort = 9022
2022-07-27 10:49:16 INFO i.a.w.p.KubeProcessFactory(create):117 - normalization-sync-309-0-qoyvq stderrLocalPort = 9023
2022-07-27 10:49:16 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):521 - Creating stdout socket server...
2022-07-27 10:49:16 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):532 - Creating stderr socket server...
2022-07-27 10:49:16 INFO i.a.w.p.KubePodProcess(<init>):480 - Creating pod...
2022-07-27 10:49:16 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):290 - Waiting for init container to be ready before copying files...
2022-07-27 10:49:16 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):293 - Init container present..
2022-07-27 10:49:17 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):296 - Init container ready..
2022-07-27 10:49:17 INFO i.a.w.p.KubePodProcess(<init>):485 - Copying files...
2022-07-27 10:49:17 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_config.json
2022-07-27 10:49:17 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/28792c07-7256-403e-a873-7f0720b5ef8b/destination_config.json dev/normalization-sync-309-0-qoyvq:/config/destination_config.json -c init
2022-07-27 10:49:17 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: destination_catalog.json
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/9280fd3b-ea9c-4a76-ad76-c3bf445f76f6/destination_catalog.json dev/normalization-sync-309-0-qoyvq:/config/destination_catalog.json -c init
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):240 - Uploading file: FINISHED_UPLOADING
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):248 - kubectl cp /tmp/0d1f9fee-8b10-425f-a227-0765df35b9cb/FINISHED_UPLOADING dev/normalization-sync-309-0-qoyvq:/config/FINISHED_UPLOADING -c init
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):251 - Waiting for kubectl cp to complete
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - kubectl cp complete, closing process
2022-07-27 10:49:18 INFO i.a.w.p.KubePodProcess(<init>):488 - Waiting until pod is ready...
2022-07-27 10:49:19 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$8):523 - Setting stdout...
2022-07-27 10:49:19 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):534 - Setting stderr...
2022-07-27 10:49:19 INFO i.a.w.p.KubePodProcess(<init>):502 - Reading pod IP...
2022-07-27 10:49:19 INFO i.a.w.p.KubePodProcess(<init>):504 - Pod IP: 15.0.3.46
2022-07-27 10:49:19 INFO i.a.w.p.KubePodProcess(<init>):511 - Using null stdin output stream...
2022-07-27 10:49:25 INFO i.a.w.p.KubePodProcess(getReturnCode):696 - Exit code for pod normalization-sync-309-0-qoyvq is 0
2022-07-27 10:49:25 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-309-0-qoyvq
2022-07-27 10:49:25 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-309-0-qoyvq
2022-07-27 10:49:25 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-309-0-qoyvq
2022-07-27 10:49:25 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-309-0-qoyvq
2022-07-27 10:49:25 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-309-0-qoyvq
2022-07-27 10:49:25 INFO i.a.w.p.KubePodProcess(exitValue):711 - Closed all resources for pod normalization-sync-309-0-qoyvq
2022-07-27 10:49:25 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 8 seconds.
2022-07-27 10:49:25 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-07-27 10:49:25 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-07-27 10:48:41 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:48:41 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-07-27 10:48:41 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-07-27 10:48:41 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.d.r.RedshiftDestination(main):77 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: WRITE
2022-07-27 10:48:44 source > Starting syncing SourceStripe
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 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:48:44 destination > 2022-07-27 10:48:41 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:48:44 destination > 2022-07-27 10:48:41 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:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INSERT
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=coupons, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_krx_coupons, outputTableName=_airbyte_raw_coupons, syncMode=append}
2022-07-27 10:48:44 source > Syncing stream: coupons 
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):140 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 1 streams
2022-07-27 10:48:44 destination > 2022-07-27 10:48:41 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_krx_coupons
2022-07-27 10:48:44 source > Setting state of coupons stream to {'created': 1658387065}
2022-07-27 10:48:44 destination > 2022-07-27 10:48:42 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed.
2022-07-27 10:48:44 source > Setting state of coupons stream to {'created': 1658387065}
2022-07-27 10:48:44 source > Read 1 records from coupons stream
2022-07-27 10:48:44 source > Finished syncing SourceStripe
2022-07-27 10:48:44 source > SourceStripe runtimes:

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