2022-04-11 06:21:40 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.45-alpha
2022-04-11 06:21:41 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/215/0/logs.log
2022-04-11 06:21:41 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.45-alpha
2022-04-11 06:21:41 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 215 attempt id: 0
2022-04-11 06:21:41 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.sports=full_refresh - append}
2022-04-11 06:21:41 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-11 06:21:41 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-snowflake:0.4.17 exists...
2022-04-11 06:21:41 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-snowflake:0.4.17 was found locally.
2022-04-11 06:21:41 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 215
2022-04-11 06:21:41 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/215/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-snowflake:0.4.17 write --config destination_config.json --catalog destination_catalog.json
2022-04-11 06:21:41 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-python:dev exists...
2022-04-11 06:21:41 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-python:dev was found locally.
2022-04-11 06:21:41 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 215
2022-04-11 06:21:41 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/215/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-python:dev read --config source_config.json --catalog source_catalog.json
2022-04-11 06:21:41 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):338 - Destination output thread started.
2022-04-11 06:21:41 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-04-11 06:21:41 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-04-11 06:21:44 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-04-11 06:21:44 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-11 06:21:44 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-04-11 06:21:44 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-04-11 06:21:44 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-04-11 06:21:44 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):304 - Total records read: 1
2022-04-11 06:21:44 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-04-11 06:21:47 destination > 2022-04-11 06:21:47 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-11 06:21:47 destination > 2022-04-11 06:21:47 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: e48ede2aaa104cf3bbadc752ee962e83
2022-04-11 06:21:47 destination > 2022-04-11 06:21:47 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-11 06:21:47 destination > 2022-04-11 06:21:47 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: WRITE
2022-04-11 06:21:47 destination > 2022-04-11 06:21:47 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-11 06:21:47 destination > 2022-04-11 06:21:47 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-11 06:21:47 destination > 2022-04-11 06:21:47 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-11 06:21:47 destination > 2022-04-11 06:21:47 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-11 06:21:47 destination > 2022-04-11 06:21:47 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-11 06:21:47 destination > 2022-04-11 06:21:47 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: INTERNAL_STAGING
2022-04-11 06:21:48 destination > 2022-04-11 06:21:48 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$toWriteConfig$0):92 - Write config: WriteConfig{streamName=sports, namespace=null, outputSchemaName=PUBLIC, tmpTableName=_airbyte_tmp_ffl_sports, outputTableName=_airbyte_raw_sports, syncMode=append}
2022-04-11 06:21:48 destination > 2022-04-11 06:21:48 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-04-11 06:21:48 destination > 2022-04-11 06:21:48 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):111 - Preparing tmp tables in destination started for 1 streams
2022-04-11 06:21:48 destination > 2022-04-11 06:21:48 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):119 - Preparing stage in destination started for schema PUBLIC stream sports: tmp table: _airbyte_tmp_ffl_sports, stage: PUBLIC_AIRBYTE_RAW_SPORTS
2022-04-11 06:21:50 destination > 2022-04-11 06:21:50 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection
2022-04-11 06:21:50 destination > 2022-04-11 06:21:50 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):130 - Preparing stage in destination completed for schema PUBLIC stream sports
2022-04-11 06:21:50 destination > 2022-04-11 06:21:50 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onStartFunction$2):133 - Preparing tables in destination completed.
2022-04-11 06:21:51 destination > 2022-04-11 06:21:51 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-04-11 06:21:51 destination > 2022-04-11 06:21:51 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-04-11 06:21:51 destination > 2022-04-11 06:21:51 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 100 bytes
2022-04-11 06:21:51 destination > 2022-04-11 06:21:51 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing sports: 1 records
2022-04-11 06:21:51 destination > 2022-04-11 06:21:51 INFO i.a.i.d.s.SnowflakeStagingSqlOperations(insertRecordsInternal):29 - Writing 1 records to PUBLIC_AIRBYTE_RAW_SPORTS/STAGED/E5AAA60A-B9EA-4224-8382-DC94D12B5B6D
2022-04-11 06:21:52 destination > 2022-04-11 06:21:52 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):173 - Finalizing tables in destination started for 1 streams
2022-04-11 06:21:52 destination > 2022-04-11 06:21:52 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):181 - Finalizing stream sports. schema PUBLIC, tmp table _airbyte_tmp_ffl_sports, final table _airbyte_raw_sports, stage path PUBLIC_AIRBYTE_RAW_SPORTS/STAGED/E5AAA60A-B9EA-4224-8382-DC94D12B5B6D
2022-04-11 06:21:54 destination > 2022-04-11 06:21:54 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):201 - Executing finalization of tables.
2022-04-11 06:21:55 destination > 2022-04-11 06:21:55 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):203 - Finalizing tables in destination completed.
2022-04-11 06:21:55 destination > 2022-04-11 06:21:55 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):205 - Cleaning tmp tables in destination started for 1 streams
2022-04-11 06:21:55 destination > 2022-04-11 06:21:55 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):209 - Cleaning tmp table in destination started for stream sports. schema PUBLIC, tmp table name: _airbyte_tmp_ffl_sports
2022-04-11 06:21:55 destination > 2022-04-11 06:21:55 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):215 - Cleaning stage in destination started for stream sports. schema PUBLIC, stage: PUBLIC_AIRBYTE_RAW_SPORTS
2022-04-11 06:21:55 destination > 2022-04-11 06:21:55 INFO i.a.i.d.s.SnowflakeInternalStagingConsumerFactory(lambda$onCloseFunction$4):219 - Cleaning tmp tables and stages in destination completed.
2022-04-11 06:21:55 destination > 2022-04-11 06:21:55 INFO i.a.i.b.IntegrationRunner(runInternal):154 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-04-11 06:21:56 INFO i.a.w.DefaultReplicationWorker(run):164 - Source and destination threads complete.
2022-04-11 06:21:56 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@4b201d7c[status=completed,recordsSynced=1,bytesSynced=25,startTime=1649658101513,endTime=1649658116909,totalStats=io.airbyte.config.SyncStats@6427f4e6[recordsEmitted=1,bytesEmitted=25,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@75af6130[streamName=sports,stats=io.airbyte.config.SyncStats@7e2792cd[recordsEmitted=1,bytesEmitted=25,stateMessagesEmitted=<null>,recordsCommitted=1]]]]
2022-04-11 06:21:56 INFO i.a.w.DefaultReplicationWorker(run):249 - Source did not output any state messages
2022-04-11 06:21:56 WARN i.a.w.DefaultReplicationWorker(run):260 - State capture: No state retained.
2022-04-11 06:21:56 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-11 06:21:56 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@5f189635[standardSyncSummary=io.airbyte.config.StandardSyncSummary@566b968[status=completed,recordsSynced=1,bytesSynced=25,startTime=1649658101513,endTime=1649658116909,totalStats=io.airbyte.config.SyncStats@6427f4e6[recordsEmitted=1,bytesEmitted=25,stateMessagesEmitted=0,recordsCommitted=1],streamStats=[io.airbyte.config.StreamSyncStats@75af6130[streamName=sports,stats=io.airbyte.config.SyncStats@7e2792cd[recordsEmitted=1,bytesEmitted=25,stateMessagesEmitted=<null>,recordsCommitted=1]]]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@270c9bec[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@54b7155a[stream=io.airbyte.protocol.models.AirbyteStream@4f0588c7[name=sports,jsonSchema={},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-04-11 06:21:56 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-11 06:21:56 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/215/0/logs.log
2022-04-11 06:21:56 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.45-alpha
2022-04-11 06:21:57 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-04-11 06:21:57 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.1.68
2022-04-11 06:21:57 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-snowflake:0.1.68 exists...
2022-04-11 06:21:57 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-snowflake:0.1.68 was found locally.
2022-04-11 06:21:57 INFO i.a.w.p.DockerProcessFactory(create):104 - Creating docker job ID: 215
2022-04-11 06:21:57 INFO i.a.w.p.DockerProcessFactory(create):155 - Preparing command: docker run --rm --init -i -w /data/215/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization-snowflake:0.1.68 run --integration-type snowflake --config destination_config.json --catalog destination_catalog.json
2022-04-11 06:21:57 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /data/215/0/normalize
2022-04-11 06:21:57 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.snowflake: 'snowflake'>, out='/data/215/0/normalize')
2022-04-11 06:21:57 normalization > transform_snowflake
2022-04-11 06:21:57 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /data/215/0/normalize --catalog destination_catalog.json --out /data/215/0/normalize/models/generated/ --json-column _airbyte_data
2022-04-11 06:21:57 normalization > Processing destination_catalog.json...
2022-04-11 06:21:57 normalization > Traceback (most recent call last):
2022-04-11 06:21:57 normalization >   File "/usr/local/bin/transform-catalog", line 8, in <module>
2022-04-11 06:21:57 normalization >     sys.exit(main())
2022-04-11 06:21:57 normalization >   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/transform.py", line 82, in main
2022-04-11 06:21:57 normalization >     TransformCatalog().run(args)
2022-04-11 06:21:57 normalization >   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/transform.py", line 35, in run
2022-04-11 06:21:57 normalization >     self.process_catalog()
2022-04-11 06:21:57 normalization >   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/transform.py", line 62, in process_catalog
2022-04-11 06:21:57 normalization >     processor.process(catalog_file=catalog_file, json_column_name=json_col, default_schema=schema)
2022-04-11 06:21:57 normalization >   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/catalog_processor.py", line 53, in process
2022-04-11 06:21:57 normalization >     stream_processors = self.build_stream_processor(
2022-04-11 06:21:57 normalization >   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/catalog_processor.py", line 134, in build_stream_processor
2022-04-11 06:21:57 normalization >     properties = get_field(get_field(stream_config, "json_schema", message), "properties", message)
2022-04-11 06:21:57 normalization >   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/catalog_processor.py", line 225, in get_field
2022-04-11 06:21:57 normalization >     raise KeyError(message)
2022-04-11 06:21:57 normalization > KeyError: "'json_schema'.'properties' are not defined for stream sports"
2022-04-11 06:21:57 normalization > 
2022-04-11 06:21:57 normalization > Showing destination_catalog.json to diagnose/debug errors (1):
2022-04-11 06:21:57 normalization > 
2022-04-11 06:21:57 normalization > {
2022-04-11 06:21:57 normalization >   "streams": [
2022-04-11 06:21:57 normalization >     {
2022-04-11 06:21:57 normalization >       "stream": {
2022-04-11 06:21:57 normalization >         "name": "sports",
2022-04-11 06:21:57 normalization >         "json_schema": {},
2022-04-11 06:21:57 normalization >         "supported_sync_modes": [
2022-04-11 06:21:57 normalization >           "full_refresh"
2022-04-11 06:21:57 normalization >         ],
2022-04-11 06:21:57 normalization >         "default_cursor_field": [],
2022-04-11 06:21:57 normalization >         "source_defined_primary_key": []
2022-04-11 06:21:57 normalization >       },
2022-04-11 06:21:57 normalization >       "sync_mode": "full_refresh",
2022-04-11 06:21:57 normalization >       "cursor_field": [],
2022-04-11 06:21:57 normalization >       "destination_sync_mode": "append",
2022-04-11 06:21:57 normalization >       "primary_key": []
2022-04-11 06:21:57 normalization >     }
2022-04-11 06:21:57 normalization >   ]
2022-04-11 06:21:57 normalization > }
2022-04-11 06:21:57 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.45-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-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.45-alpha.jar:?]
	... 3 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:159) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-11 06:21:57 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-11 06:21:57 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-04-11 06:21:57 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=2b29cda7-6e21-3f71-9cf0-1c00ef95ce43, 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.45-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:71) ~[io.airbyte-airbyte-workers-0.35.45-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.45-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:97) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.45-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.45-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.lambda$normalize$1(NormalizationActivityImpl.java:97) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:228) ~[io.airbyte-airbyte-workers-0.35.45-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.45-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-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.45-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
	... 1 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:159) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:45) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.45-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
2022-04-11 06:21:58 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed. 
errors: $.method: does not have a value in the enumeration [Standard]