2022-04-19 18:22:01 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.0-alpha 2022-04-19 18:22:01 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/112/0/logs.log 2022-04-19 18:22:36 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-04-19 18:22:01 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.0-alpha 2022-04-19 18:22:01 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 112 attempt id: 0 2022-04-19 18:22:01 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.transactions=full_refresh - overwrite} 2022-04-19 18:22:01 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-04-19 18:22:01 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = destination-redshift-sync-112-0-umzxk for airbyte/destination-redshift:0.3.30 2022-04-19 18:22:01 INFO i.a.w.p.KubeProcessFactory(create):116 - destination-redshift-sync-112-0-umzxk stdoutLocalPort = 9024 2022-04-19 18:22:01 INFO i.a.w.p.KubeProcessFactory(create):119 - destination-redshift-sync-112-0-umzxk stderrLocalPort = 9025 2022-04-19 18:22:01 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):583 - Creating stdout socket server... 2022-04-19 18:22:01 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Creating stderr socket server... 2022-04-19 18:22:01 INFO i.a.w.p.KubePodProcess():521 - Creating pod destination-redshift-sync-112-0-umzxk... 2022-04-19 18:22:31 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-19 18:22:31 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):318 - Init container present.. 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):321 - Init container ready.. 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/bcfb63f2-ab99-4caa-bea0-f923f27c51bd/destination_config.json airbyte/destination-redshift-sync-112-0-umzxk:/config/destination_config.json -c init 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/0d7cbd6c-c5a6-4da0-b1a7-5c294de90213/destination_catalog.json airbyte/destination-redshift-sync-112-0-umzxk:/config/destination_catalog.json -c init 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/533f839c-def1-4434-9e41-86af93cfa99a/FINISHED_UPLOADING airbyte/destination-redshift-sync-112-0-umzxk:/config/FINISHED_UPLOADING -c init 2022-04-19 18:22:33 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-19 18:22:34 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-19 18:22:34 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-04-19 18:22:34 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):592 - Setting stdout... 2022-04-19 18:22:34 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):604 - Setting stderr... 2022-04-19 18:22:35 INFO i.a.w.p.KubePodProcess():564 - Reading pod IP... 2022-04-19 18:22:35 INFO i.a.w.p.KubePodProcess():566 - Pod IP: 100.65.254.2 2022-04-19 18:22:35 INFO i.a.w.p.KubePodProcess():569 - Creating stdin socket... 2022-04-19 18:22:35 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-04-19 18:22:35 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-04-19 18:22:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-04-19 18:22:35 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 1 (0 bytes) 2022-04-19 18:22:35 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other. 2022-04-19 18:22:55 INFO i.a.w.p.KubePodProcess(close):713 - (pod: airbyte / destination-redshift-sync-112-0-umzxk) - Closed all resources for pod 2022-04-19 18:22:55 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 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:164) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:119) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.0-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-workers-0.36.0-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-04-19 18:22:55 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@2d3ede5e[status=failed,recordsSynced=0,bytesSynced=0,startTime=1650392521336,endTime=1650392575896,totalStats=io.airbyte.config.SyncStats@2e8c4020[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[]] 2022-04-19 18:22:55 INFO i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message 2022-04-19 18:22:55 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained. 2022-04-19 18:22:55 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-19 18:22:55 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@738a2441[standardSyncSummary=io.airbyte.config.StandardSyncSummary@3d9662a8[status=failed,recordsSynced=0,bytesSynced=0,startTime=1650392521336,endTime=1650392575896,totalStats=io.airbyte.config.SyncStats@2e8c4020[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@1182d72a[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@222be134[stream=io.airbyte.protocol.models.AirbyteStream@a1711c[name=google_analytics_wine_transactions,jsonSchema={"type":["null","object"],"$schema":"http://json-schema.org/draft-07/schema#","properties":{"ga_date":{"type":["string"],"format":"date"},"view_id":{"type":["string"]},"ga_campaign":{"type":["string"]},"ga_itemQuantity":{"type":["null","integer"]},"ga_sourceMedium":{"type":["string"]},"ga_transactionId":{"type":["string"]},"ga_dateHourMinute":{"type":["string"]},"ga_deviceCategory":{"type":["string"]},"ga_landingPagePath":{"type":["string"]},"ga_transactionRevenue":{"type":["null","string"]},"ga_transactionShipping":{"type":["null","string"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[ga_date],sourceDefinedPrimaryKey=[],namespace=,additionalProperties={}],syncMode=full_refresh,cursorField=[ga_date],destinationSyncMode=overwrite,primaryKey=[[ga_transactionId]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@eacc082[failureOrigin=destination,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@9107dfa[additionalProperties={attemptNumber=0, jobId=112}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1650392575895]]] 2022-04-19 18:22:55 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-04-19 18:22:56 INFO i.a.w.t.TemporalAttemptExecution(get):107 - Cloud storage job log path: /workspace/112/0/logs.log 2022-04-19 18:22:56 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.0-alpha 2022-04-19 18:22:56 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization. 2022-04-19 18:22:56 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.75 2022-04-19 18:22:56 INFO i.a.w.p.KubeProcessFactory(create):113 - Attempting to start pod = normalization-sync-112-0-senpp for airbyte/normalization:0.1.75 2022-04-19 18:22:56 INFO i.a.w.p.KubeProcessFactory(create):116 - normalization-sync-112-0-senpp stdoutLocalPort = 9028 2022-04-19 18:22:56 INFO i.a.w.p.KubeProcessFactory(create):119 - normalization-sync-112-0-senpp stderrLocalPort = 9029 2022-04-19 18:22:56 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):583 - Creating stdout socket server... 2022-04-19 18:22:56 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):601 - Creating stderr socket server... 2022-04-19 18:22:56 INFO i.a.w.p.KubePodProcess():521 - Creating pod normalization-sync-112-0-senpp... 2022-04-19 18:22:36 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-19 18:22:36 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-04-19 18:22:36 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-04-19 18:22:36 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-04-19 18:22:39 destination > 2022-04-19 18:22:39 INFO i.a.i.d.r.RedshiftDestination(main):76 - starting destination: class io.airbyte.integrations.destination.redshift.RedshiftDestination 2022-04-19 18:22:40 destination > 2022-04-19 18:22:40 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-04-19 18:22:40 destination > 2022-04-19 18:22:40 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.redshift.RedshiftDestination 2022-04-19 18:22:40 destination > 2022-04-19 18:22:40 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-04-19 18:22:40 destination > 2022-04-19 18:22:40 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-04-19 18:22:41 destination > 2022-04-19 18:22: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-04-19 18:22:41 destination > 2022-04-19 18:22: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-04-19 18:22:41 destination > 2022-04-19 18:22:41 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3_WITH_SUPER_TMP_TYPE 2022-04-19 18:22:42 destination > 2022-04-19 18:22:42 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):165 - Creating S3 client... 2022-04-19 18:22:44 destination > 2022-04-19 18:22:44 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-04-19 18:22:44 destination > 2022-04-19 18:22:44 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-04-19 18:22:44 destination > 2022-04-19 18:22:44 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-04-19 18:22:44 destination > 2022-04-19 18:22:44 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):155 - Creating schema in destination if it doesn't exist: wine_stg 2022-04-19 18:22:48 destination > 2022-04-19 18:22:48 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):161 - Preparing tmp table in destination for stream: google_analytics_wine_transactions, schema: wine_stg, tmp table name: _airbyte_tmp_rbk_google_analytics_wine_transactions. 2022-04-19 18:22:51 destination > 2022-04-19 18:22:51 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):86 - Starting copy to tmp table: _airbyte_tmp_rbk_google_analytics_wine_transactions in destination for stream: google_analytics_wine_transactions, schema: wine_stg, . 2022-04-19 18:22:51 destination > 2022-04-19 18:22:51 INFO i.a.i.d.r.RedshiftStreamCopier(copyStagingFileToTemporaryTable):90 - Copy to tmp table _airbyte_tmp_rbk_google_analytics_wine_transactions in destination for stream google_analytics_wine_transactions complete. 2022-04-19 18:22:51 destination > 2022-04-19 18:22:51 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):177 - Preparing table _airbyte_raw_google_analytics_wine_transactions in destination. 2022-04-19 18:22:52 destination > 2022-04-19 18:22:52 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):179 - Table _airbyte_tmp_rbk_google_analytics_wine_transactions in destination prepared. 2022-04-19 18:22:52 destination > 2022-04-19 18:22:52 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):186 - Preparing to merge tmp table _airbyte_tmp_rbk_google_analytics_wine_transactions to dest table: _airbyte_raw_google_analytics_wine_transactions, schema: wine_stg, in destination. 2022-04-19 18:22:52 destination > 2022-04-19 18:22:52 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):190 - Destination OVERWRITE mode detected. Dest table: _airbyte_raw_google_analytics_wine_transactions, schema: wine_stg, truncated. 2022-04-19 18:22:54 destination > 2022-04-19 18:22:54 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):205 - Begin cleaning _airbyte_tmp_rbk_google_analytics_wine_transactions tmp table in destination. 2022-04-19 18:22:54 destination > 2022-04-19 18:22:54 ERROR i.a.i.d.b.BufferedStreamConsumer(close):191 - Close failed. 2022-04-19 18:22:54 destination > java.sql.SQLException: [Amazon](500310) Invalid operation: current transaction is aborted, commands ignored until end of transaction block; 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > Exception in thread "main" java.sql.SQLException: [Amazon](500310) Invalid operation: current transaction is aborted, commands ignored until end of transaction block; 2022-04-19 18:22:54 destination > at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.messages.inbound.ErrorResponse.toErrorException(Unknown Source) 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.handleErrorResponse(Unknown Source) 2022-04-19 18:22:54 destination > at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) ~[redshift-jdbc42-no-awssdk-1.2.51.1078.jar:RedshiftJDBC_1.2.51.1078] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.handleMessage(Unknown Source) 2022-04-19 18:22:54 destination > at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?] 2022-04-19 18:22:54 destination > at com.amazon.jdbc.communications.InboundMessagesPipeline.getNextMessageOfClass(Unknown Source) 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.doMoveToNextClass(Unknown Source) 2022-04-19 18:22:54 destination > at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.moveThroughMetadata(Unknown Source) 2022-04-19 18:22:54 destination > at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?] 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGMessagingContext.getNoData(Unknown Source) 2022-04-19 18:22:54 destination > at com.amazon.redshift.client.PGClient.directExecuteExtraMetadataWithMessage(Unknown Source) 2022-04-19 18:22:54 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: current transaction is aborted, commands ignored until end of transaction block; 2022-04-19 18:22:54 destination > at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) 2022-04-19 18:22:54 destination > at com.amazon.redshift.dataengine.PGQueryExecutor$CallableExecuteTask.call(Unknown Source) 2022-04-19 18:22:54 destination > ... 13 more 2022-04-19 18:22:54 destination > at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 2022-04-19 18:22:54 destination > at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) 2022-04-19 18:22:54 destination > at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) 2022-04-19 18:22:54 destination > Caused by: com.amazon.support.exceptions.ErrorException: [Amazon](500310) Invalid operation: current transaction is aborted, commands ignored until end of transaction block; 2022-04-19 18:22:54 destination > ... 13 more 2022-04-19 18:23:29 normalization > Running: transform-config --config destination_config.json --integration-type redshift --out /config 2022-04-19 18:23:29 normalization > Namespace(config='destination_config.json', integration_type=, out='/config') 2022-04-19 18:23:29 normalization > transform_redshift 2022-04-19 18:23:29 normalization > Running: transform-catalog --integration-type redshift --profile-config-dir /config --catalog destination_catalog.json --out /config/models/generated/ --json-column _airbyte_data 2022-04-19 18:23:29 normalization > Processing destination_catalog.json... 2022-04-19 18:23:29 normalization > Generating airbyte_ctes/wine_stg/google_analytics_wine_transactions_ab1.sql from google_analytics_wine_transactions 2022-04-19 18:23:29 normalization > Generating airbyte_ctes/wine_stg/google_analytics_wine_transactions_ab2.sql from google_analytics_wine_transactions 2022-04-19 18:23:29 normalization > Generating airbyte_ctes/wine_stg/google_analytics_wine_transactions_ab3.sql from google_analytics_wine_transactions 2022-04-19 18:23:29 normalization > Generating airbyte_tables/wine_stg/google_analytics_wine_transactions.sql from google_analytics_wine_transactions 2022-04-19 18:23:29 normalization > detected no config file for ssh, assuming ssh is off. 2022-04-19 18:23:35 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-04-19 18:23:35 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-04-19 18:23:35 normalization > 2022-04-19 18:23:35 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-04-19 18:23:35 normalization > 2022-04-19 18:23:26 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files... 2022-04-19 18:23:26 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):318 - Init container present.. 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):321 - Init container ready.. 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess():546 - Copying files... 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/498b2637-f41c-4246-9484-7216d6e452e8/destination_config.json airbyte/normalization-sync-112-0-senpp:/config/destination_config.json -c init 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/08fc52ac-eac7-4d5b-b2dc-1129364890b1/destination_catalog.json airbyte/normalization-sync-112-0-senpp:/config/destination_catalog.json -c init 2022-04-19 18:23:27 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/64ab1684-38c4-4f8b-9a2e-57c8a7884c01/FINISHED_UPLOADING airbyte/normalization-sync-112-0-senpp:/config/FINISHED_UPLOADING -c init 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess():549 - Waiting until pod is ready... 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):592 - Setting stdout... 2022-04-19 18:23:28 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):604 - Setting stderr... 2022-04-19 18:23:29 INFO i.a.w.p.KubePodProcess():564 - Reading pod IP... 2022-04-19 18:23:29 INFO i.a.w.p.KubePodProcess():566 - Pod IP: 100.65.248.232 2022-04-19 18:23:29 INFO i.a.w.p.KubePodProcess():573 - Using null stdin output stream... 2022-04-19 18:23:42 normalization > 18:23:42 Running with dbt=1.0.0 2022-04-19 18:23:42 normalization > 18:23:42 Partial parse save file not found. Starting full parse. 2022-04-19 18:23:46 normalization > 18:23:46 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-04-19 18:23:46 normalization > There are 2 unused configuration paths: 2022-04-19 18:23:46 normalization > - models.airbyte_utils.generated.airbyte_incremental 2022-04-19 18:23:46 normalization > - models.airbyte_utils.generated.airbyte_views 2022-04-19 18:23:46 normalization > 2022-04-19 18:23:46 normalization > 18:23:46 Found 4 models, 0 tests, 0 snapshots, 0 analyses, 540 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2022-04-19 18:23:46 normalization > 18:23:46 2022-04-19 18:23:48 normalization > 18:23:48 Concurrency: 4 threads (target='prod') 2022-04-19 18:23:48 normalization > 18:23:48 2022-04-19 18:23:49 normalization > 18:23:49 1 of 1 START table model wine_stg.google_analytics_wine_transactions.................................................... [RUN] 2022-04-19 18:24:23 normalization > 18:24:23 1 of 1 OK created table model wine_stg.google_analytics_wine_transactions............................................... [SELECT in 34.34s] 2022-04-19 18:24:23 normalization > 18:24:23 2022-04-19 18:24:23 normalization > 18:24:23 Finished running 1 table model in 36.92s. 2022-04-19 18:24:23 normalization > 18:24:23 2022-04-19 18:24:23 normalization > 18:24:23 Completed successfully 2022-04-19 18:24:23 normalization > 18:24:23 2022-04-19 18:24:23 normalization > 18:24:23 Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1 2022-04-19 18:24:24 INFO i.a.w.p.KubePodProcess(close):713 - (pod: airbyte / normalization-sync-112-0-senpp) - Closed all resources for pod 2022-04-19 18:24:24 INFO i.a.w.DefaultNormalizationWorker(run):71 - Normalization executed in 1 minute 28 seconds. 2022-04-19 18:24:24 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-04-19 18:24:24 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...