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 7d02b1fd3c [MINOR] Minor fixes to exception log and removing unwanted metrics flush in integ test (#5646) 7d02b1fd3c is described below commit 7d02b1fd3c74abfbd118f69a10a8c106cc900a3e Author: Sivabalan Narayanan <n.siv...@gmail.com> AuthorDate: Fri May 20 19:27:35 2022 -0400 [MINOR] Minor fixes to exception log and removing unwanted metrics flush in integ test (#5646) --- .../org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java | 3 --- .../main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java | 2 +- 2 files changed, 1 insertion(+), 4 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 0183f52c2a..ab80df0d6a 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 @@ -117,9 +117,6 @@ public class DagScheduler { if (curRound < workflowDag.getRounds()) { new DelayNode(workflowDag.getIntermittentDelayMins()).execute(executionContext, curRound); } - - // After each level, report and flush the metrics - Metrics.flush(); } while (curRound++ < workflowDag.getRounds()); log.info("Finished workloads"); } diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java index 8f44b8b7d0..a1a804b9ed 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java @@ -846,7 +846,7 @@ public class DeltaSync implements Serializable { } return newWriteSchema; } catch (Exception e) { - throw new HoodieException("Failed to fetch schema from table."); + throw new HoodieException("Failed to fetch schema from table ", e); } }