2022-05-05 21:23:55 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.3-alpha
2022-05-05 21:23:55 INFO i.a.w.t.TemporalAttemptExecution(get):118 - Docker volume job log path: /tmp/workspace/17829/1/logs.log
2022-05-05 21:23:55 INFO i.a.w.t.TemporalAttemptExecution(get):123 - Executing worker wrapper. Airbyte version: version not set
2022-05-05 21:23:55 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-05-05 21:23:55 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-05-05 21:23:55 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-05-05 21:23:55 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-05-05 21:23:55 INFO i.a.w.DefaultReplicationWorker(run):99 - start sync worker. job id: 17829 attempt id: 1
2022-05-05 21:23:55 INFO i.a.w.DefaultReplicationWorker(run):108 - configured sync modes: {analytics_271550005.last_day_data=incremental - append}
2022-05-05 21:23:55 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-05-05 21:23:55 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-clickhouse:0.1.5 exists...
2022-05-05 21:23:55 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-clickhouse:0.1.5 was found locally.
2022-05-05 21:23:55 INFO i.a.w.p.DockerProcessFactory(create):171 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/17829/1 --network host --log-driver none airbyte/destination-clickhouse:0.1.5 write --config destination_config.json --catalog destination_catalog.json
2022-05-05 21:23:55 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-bigquery:0.1.7 exists...
2022-05-05 21:23:55 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-bigquery:0.1.7 was found locally.
2022-05-05 21:23:55 INFO i.a.w.p.DockerProcessFactory(create):171 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/17829/1 --network host --log-driver none airbyte/source-bigquery:0.1.7 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-05-05 21:23:55 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):242 - Destination output thread started.
2022-05-05 21:23:55 INFO i.a.w.DefaultReplicationWorker(run):130 - Waiting for source and destination threads to complete.
2022-05-05 21:23:55 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Replication thread started.
2022-05-05 21:23:56 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-05-05 21:23:56 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-05 21:23:56 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-05-05 21:23:56 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-05-05 21:23:56 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-05-05 21:23:56 destination > 2022-05-05 21:23:56 INFO i.a.i.d.c.ClickhouseDestination(main):96 - starting destination: class io.airbyte.integrations.destination.clickhouse.ClickhouseDestination
2022-05-05 21:23:56 source > 2022-05-05 21:23:56 INFO i.a.i.s.b.BigQuerySource(main):174 - starting source: class io.airbyte.integrations.source.bigquery.BigQuerySource
2022-05-05 21:23:56 destination > 2022-05-05 21:23:56 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-05-05 21:23:56 destination > 2022-05-05 21:23:56 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-05-05 21:23:56 destination > 2022-05-05 21:23:56 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-05-05 21:23:56 destination > 2022-05-05 21:23:56 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-05 21:23:56 source > 2022-05-05 21:23:56 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-05-05 21:23:56 source > 2022-05-05 21:23:56 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.source.bigquery.BigQuerySource
2022-05-05 21:23:56 source > 2022-05-05 21:23:56 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: READ
2022-05-05 21:23:56 source > 2022-05-05 21:23:56 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-05-05 21:23:57 destination > 2022-05-05 21:23:57 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-05 21:23:57 destination > 2022-05-05 21:23:57 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-05 21:23:57 destination > 2022-05-05 21:23:57 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-05 21:23:57 destination > 2022-05-05 21:23:57 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-05 21:23:57 source > 2022-05-05 21:23:57 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-05 21:23:57 source > 2022-05-05 21:23:57 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-05-05 21:23:57 source > 2022-05-05 21:23:57 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):108 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='last_day_data', namespace='analytics_271550005'}. Cursor Field: event_timestamp Value: 1651697999206391
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 INFO r.y.c.ClickHouseDriver(<clinit>):49 - Driver registered
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):97 - Write config: WriteConfig{streamName=last_day_data, namespace=new_last_day_click_with_normalization, outputSchemaName=new_last_day_click_with_normalization, tmpTableName=_airbyte_tmp_ytr_last_day_data, outputTableName=_airbyte_raw_last_day_data, syncMode=append}
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):116 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):122 - Preparing tmp tables in destination started for 1 streams
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):126 - Preparing tmp table in destination started for stream last_day_data. schema: new_last_day_click_with_normalization, tmp table name: _airbyte_tmp_ytr_last_day_data
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 WARN r.y.c.ClickhouseJdbcUrlParser(parseUriQueryPart):84 - don't know how to handle parameter pair: 
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 WARN r.y.c.ClickhouseJdbcUrlParser(parseUriQueryPart):84 - don't know how to handle parameter pair: 
2022-05-05 21:23:57 destination > 2022-05-05 21:23:57 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):132 - Preparing tables in destination completed.
2022-05-05 21:24:05 source > 2022-05-05 21:24:05 INFO i.a.d.b.BigQuerySourceOperations(getQueryParameter):146 - Query parameter for set : 1651697999206391. Type: INT64
2022-05-05 21:24:06 source > 2022-05-05 21:24:06 INFO i.a.i.s.r.StateDecoratingIterator(computeNext):60 - State Report: stream name: AirbyteStreamNameNamespacePair{name='last_day_data', namespace='analytics_271550005'}, original cursor field: event_timestamp, original cursor 1651697999206391, cursor field: event_timestamp, new cursor: 1651697999206391
2022-05-05 21:24:06 source > 2022-05-05 21:24:06 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):124 - Closing database connection pool.
2022-05-05 21:24:06 source > 2022-05-05 21:24:06 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):126 - Closed database connection pool.
2022-05-05 21:24:06 source > 2022-05-05 21:24:06 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.source.bigquery.BigQuerySource
2022-05-05 21:24:06 source > 2022-05-05 21:24:06 INFO i.a.i.s.b.BigQuerySource(main):176 - completed source: class io.airbyte.integrations.source.bigquery.BigQuerySource
2022-05-05 21:24:06 INFO i.a.w.DefaultReplicationWorker(run):135 - One of source or destination thread complete. Waiting on the other.
2022-05-05 21:24:06 destination > 2022-05-05 21:24:06 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-05-05 21:24:06 destination > 2022-05-05 21:24:06 INFO i.a.i.d.b.BufferedStreamConsumer(close):170 - executing on success close procedure.
2022-05-05 21:24:06 destination > 2022-05-05 21:24:06 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):161 - Finalizing tables in destination started for 1 streams
2022-05-05 21:24:06 destination > 2022-05-05 21:24:06 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):166 - Finalizing stream last_day_data. schema new_last_day_click_with_normalization, tmp table _airbyte_tmp_ytr_last_day_data, final table _airbyte_raw_last_day_data
2022-05-05 21:24:07 destination > 2022-05-05 21:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):179 - Executing finalization of tables.
2022-05-05 21:24:07 destination > 2022-05-05 21:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):181 - Finalizing tables in destination completed.
2022-05-05 21:24:07 destination > 2022-05-05 21:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):184 - Cleaning tmp tables in destination started for 1 streams
2022-05-05 21:24:07 destination > 2022-05-05 21:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):188 - Cleaning tmp table in destination started for stream last_day_data. schema new_last_day_click_with_normalization, tmp table name: _airbyte_tmp_ytr_last_day_data
2022-05-05 21:24:07 destination > 2022-05-05 21:24:07 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):193 - Cleaning tmp tables in destination completed.
2022-05-05 21:24:07 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):247 - state in DefaultReplicationWorker from Destination: io.airbyte.protocol.models.AirbyteMessage@352fca39[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@3be832ec[data={"cdc":false,"streams":[{"stream_name":"last_day_data","stream_namespace":"analytics_271550005","cursor_field":["event_timestamp"],"cursor":"1651697999206391"}]},additionalProperties={}],additionalProperties={}]
2022-05-05 21:24:07 destination > 2022-05-05 21:24:07 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-05-05 21:24:07 destination > 2022-05-05 21:24:07 INFO i.a.i.d.c.ClickhouseDestination(main):98 - completed destination: class io.airbyte.integrations.destination.clickhouse.ClickhouseDestination
2022-05-05 21:24:07 INFO i.a.w.DefaultReplicationWorker(run):137 - Source and destination threads complete.
2022-05-05 21:24:07 INFO i.a.w.DefaultReplicationWorker(run):165 - sync summary: io.airbyte.config.ReplicationAttemptSummary@77133637[status=completed,recordsSynced=0,bytesSynced=0,startTime=1651785835659,endTime=1651785847323]
2022-05-05 21:24:07 INFO i.a.w.DefaultReplicationWorker(run):172 - Source output at least one state message
2022-05-05 21:24:07 INFO i.a.w.DefaultReplicationWorker(run):178 - State capture: Updated state to: Optional[io.airbyte.config.State@3a16f4b3[state={"cdc":false,"streams":[{"stream_name":"last_day_data","stream_namespace":"analytics_271550005","cursor_field":["event_timestamp"],"cursor":"1651697999206391"}]}]]
2022-05-05 21:24:07 INFO i.a.w.t.TemporalAttemptExecution(get):144 - Stopping cancellation check scheduling...
2022-05-05 21:24:07 INFO i.a.w.t.s.ReplicationActivityImpl(replicate):144 - sync summary: io.airbyte.config.StandardSyncOutput@203b2cb6[standardSyncSummary=io.airbyte.config.StandardSyncSummary@2ccec842[status=completed,recordsSynced=0,bytesSynced=0,startTime=1651785835659,endTime=1651785847323],state=io.airbyte.config.State@3a16f4b3[state={"cdc":false,"streams":[{"stream_name":"last_day_data","stream_namespace":"analytics_271550005","cursor_field":["event_timestamp"],"cursor":"1651697999206391"}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@2e531a24[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@5dd2b9a4[stream=io.airbyte.protocol.models.AirbyteStream@24757034[name=last_day_data,jsonSchema={"type":"object","properties":{"geo":{"type":"object"},"items":{"type":"object"},"device":{"type":"object"},"user_id":{"type":"string"},"app_info":{"type":"object"},"platform":{"type":"string"},"user_ltv":{"type":"object"},"ecommerce":{"type":"object"},"stream_id":{"type":"string"},"event_date":{"type":"string"},"event_name":{"type":"string"},"event_params":{"type":"object"},"privacy_info":{"type":"object"},"traffic_source":{"type":"object"},"user_pseudo_id":{"type":"string"},"event_timestamp":{"type":"number"},"user_properties":{"type":"object"},"event_dimensions":{"type":"object"},"event_value_in_usd":{"type":"number"},"event_bundle_sequence_id":{"type":"number"},"event_previous_timestamp":{"type":"number"},"user_first_touch_timestamp":{"type":"number"},"event_server_timestamp_offset":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=new_last_day_click_with_normalization,additionalProperties={}],syncMode=incremental,cursorField=[event_timestamp],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}]]
2022-05-05 21:24:07 INFO i.a.c.p.ConfigRepository(updateConnectionState):545 - Updating connection ab8863f5-47c6-4d17-8c16-d97dc93746c9 state: io.airbyte.config.State@c008d5[state={"cdc":false,"streams":[{"stream_name":"last_day_data","stream_namespace":"analytics_271550005","cursor_field":["event_timestamp"],"cursor":"1651697999206391"}]}]
2022-05-05 21:24:07 INFO i.a.w.t.TemporalAttemptExecution(get):118 - Docker volume job log path: /tmp/workspace/17829/1/logs.log
2022-05-05 21:24:07 INFO i.a.w.t.TemporalAttemptExecution(get):123 - Executing worker wrapper. Airbyte version: version not set
2022-05-05 21:24:07 WARN i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):65 - Waiting for database to become available...
2022-05-05 21:24:07 INFO i.a.d.i.j.JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2022-05-05 21:24:07 INFO i.a.d.Databases(createPostgresDatabaseWithRetryTimeout):90 - Database available!
2022-05-05 21:24:07 INFO i.a.d.Databases(createPostgresDatabaseWithRetry):48 - Database available!
2022-05-05 21:24:07 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-05-05 21:24:07 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-clickhouse:0.1.61
2022-05-05 21:24:07 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization-clickhouse:0.1.61 exists...
2022-05-05 21:24:07 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization-clickhouse:0.1.61 not found locally. Attempting to pull the image...
2022-05-05 21:24:09 INFO i.a.c.i.LineGobbler(voidCall):82 - Image does not exist.
2022-05-05 21:24:09 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):177 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.WorkerException: Could not find image: airbyte/normalization-clickhouse:0.1.61
	at io.airbyte.workers.process.DockerProcessFactory.create(DockerProcessFactory.java:97) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:55) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	... 3 more
2022-05-05 21:24:09 INFO i.a.w.t.TemporalAttemptExecution(get):144 - Stopping cancellation check scheduling...
2022-05-05 21:24:09 WARN i.t.i.s.POJOActivityTaskHandler(activityFailureToResult):363 - Activity failure. ActivityId=79ef6b39-30cc-3376-a58b-b46eb6c62d22, activityType=Normalize, attempt=1
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:142) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:98) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at jdk.internal.reflect.GeneratedMethodAccessor164.invoke(Unknown Source) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:286) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:252) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:209) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:193) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:151) ~[temporal-sdk-1.6.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:73) ~[temporal-sdk-1.6.0.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.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.WorkerException: Could not find image: airbyte/normalization-clickhouse:0.1.61
	at io.airbyte.workers.process.DockerProcessFactory.create(DockerProcessFactory.java:97) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.runProcess(DefaultNormalizationRunner.java:123) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.normalization.DefaultNormalizationRunner.normalize(DefaultNormalizationRunner.java:108) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:55) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:18) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:174) ~[io.airbyte-airbyte-workers-0.35.3-alpha.jar:?]
	... 1 more