diff --git a/kubernetes/helm_charts/datapipeline_jobs/values.j2 b/kubernetes/helm_charts/datapipeline_jobs/values.j2
index 462e95f0fa433bcce6db04f680bdb6b1d7ef6182..5dfae09836eb938e2e70d0152077ac43f72581a7 100644
--- a/kubernetes/helm_charts/datapipeline_jobs/values.j2
+++ b/kubernetes/helm_charts/datapipeline_jobs/values.j2
@@ -834,9 +834,9 @@ dialcode-context-updater:
     es_sync_wait_time = 20000
 
   flink-conf: |+
-    jobmanager.memory.flink.size: {{ flink_job_names['qrcode-image-generator'].jobmanager_memory }}
-    taskmanager.memory.flink.size: {{ flink_job_names['qrcode-image-generator'].taskmanager_memory }}
-    taskmanager.numberOfTaskSlots: {{ flink_job_names['qrcode-image-generator'].taskslots }}
+    jobmanager.memory.flink.size: {{ flink_job_names['dialcode-context-updater'].jobmanager_memory }}
+    taskmanager.memory.flink.size: {{ flink_job_names['dialcode-context-updater'].taskmanager_memory }}
+    taskmanager.numberOfTaskSlots: {{ flink_job_names['dialcode-context-updater'].taskslots }}
     parallelism.default: 1
     jobmanager.execution.failover-strategy: region
     taskmanager.memory.network.fraction: 0.1
@@ -1014,9 +1014,9 @@ live-node-publisher:
     }
 
   flink-conf: |+
-    jobmanager.memory.flink.size: {{ flink_job_names['content-publish'].jobmanager_memory }}
-    taskmanager.memory.flink.size: {{ flink_job_names['content-publish'].taskmanager_memory }}
-    taskmanager.numberOfTaskSlots: {{ flink_job_names['content-publish'].taskslots }}
+    jobmanager.memory.flink.size: {{ flink_job_names['live-node-publisher'].jobmanager_memory }}
+    taskmanager.memory.flink.size: {{ flink_job_names['live-node-publisher'].taskmanager_memory }}
+    taskmanager.numberOfTaskSlots: {{ flink_job_names['live-node-publisher'].taskslots }}
     parallelism.default: 1
     jobmanager.execution.failover-strategy: region
     taskmanager.memory.network.fraction: 0.1
@@ -1091,9 +1091,9 @@ live-video-stream-generator:
 
 
   flink-conf: |+
-    jobmanager.memory.flink.size: {{ flink_job_names['video-stream-generator'].jobmanager_memory }}
-    taskmanager.memory.flink.size: {{ flink_job_names['video-stream-generator'].taskmanager_memory }}
-    taskmanager.numberOfTaskSlots: {{ flink_job_names['video-stream-generator'].taskslots }}
+    jobmanager.memory.flink.size: {{ flink_job_names['live-video-stream-generator'].jobmanager_memory }}
+    taskmanager.memory.flink.size: {{ flink_job_names['live-video-stream-generator'].taskmanager_memory }}
+    taskmanager.numberOfTaskSlots: {{ flink_job_names['live-video-stream-generator'].taskslots }}
     parallelism.default: 1
     jobmanager.execution.failover-strategy: region
     taskmanager.memory.network.fraction: 0.1
@@ -1192,9 +1192,9 @@ csp-migrator:
     cloud_storage_container="{{ cloud_storage_content_bucketname }}"
 
   flink-conf: |+
-    jobmanager.memory.flink.size: {{ flink_job_names['video-stream-generator'].jobmanager_memory }}
-    taskmanager.memory.flink.size: {{ flink_job_names['video-stream-generator'].taskmanager_memory }}
-    taskmanager.numberOfTaskSlots: {{ flink_job_names['video-stream-generator'].taskslots }}
+    jobmanager.memory.flink.size: {{ flink_job_names['csp-migrator'].jobmanager_memory }}
+    taskmanager.memory.flink.size: {{ flink_job_names['csp-migrator'].taskmanager_memory }}
+    taskmanager.numberOfTaskSlots: {{ flink_job_names['csp-migrator'].taskslots }}
     parallelism.default: 1
     jobmanager.execution.failover-strategy: region
     taskmanager.memory.network.fraction: 0.1
diff --git a/platform-modules/actors/src/main/java/org/sunbird/learning/util/ControllerUtil.java b/platform-modules/actors/src/main/java/org/sunbird/learning/util/ControllerUtil.java
index 30c88f2e0dbccde6ad13460ca443d4857777c5cb..b0b77942ff8d0455ffa5673cd08e6183c8d143fc 100644
--- a/platform-modules/actors/src/main/java/org/sunbird/learning/util/ControllerUtil.java
+++ b/platform-modules/actors/src/main/java/org/sunbird/learning/util/ControllerUtil.java
@@ -426,12 +426,10 @@ public class ControllerUtil extends BaseLearningManager {
         sc.setStartPosition(startPosition);
        if(!filters.isEmpty() && filters.size()>0)
             sc.addMetadata(MetadataCriterion.create(filters));
-        System.out.println("ControllerUtil:: getNodes:: sc:: " + sc);
         Request req = getRequest(graphId, GraphEngineManagers.SEARCH_MANAGER, "searchNodes",
                 GraphDACParams.search_criteria.name(), sc);
         req.put(GraphDACParams.get_tags.name(), true);
         Response listRes = getResponse(req);
-        System.out.println("ControllerUtil:: getNodes:: listRes.params:: " + listRes.getParams());
         if (checkError(listRes))
             return null;
         else {