From 7f704cdd9e40c973e06f2d0c68791daeb49e8f0b Mon Sep 17 00:00:00 2001
From: Vivek Rai <vivekrai5839@gmail.com>
Date: Thu, 30 Oct 2025 18:16:51 +0530
Subject: [PATCH 1/2] remove helix jobs mapping from temporal job scheduler

---
 .../GobblinTemporalJobScheduler.java          | 25 +------------------
 1 file changed, 1 insertion(+), 24 deletions(-)

diff --git a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java
index fe589e18d15..f726af4cc4e 100644
--- a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java
+++ b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java
@@ -79,8 +79,6 @@ public class GobblinTemporalJobScheduler extends JobScheduler implements Standar
   private final MetricContext metricContext;
   final GobblinTemporalJobSchedulerMetrics jobSchedulerMetrics;
   final GobblinTemporalJobLauncherMetrics launcherMetrics;
-  final GobblinTemporalPlanningJobLauncherMetrics planningJobLauncherMetrics;
-  final HelixJobsMapping jobsMapping;
   private boolean startServicesCompleted;
 
   public GobblinTemporalJobScheduler(Config sysConfig,
@@ -108,22 +106,13 @@ public GobblinTemporalJobScheduler(Config sysConfig,
             this.metricContext,
             metricsWindowSizeInMin);
 
-    this.jobsMapping = new HelixJobsMapping(ConfigUtils.propertiesToConfig(properties),
-            PathUtils.getRootPath(appWorkDir).toUri(),
-            appWorkDir.toString());
-
-    this.planningJobLauncherMetrics = new GobblinTemporalPlanningJobLauncherMetrics("planningLauncherInScheduler",
-            this.metricContext,
-            metricsWindowSizeInMin, this.jobsMapping);
-
     this.startServicesCompleted = false;
   }
 
   @Override
   public Collection<StandardMetrics> getStandardMetricsCollection() {
     return ImmutableList.of(this.launcherMetrics,
-            this.jobSchedulerMetrics,
-            this.planningJobLauncherMetrics);
+            this.jobSchedulerMetrics);
   }
 
   @Override
@@ -153,18 +142,6 @@ public void scheduleJob(Properties jobProps, JobListener jobListener) throws Job
 
   @Override
   protected void startServices() throws Exception {
-
-    boolean cleanAllDistJobs = PropertiesUtils.getPropAsBoolean(this.properties,
-            GobblinClusterConfigurationKeys.CLEAN_ALL_DIST_JOBS,
-            String.valueOf(GobblinClusterConfigurationKeys.DEFAULT_CLEAN_ALL_DIST_JOBS));
-
-    if (cleanAllDistJobs) {
-      for (org.apache.gobblin.configuration.State state : this.jobsMapping.getAllStates()) {
-        String jobUri = state.getId();
-        LOGGER.info("Delete mapping for job " + jobUri);
-        this.jobsMapping.deleteMapping(jobUri);
-      }
-    }
   }
 
   @Override

From 8411ec36d04ae084059ab12092d90f0702e376ce Mon Sep 17 00:00:00 2001
From: Vivek Rai <vivekrai5839@gmail.com>
Date: Thu, 30 Oct 2025 22:23:43 +0530
Subject: [PATCH 2/2] remove unused imports

---
 .../temporal/joblauncher/GobblinTemporalJobScheduler.java      | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java
index f726af4cc4e..8ed3999d0ce 100644
--- a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java
+++ b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java
@@ -35,7 +35,6 @@
 import org.apache.gobblin.annotation.Alpha;
 import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys;
 import org.apache.gobblin.cluster.GobblinHelixJob;
-import org.apache.gobblin.cluster.HelixJobsMapping;
 import org.apache.gobblin.cluster.event.CancelJobConfigArrivalEvent;
 import org.apache.gobblin.cluster.event.DeleteJobConfigArrivalEvent;
 import org.apache.gobblin.cluster.event.NewJobConfigArrivalEvent;
@@ -52,8 +51,6 @@
 import org.apache.gobblin.scheduler.SchedulerService;
 import org.apache.gobblin.temporal.GobblinTemporalConfigurationKeys;
 import org.apache.gobblin.util.ConfigUtils;
-import org.apache.gobblin.util.PathUtils;
-import org.apache.gobblin.util.PropertiesUtils;
 import org.apache.gobblin.util.reflection.GobblinConstructorUtils;