You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by vi...@apache.org on 2022/05/20 23:27:42 UTC
[hudi] branch master updated: [MINOR] Minor fixes to exception log and removing unwanted metrics flush in integ test (#5646)
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....@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);
}
}