lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Change the log level of the dag scheduler for the test suite (#2134)

Browse Source
This commit is contained in:
vinoyang
2020-09-30 17:17:44 +08:00
committed by GitHub
parent a99e93bed5
commit 5aaaf8bff1
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java
View File

@@ -79,7 +79,7 @@ public class DagScheduler {
private void execute(ExecutorService service, List<DagNode> nodes) throws Exception { private void execute(ExecutorService service, List<DagNode> nodes) throws Exception {
// Nodes at the same level are executed in parallel // Nodes at the same level are executed in parallel
Queue<DagNode> queue = new PriorityQueue<>(nodes); Queue<DagNode> queue = new PriorityQueue<>(nodes);
log.warn("Running workloads"); log.info("Running workloads");
do { do {
List<Future> futures = new ArrayList<>(); List<Future> futures = new ArrayList<>();
Set<DagNode> childNodes = new HashSet<>(); Set<DagNode> childNodes = new HashSet<>();
@@ -109,7 +109,7 @@ public class DagScheduler {
throw new RuntimeException("DagNode already completed! Cannot re-execute"); throw new RuntimeException("DagNode already completed! Cannot re-execute");
} }
try { 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.execute(executionContext);
node.setCompleted(true); node.setCompleted(true);
log.info("Finished executing {}", node.getName()); log.info("Finished executing {}", node.getName());