diff --git a/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/DbtJobOrchestrator.java b/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/DbtJobOrchestrator.java
index c87fd499dc63..fc426adb5ed2 100644
--- a/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/DbtJobOrchestrator.java
+++ b/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/DbtJobOrchestrator.java
@@ -59,7 +59,8 @@ public void runJob() throws Exception {
             processFactory, NormalizationRunnerFactory.create(
                 workerConfigs,
                 destinationLauncherConfig.getDockerImage(),
-                processFactory)));;
+                processFactory,
+                NormalizationRunnerFactory.NORMALIZATION_VERSION)));
 
     log.info("Running dbt worker...");
     final Path jobRoot = WorkerUtils.getJobRoot(configs.getWorkspaceRoot(), jobRunConfig.getJobId(), jobRunConfig.getAttemptId());
diff --git a/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java b/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java
index c8cb34206716..6d8251e28947 100644
--- a/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java
+++ b/airbyte-container-orchestrator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java
@@ -56,7 +56,8 @@ public void runJob() throws Exception {
         NormalizationRunnerFactory.create(
             workerConfigs,
             destinationLauncherConfig.getDockerImage(),
-            processFactory),
+            processFactory,
+            NormalizationRunnerFactory.NORMALIZATION_VERSION),
         configs.getWorkerEnvironment());
 
     log.info("Running normalization worker...");
diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/normalization/NormalizationRunnerFactory.java b/airbyte-workers/src/main/java/io/airbyte/workers/normalization/NormalizationRunnerFactory.java
index 2fee47175bd0..0e921d438a0d 100644
--- a/airbyte-workers/src/main/java/io/airbyte/workers/normalization/NormalizationRunnerFactory.java
+++ b/airbyte-workers/src/main/java/io/airbyte/workers/normalization/NormalizationRunnerFactory.java
@@ -34,8 +34,6 @@ public class NormalizationRunnerFactory {
           .put("airbyte/destination-postgres-strict-encrypt", ImmutablePair.of(BASE_NORMALIZATION_IMAGE_NAME, DestinationType.POSTGRES))
           .put("airbyte/destination-redshift", ImmutablePair.of(BASE_NORMALIZATION_IMAGE_NAME, DestinationType.REDSHIFT))
           .put("airbyte/destination-snowflake", ImmutablePair.of("airbyte/normalization-snowflake", DestinationType.SNOWFLAKE))
-          .put("airbyte/destination-clickhouse", ImmutablePair.of("airbyte/normalization-clickhouse", DestinationType.CLICKHOUSE))
-          .put("airbyte/destination-clickhouse-strict-encrypt", ImmutablePair.of("airbyte/normalization-clickhouse", DestinationType.CLICKHOUSE))
           .build();
 
   public static NormalizationRunner create(final WorkerConfigs workerConfigs,
diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/sync/DbtTransformationActivityImpl.java b/airbyte-workers/src/main/java/io/airbyte/workers/temporal/sync/DbtTransformationActivityImpl.java
index 44716c1c566f..404eaef20412 100644
--- a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/sync/DbtTransformationActivityImpl.java
+++ b/airbyte-workers/src/main/java/io/airbyte/workers/temporal/sync/DbtTransformationActivityImpl.java
@@ -111,10 +111,10 @@ private CheckedSupplier<Worker<OperatorDbtInput, Void>, Exception> getLegacyWork
         new DbtTransformationRunner(
             workerConfigs,
             jobProcessFactory, NormalizationRunnerFactory.create(
-            workerConfigs,
-            destinationLauncherConfig.getDockerImage(),
-            jobProcessFactory,
-            NormalizationRunnerFactory.NORMALIZATION_VERSION)));
+                workerConfigs,
+                destinationLauncherConfig.getDockerImage(),
+                jobProcessFactory,
+                NormalizationRunnerFactory.NORMALIZATION_VERSION)));
   }
 
   private CheckedSupplier<Worker<OperatorDbtInput, Void>, Exception> getContainerLauncherWorkerFactory(