Add enhanced logs

apache · May 10, 2023 · 0b89d11 · 0b89d11
1 parent caaff4d
commit 0b89d11
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java
@@ -157,7 +157,8 @@ protected void processMessage(DecodeableKafkaRecord<byte[],byte[]> message) {
                   this.cancelledSpecs.mark();
                   this.jobCatalog.remove(specUri, true);
                 } else {
-                  log.warn("Could not find job spec {} with flow execution ID {} to cancel", specUri, flowIdToCancel);
+                  log.warn("Job spec {} that has flow execution ID {} could not be cancelled, incoming request expects to cancel flow execution ID {}", specUri,
+                      spec.getConfig().getString(ConfigurationKeys.FLOW_EXECUTION_ID_KEY), flowIdToCancel);
                 }
               }
             } catch (JobSpecNotFoundException e) {