2022-04-13 08:17:18 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-13 08:17:18 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/28/0/logs.log
2022-04-13 08:17:18 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-13 08:17:18 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 28 attempt id: 0
2022-04-13 08:17:18 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {dbo.Transactions=full_refresh - append}
2022-04-13 08:17:18 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-13 08:17:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-mysql:0.1.18 exists...
2022-04-13 08:17:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-mysql:0.1.18 was found locally.
2022-04-13 08:17:18 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 28
2022-04-13 08:17:18 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/28/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-mysql:0.1.18 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=28 airbyte/destination-mysql:0.1.18 write --config destination_config.json --catalog destination_catalog.json
2022-04-13 08:17:18 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-mssql:0.3.19 exists...
2022-04-13 08:17:18 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-mssql:0.3.19 was found locally.
2022-04-13 08:17:18 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 28
2022-04-13 08:17:18 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/28/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.3.19 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=28 airbyte/source-mssql:0.3.19 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-04-13 08:17:18 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-13 08:17:18 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-13 08:17:18 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-13 08:17:19 source > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-13 08:17:19 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:17:19 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:17:19 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-13 08:17:19 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-13 08:17:19 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-13 08:17:19 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:17:19 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-13 08:17:19 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-13 08:17:19 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-13 08:17:20 source > 2022-04-13 08:17:20 INFO i.a.i.s.m.MssqlSource(main):448 - starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-04-13 08:17:20 destination > 2022-04-13 08:17:20 INFO i.a.i.d.m.MySQLDestination(main):125 - starting destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-13 08:17:20 source > 2022-04-13 08:17:20 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-04-13 08:17:20 source > 2022-04-13 08:17:20 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-13 08:17:20 source > 2022-04-13 08:17:20 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ
2022-04-13 08:17:20 source > 2022-04-13 08:17:20 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-04-13 08:17:20 source > 2022-04-13 08:17:20 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-04-13 08:17:20 source > 2022-04-13 08:17:20 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-13 08:17:20 source > 2022-04-13 08:17:20 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-13 08:17:20 source > 2022-04-13 08:17:20 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-04-13 08:17:21 source > 2022-04-13 08:17:21 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-13 08:17:21 source > 2022-04-13 08:17:21 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-04-13 08:17:21 source > 2022-04-13 08:17:21 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='Transactions', namespace='dbo'}, New Cursor Field: null. Resetting cursor value
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column id (type int[10]) -> Json type io.airbyte.protocol.models.JsonSchemaType@45792847
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column name (type varchar[25]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4e25147a
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column state (type varchar[25]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4e25147a
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):137 - Table Transactions column date (type datetime[23]) -> Json type io.airbyte.protocol.models.JsonSchemaType@4e25147a
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.m.MssqlSource(getIncrementalIterators):361 - using CDC: false
2022-04-13 08:17:22 destination > 2022-04-13 08:17:22 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):74 - Queueing query for table: Transactions
2022-04-13 08:17:22 destination > 2022-04-13 08:17:22 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: a519460e1bc44227a997d312d521d3a1
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.m.MssqlSource(queryTableFullRefresh):83 - Prepared SQL query for TableFullRefresh is: SELECT "id","name","state","date" FROM "dbo"."Transactions"
2022-04-13 08:17:22 destination > 2022-04-13 08:17:22 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-13 08:17:22 destination > 2022-04-13 08:17:22 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE
2022-04-13 08:17:22 destination > 2022-04-13 08:17:22 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):124 - Closing database connection pool.
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):126 - Closed database connection pool.
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-04-13 08:17:22 source > 2022-04-13 08:17:22 INFO i.a.i.s.m.MssqlSource(main):450 - completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 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-04-13 08:17:23 destination > 2022-04-13 08:17:23 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-13 08:17:23 destination > 2022-04-13 08:17:23 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-13 08:17:23 destination > 2022-04-13 08:17:23 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-04-13 08:17:23 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 0 (0 bytes)
2022-04-13 08:17:23 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - Write config: WriteConfig{streamName=Transactions, namespace=null, outputSchemaName=test_airbyte_2, tmpTableName=_airbyte_tmp_zca_transactions, outputTableName=_airbyte_raw_transactions, syncMode=append}
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - Preparing tmp tables in destination started for 1 streams
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - Preparing tmp table in destination started for stream Transactions. schema: test_airbyte_2, tmp table name: _airbyte_tmp_zca_transactions
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - Preparing tables in destination completed.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 0 bytes
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - Finalizing tables in destination started for 1 streams
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - Finalizing stream Transactions. schema test_airbyte_2, tmp table _airbyte_tmp_zca_transactions, final table _airbyte_raw_transactions
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - Executing finalization of tables.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - Finalizing tables in destination completed.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - Cleaning tmp tables in destination started for 1 streams
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - Cleaning tmp table in destination started for stream Transactions. schema test_airbyte_2, tmp table name: _airbyte_tmp_zca_transactions
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - Cleaning tmp tables in destination completed.
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-04-13 08:17:23 destination > 2022-04-13 08:17:23 INFO i.a.i.d.m.MySQLDestination(main):127 - completed destination: class io.airbyte.integrations.destination.mysql.MySQLDestination
2022-04-13 08:17:24 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-04-13 08:17:24 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@dbb78cb[status=completed,recordsSynced=0,bytesSynced=0,startTime=1649837838590,endTime=1649837844042,totalStats=io.airbyte.config.SyncStats@5d0f094e[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-04-13 08:17:24 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-13 08:17:24 WARN i.a.w.DefaultReplicationWorker(run):258 - State capture: No new state, falling back on input state: io.airbyte.config.State@bcd59f1[state={}]
2022-04-13 08:17:24 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-13 08:17:24 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@1e7126c4[standardSyncSummary=io.airbyte.config.StandardSyncSummary@252edc3e[status=completed,recordsSynced=0,bytesSynced=0,startTime=1649837838590,endTime=1649837844042,totalStats=io.airbyte.config.SyncStats@5d0f094e[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],state=io.airbyte.config.State@bcd59f1[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@66456b58[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@74df304d[stream=io.airbyte.protocol.models.AirbyteStream@638f7f14[name=Transactions,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"date":{"type":"string"},"name":{"type":"string"},"state":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-04-13 08:17:24 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-13 08:17:24 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 96bc49ca-26df-4898-8d86-7339b55a0883 state: io.airbyte.config.State@7091283b[state={}]
2022-04-13 08:17:24 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/28/0/logs.log
2022-04-13 08:17:24 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-13 08:17:24 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-04-13 08:17:24 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-mysql:0.1.74
2022-04-13 08:17:24 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-mysql:0.1.74 exists...
2022-04-13 08:17:24 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-mysql:0.1.74 was found locally.
2022-04-13 08:17:24 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 28
2022-04-13 08:17:24 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/28/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha airbyte/normalization-mysql:0.1.74 run --integration-type mysql --config destination_config.json --catalog destination_catalog.json
2022-04-13 08:17:24 normalization > Running: transform-config --config destination_config.json --integration-type mysql --out /data/28/0/normalize
2022-04-13 08:17:24 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.mysql: 'mysql'>, out='/data/28/0/normalize')
2022-04-13 08:17:24 normalization > transform_mysql
2022-04-13 08:17:24 normalization > Running: transform-catalog --integration-type mysql --profile-config-dir /data/28/0/normalize --catalog destination_catalog.json --out /data/28/0/normalize/models/generated/ --json-column _airbyte_data
2022-04-13 08:17:25 normalization > Processing destination_catalog.json...
2022-04-13 08:17:25 normalization >   Generating airbyte_ctes/test_airbyte_2/transactions_ab1.sql from Transactions
2022-04-13 08:17:25 normalization >   Generating airbyte_ctes/test_airbyte_2/transactions_ab2.sql from Transactions
2022-04-13 08:17:25 normalization >   Generating airbyte_ctes/test_airbyte_2/transactions_ab3.sql from Transactions
2022-04-13 08:17:25 normalization >   Generating airbyte_incremental/test_airbyte_2/transactions.sql from Transactions
2022-04-13 08:17:25 normalization > detected no config file for ssh, assuming ssh is off.
2022-04-13 08:17:26 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):158 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 3 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-13 08:17:26 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-13 08:17:26 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-13 08:17:26 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=aedc81bc-1ea5-35fb-84fb-9cb5ed3ad190, activityType=Normalize, attempt=1
java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:233) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:71) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.temporal.serviceclient.CheckedExceptionWrapper.wrap(CheckedExceptionWrapper.java:56) ~[temporal-serviceclient-1.8.1.jar:?]
	at io.temporal.internal.sync.WorkflowInternal.wrap(WorkflowInternal.java:448) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.activity.Activity.wrap(Activity.java:51) ~[temporal-sdk-1.8.1.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:135) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:97) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 14 more
Caused by: java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:129) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:97) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 14 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	... 1 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:160) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]