diff --git a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java
index 2e9d43736..22b9ff49e 100644
--- a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java
+++ b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java
@@ -79,7 +79,7 @@ public class DagScheduler {
   private void execute(ExecutorService service, List<DagNode> nodes) throws Exception {
     // Nodes at the same level are executed in parallel
     Queue<DagNode> queue = new PriorityQueue<>(nodes);
-    log.warn("Running workloads");
+    log.info("Running workloads");
     do {
       List<Future> futures = new ArrayList<>();
       Set<DagNode> childNodes = new HashSet<>();
@@ -109,7 +109,7 @@ public class DagScheduler {
       throw new RuntimeException("DagNode already completed! Cannot re-execute");
     }
     try {
-      log.warn("executing node: " + node.getName() + " of type: " + node.getClass());
+      log.info("executing node: " + node.getName() + " of type: " + node.getClass());
       node.execute(executionContext);
       node.setCompleted(true);
       log.info("Finished executing {}", node.getName());