[hudi] branch master updated: [MINOR] Change the log level of the dag scheduler for the test suite (#2134)

[vinoyang]

This is an automated email from the ASF dual-hosted git repository.

vinoyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 5aaaf8b  [MINOR] Change the log level of the dag scheduler for the 
test suite (#2134)
5aaaf8b is described below

commit 5aaaf8bff17fcff595aa3927b45f4928e0d400e8
Author: vinoyang <yanghua1...@gmail.com>
AuthorDate: Wed Sep 30 17:17:44 2020 +0800

    [MINOR] Change the log level of the dag scheduler for the test suite (#2134)
---
 .../org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 2e9d437..22b9ff4 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());