2022-05-17 08:45:53 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-05-17 08:45:53 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/56/0/logs.log 2022-05-17 08:45:53 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-05-17 08:45:53 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 56 attempt id: 0 2022-05-17 08:45:53 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {null.Attribute_Bundle_Item_Mapping__Tag=incremental - append_dedup} 2022-05-17 08:45:53 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination... 2022-05-17 08:45:53 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.17 exists... 2022-05-17 08:45:53 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.17 was found locally. 2022-05-17 08:45:53 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 56 2022-05-17 08:45:53 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/56/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.17 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=56 airbyte/destination-postgres:0.3.17 write --config destination_config.json --catalog destination_catalog.json 2022-05-17 08:45:53 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-salesforce:1.0.9 exists... 2022-05-17 08:45:53 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-salesforce:1.0.9 was found locally. 2022-05-17 08:45:53 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 56 2022-05-17 08:45:53 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/56/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-salesforce:1.0.9 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha -e WORKER_JOB_ID=56 airbyte/source-salesforce:1.0.9 read --config source_config.json --catalog source_catalog.json 2022-05-17 08:45:53 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started. 2022-05-17 08:45:53 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started. 2022-05-17 08:45:53 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete. 2022-05-17 08:45:54 destination > SLF4J: Class path contains multiple SLF4J bindings. 2022-05-17 08:45:54 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-17 08:45:54 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class] 2022-05-17 08:45:54 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 2022-05-17 08:45:54 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory] 2022-05-17 08:45:54 source > Starting generating streams 2022-05-17 08:45:54 destination > 2022-05-17 08:45:54 INFO i.a.i.d.p.PostgresDestination(main):77 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-05-17 08:45:54 destination > 2022-05-17 08:45:54 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2022-05-17 08:45:54 destination > 2022-05-17 08:45:54 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-05-17 08:45:54 destination > 2022-05-17 08:45:54 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE 2022-05-17 08:45:54 destination > 2022-05-17 08:45:54 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2022-05-17 08:45:55 destination > 2022-05-17 08:45:55 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-05-17 08:45:55 destination > 2022-05-17 08:45:55 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-05-17 08:45:55 destination > 2022-05-17 08:45:55 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-05-17 08:45:55 destination > 2022-05-17 08:45:55 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-05-17 08:45:55 source > Starting syncing SourceSalesforce 2022-05-17 08:45:55 source > Syncing stream: Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:55 destination > 2022-05-17 08:45:55 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL 2022-05-17 08:45:55 source > error body: [{"errorCode":"INVALIDENTITY","message":"Entity '01I0e000000FMSK.Tag' is not supported by the Bulk API."}], sobject options: {'activateable': False, 'associateEntityType': 'Tag', 'associateParentEntity': 'Attribute_Bundle_Item_Mapping__c', 'createable': True, 'custom': False, 'customSetting': False, 'deepCloneable': False, 'deletable': True, 'deprecatedAndHidden': False, 'feedEnabled': False, 'hasSubtypes': False, 'isInterface': False, 'isSubtype': False, 'keyPrefix': None, 'label': 'Tag: Attribute To Bundle Item Mapping', 'labelPlural': 'Tag: Attribute To Bundle Item Mapping', 'layoutable': False, 'mergeable': False, 'mruEnabled': False, 'queryable': True, 'replicateable': False, 'retrieveable': True, 'searchable': False, 'triggerable': False, 'undeletable': False, 'updateable': False, 'urls': {'rowTemplate': '/services/data/v52.0/sobjects/Attribute_Bundle_Item_Mapping__Tag/{ID}', 'describe': '/services/data/v52.0/sobjects/Attribute_Bundle_Item_Mapping__Tag/describe', 'sobject': '/services/data/v52.0/sobjects/Attribute_Bundle_Item_Mapping__Tag'}} 2022-05-17 08:45:55 source > Giving up for returned HTTP status: 400, body: [{"errorCode":"INVALIDENTITY","message":"Entity '01I0e000000FMSK.Tag' is not supported by the Bulk API."}] 2022-05-17 08:45:55 source > Giving up _send_http_request(...) after 1 tries (requests.exceptions.HTTPError: 400 Client Error: Bad Request for url: https://global.my.salesforce.com/services/data/v52.0/jobs/query) 2022-05-17 08:45:55 source > Cannot receive data for stream 'Attribute_Bundle_Item_Mapping__Tag' using BULK API, sobject options: {'activateable': False, 'associateEntityType': 'Tag', 'associateParentEntity': 'Attribute_Bundle_Item_Mapping__c', 'createable': True, 'custom': False, 'customSetting': False, 'deepCloneable': False, 'deletable': True, 'deprecatedAndHidden': False, 'feedEnabled': False, 'hasSubtypes': False, 'isInterface': False, 'isSubtype': False, 'keyPrefix': None, 'label': 'Tag: Attribute To Bundle Item Mapping', 'labelPlural': 'Tag: Attribute To Bundle Item Mapping', 'layoutable': False, 'mergeable': False, 'mruEnabled': False, 'queryable': True, 'replicateable': False, 'retrieveable': True, 'searchable': False, 'triggerable': False, 'undeletable': False, 'updateable': False, 'urls': {'rowTemplate': '/services/data/v52.0/sobjects/Attribute_Bundle_Item_Mapping__Tag/{ID}', 'describe': '/services/data/v52.0/sobjects/Attribute_Bundle_Item_Mapping__Tag/describe', 'sobject': '/services/data/v52.0/sobjects/Attribute_Bundle_Item_Mapping__Tag'}}, error message: 'Entity '01I0e000000FMSK.Tag' is not supported by the Bulk API.' 2022-05-17 08:45:55 source > Encountered an exception while reading stream SourceSalesforce Traceback (most recent call last): File "/airbyte/integration_code/source_salesforce/source.py", line 111, in read yield from self._read_stream( File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 159, in _read_stream for record in record_iterator: File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 215, in _read_incremental for record_counter, record_data in enumerate(records, start=1): File "/airbyte/integration_code/source_salesforce/streams.py", line 381, in read_records raise SalesforceException(f"Job for {self.name} stream using BULK API was failed.") source_salesforce.exceptions.SalesforceException: Job for Attribute_Bundle_Item_Mapping__Tag stream using BULK API was failed. 2022-05-17 08:45:55 source > Job for Attribute_Bundle_Item_Mapping__Tag stream using BULK API was failed. Traceback (most recent call last): File "/airbyte/integration_code/main.py", line 13, in launch(source, sys.argv[1:]) File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 129, in launch for message in source_entrypoint.run(parsed_args): File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 120, in run for message in generator: File "/airbyte/integration_code/source_salesforce/source.py", line 128, in read raise e File "/airbyte/integration_code/source_salesforce/source.py", line 111, in read yield from self._read_stream( File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 159, in _read_stream for record in record_iterator: File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 215, in _read_incremental for record_counter, record_data in enumerate(records, start=1): File "/airbyte/integration_code/source_salesforce/streams.py", line 381, in read_records raise SalesforceException(f"Job for {self.name} stream using BULK API was failed.") source_salesforce.exceptions.SalesforceException: Job for Attribute_Bundle_Item_Mapping__Tag stream using BULK API was failed. 2022-05-17 08:45:55 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. errors: $.type: does not have a value in the enumeration [RECORD, STATE, LOG, SPEC, CONNECTION_STATUS, CATALOG] 2022-05-17 08:45:55 ERROR i.a.w.p.a.DefaultAirbyteStreamFactory(lambda$create$1):70 - Validation failed: {"type":"TRACE","trace":{"type":"ERROR","emitted_at":1.652777155505008E12,"error":{"message":"Something went wrong in the connector. See the logs for more details.","internal_message":"Job for Attribute_Bundle_Item_Mapping__Tag stream using BULK API was failed.","stack_trace":"Traceback (most recent call last):\n File \"/airbyte/integration_code/main.py\", line 13, in \n launch(source, sys.argv[1:])\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 129, in launch\n for message in source_entrypoint.run(parsed_args):\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py\", line 120, in run\n for message in generator:\n File \"/airbyte/integration_code/source_salesforce/source.py\", line 128, in read\n raise e\n File \"/airbyte/integration_code/source_salesforce/source.py\", line 111, in read\n yield from self._read_stream(\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 159, in _read_stream\n for record in record_iterator:\n File \"/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py\", line 215, in _read_incremental\n for record_counter, record_data in enumerate(records, start=1):\n File \"/airbyte/integration_code/source_salesforce/streams.py\", line 381, in read_records\n raise SalesforceException(f\"Job for {self.name} stream using BULK API was failed.\")\nsource_salesforce.exceptions.SalesforceException: Job for Attribute_Bundle_Item_Mapping__Tag stream using BULK API was failed.\n","failure_type":"system_error"}}} 2022-05-17 08:45:55 destination > 2022-05-17 08:45:55 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=Attribute_Bundle_Item_Mapping__Tag, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_eqd_Attribute_Bundle_Item_Mapping__Tag, outputTableName=_airbyte_raw_Attribute_Bundle_Item_Mapping__Tag, syncMode=append_dedup} 2022-05-17 08:45:55 destination > 2022-05-17 08:45:55 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2022-05-17 08:45:55 destination > 2022-05-17 08:45:55 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams 2022-05-17 08:45:55 destination > 2022-05-17 08:45:55 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream Attribute_Bundle_Item_Mapping__Tag. schema: public, tmp table name: _airbyte_tmp_eqd_Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 0 (0 bytes) 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed. 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded. 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure. 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):161 - Finalizing tables in destination started for 1 streams 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):166 - Finalizing stream Attribute_Bundle_Item_Mapping__Tag. schema public, tmp table _airbyte_tmp_eqd_Attribute_Bundle_Item_Mapping__Tag, final table _airbyte_raw_Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):179 - Executing finalization of tables. 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Finalizing tables in destination completed. 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):184 - Cleaning tmp tables in destination started for 1 streams 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):188 - Cleaning tmp table in destination started for stream Attribute_Bundle_Item_Mapping__Tag. schema public, tmp table name: _airbyte_tmp_eqd_Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):193 - Cleaning tmp tables in destination completed. 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination 2022-05-17 08:45:56 destination > 2022-05-17 08:45:56 INFO i.a.i.d.p.PostgresDestination(main):79 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2022-05-17 08:45:56 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed. java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source 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:162) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled. at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.36.1-alpha.jar:?] at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) ~[io.airbyte-airbyte-workers-0.36.1-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-05-17 08:45:56 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@3866b241[status=failed,recordsSynced=0,bytesSynced=0,startTime=1652777153374,endTime=1652777156152,totalStats=io.airbyte.config.SyncStats@7507db93[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]] 2022-05-17 08:45:56 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages 2022-05-17 08:45:56 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained. 2022-05-17 08:45:56 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-05-17 08:45:56 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@4805e61a[standardSyncSummary=io.airbyte.config.StandardSyncSummary@35447ac4[status=failed,recordsSynced=0,bytesSynced=0,startTime=1652777153374,endTime=1652777156152,totalStats=io.airbyte.config.SyncStats@7507db93[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=,state=,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@3021d930[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@64a5e403[stream=io.airbyte.protocol.models.AirbyteStream@3f7ebbb[name=Attribute_Bundle_Item_Mapping__Tag,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"Id":{"type":["string","null"]},"Name":{"type":["string","null"]},"Type":{"type":["string","null"]},"ItemId":{"type":["string","null"]},"IsDeleted":{"type":["boolean","null"]},"CreatedDate":{"type":["string","null"],"format":"date-time"},"SystemModstamp":{"type":["string","null"],"format":"date-time"},"TagDefinitionId":{"type":["string","null"]}},"additionalProperties":true},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[SystemModstamp],sourceDefinedPrimaryKey=[[Id]],namespace=,additionalProperties={}],syncMode=incremental,cursorField=[SystemModstamp],destinationSyncMode=append_dedup,primaryKey=[[Id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@1573235b[failureOrigin=source,failureType=,internalMessage=io.airbyte.workers.DefaultReplicationWorker$SourceException: Source process exited with non-zero exit code 1,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@2b25909c[additionalProperties={attemptNumber=0, jobId=56}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$SourceException: Source 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$SourceException: Source process exited with non-zero exit code 1 at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:312) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ... 3 more ,retryable=,timestamp=1652777155796]]] 2022-05-17 08:45:56 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating... 2022-05-17 08:45:56 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/56/0/logs.log 2022-05-17 08:45:56 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.36.1-alpha 2022-05-17 08:45:56 INFO i.a.w.DefaultNormalizationWorker(run):47 - Running normalization. 2022-05-17 08:45:56 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.75 2022-05-17 08:45:56 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.75 exists... 2022-05-17 08:45:56 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.75 not found locally. Attempting to pull the image... 2022-05-17 08:45:57 INFO i.a.c.i.LineGobbler(voidCall):82 - Pulled airbyte/normalization:0.1.75 from remote. 2022-05-17 08:45:57 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 56 2022-05-17 08:45:57 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/56/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.36.1-alpha airbyte/normalization:0.1.75 run --integration-type postgres --config destination_config.json --catalog destination_catalog.json 2022-05-17 08:45:57 normalization > Running: transform-config --config destination_config.json --integration-type postgres --out /data/56/0/normalize 2022-05-17 08:45:57 normalization > Namespace(config='destination_config.json', integration_type=, out='/data/56/0/normalize') 2022-05-17 08:45:57 normalization > transform_postgres 2022-05-17 08:45:57 normalization > Running: transform-catalog --integration-type postgres --profile-config-dir /data/56/0/normalize --catalog destination_catalog.json --out /data/56/0/normalize/models/generated/ --json-column _airbyte_data 2022-05-17 08:45:57 normalization > Processing destination_catalog.json... 2022-05-17 08:45:57 normalization > Generating airbyte_ctes/public/attribute_bundle_item_mapping__tag_ab1.sql from Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:57 normalization > Generating airbyte_ctes/public/attribute_bundle_item_mapping__tag_ab2.sql from Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:57 normalization > Truncating _airbyte_attribute_bundle_item_mapping__tag_hashid (#50) to _airbyte_attribute_b_m_mapping__tag_hashid (#43) 2022-05-17 08:45:57 normalization > Generating airbyte_incremental/public/attribute_bundle_item_mapping__tag_stg.sql from Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:57 normalization > Truncating _airbyte_attribute_bundle_item_mapping__tag_hashid (#50) to _airbyte_attribute_b_m_mapping__tag_hashid (#43) 2022-05-17 08:45:57 normalization > Generating airbyte_incremental/scd/public/attribute_bundle_item_mapping__tag_scd.sql from Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:57 normalization > Truncating _airbyte_attribute_bundle_item_mapping__tag_hashid (#50) to _airbyte_attribute_b_m_mapping__tag_hashid (#43) 2022-05-17 08:45:57 normalization > Generating airbyte_incremental/public/attribute_bundle_item_mapping__tag.sql from Attribute_Bundle_Item_Mapping__Tag 2022-05-17 08:45:57 normalization > detected no config file for ssh, assuming ssh is off. 2022-05-17 08:45:59 normalization > [--event-buffer-size EVENT_BUFFER_SIZE] 2022-05-17 08:45:59 normalization > --event-buffer-size EVENT_BUFFER_SIZE 2022-05-17 08:45:59 normalization > 2022-05-17 08:45:59 normalization > DBT >=1.0.0 detected; using 10K event buffer size 2022-05-17 08:45:59 normalization > 2022-05-17 08:46:01 normalization > 08:46:01 Running with dbt=1.0.0 2022-05-17 08:46:01 normalization > 08:46:01 Partial parse save file not found. Starting full parse. 2022-05-17 08:46:02 normalization > 08:46:02 [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources. 2022-05-17 08:46:02 normalization > There are 2 unused configuration paths: 2022-05-17 08:46:02 normalization > - models.airbyte_utils.generated.airbyte_tables 2022-05-17 08:46:02 normalization > - models.airbyte_utils.generated.airbyte_views 2022-05-17 08:46:02 normalization > 2022-05-17 08:46:02 normalization > 08:46:02 Found 5 models, 0 tests, 0 snapshots, 0 analyses, 514 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics 2022-05-17 08:46:02 normalization > 08:46:02 2022-05-17 08:46:03 normalization > 08:46:03 Concurrency: 8 threads (target='prod') 2022-05-17 08:46:03 normalization > 08:46:03 2022-05-17 08:46:03 normalization > 08:46:03 1 of 3 START incremental model _airbyte_public.attribute_bundle_item_mapping__tag_stg................................... [RUN] 2022-05-17 08:46:03 normalization > 08:46:03 08:46:03 + "dc_web_dev"._airbyte_public."attribute_bundle_item_mapping__tag_stg"._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-05-17 08:46:03 normalization > 08:46:03 1 of 3 OK created incremental model _airbyte_public.attribute_bundle_item_mapping__tag_stg.............................. [SELECT 0 in 0.17s] 2022-05-17 08:46:03 normalization > 08:46:03 2 of 3 START incremental model public.attribute_bundle_item_mapping__tag_scd............................................ [RUN] 2022-05-17 08:46:03 normalization > 08:46:03 08:46:03 + "dc_web_dev".public."attribute_bundle_item_mapping__tag_scd"._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-05-17 08:46:03 normalization > 08:46:03 2 of 3 OK created incremental model public.attribute_bundle_item_mapping__tag_scd....................................... [SELECT 0 in 0.06s] 2022-05-17 08:46:03 normalization > 08:46:03 3 of 3 START incremental model public.attribute_bundle_item_mapping__tag................................................ [RUN] 2022-05-17 08:46:03 normalization > 08:46:03 08:46:03 + "dc_web_dev".public."attribute_bundle_item_mapping__tag"._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh 2022-05-17 08:46:03 normalization > 08:46:03 3 of 3 OK created incremental model public.attribute_bundle_item_mapping__tag........................................... [SELECT 0 in 0.05s] 2022-05-17 08:46:03 normalization > 08:46:03 2022-05-17 08:46:03 normalization > 08:46:03 Finished running 3 incremental models in 0.53s. 2022-05-17 08:46:03 normalization > 08:46:03 2022-05-17 08:46:03 normalization > 08:46:03 Completed successfully 2022-05-17 08:46:03 normalization > 08:46:03 2022-05-17 08:46:03 normalization > 08:46:03 Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3 2022-05-17 08:46:03 INFO i.a.w.DefaultNormalizationWorker(run):71 - Normalization executed in 7 seconds. 2022-05-17 08:46:03 INFO i.a.w.DefaultNormalizationWorker(run):77 - Normalization summary: io.airbyte.config.NormalizationSummary@20157111[startTime=1652777156202,endTime=1652777163804] 2022-05-17 08:46:03 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling... 2022-05-17 08:46:03 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...