diff --git a/src/main/java/org/opensearch/jobscheduler/sweeper/JobSweeper.java b/src/main/java/org/opensearch/jobscheduler/sweeper/JobSweeper.java
index 61b727a1..0b6b7a7e 100644
--- a/src/main/java/org/opensearch/jobscheduler/sweeper/JobSweeper.java
+++ b/src/main/java/org/opensearch/jobscheduler/sweeper/JobSweeper.java
@@ -50,7 +50,6 @@
 import org.opensearch.cluster.routing.Murmur3HashFunction;
 import org.opensearch.cluster.routing.ShardRouting;
 import org.opensearch.cluster.service.ClusterService;
-import org.opensearch.common.Strings;
 import org.opensearch.common.bytes.BytesReference;
 import org.opensearch.common.component.LifecycleListener;
 import org.opensearch.common.settings.Settings;
@@ -277,8 +276,7 @@ void sweep(ShardId shardId, String docId, BytesReference jobSource, JobDocVersio
                     }
                     return jobDocVersion;
                 } catch (Exception e) {
-                    log.warn("Unable to parse job, error message: {} , message source: {}", e.getMessage(),
-                            Strings.cleanTruncate(jobSource.utf8ToString(), 1000));
+                    log.warn("Unable to parse job {}, error message: {}", docId, e.getMessage());
                     return currentJobDocVersion;
                 }
             } else {