lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Minor fixes to exception log and removing unwanted metrics flush in integ test (#5646)

Browse Source
This commit is contained in:
Sivabalan Narayanan
2022-05-20 19:27:35 -04:00
committed by GitHub
parent 85b146d3d5
commit 7d02b1fd3c
2 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -117,9 +117,6 @@ public class DagScheduler {
if (curRound < workflowDag.getRounds()) { if (curRound < workflowDag.getRounds()) {
new DelayNode(workflowDag.getIntermittentDelayMins()).execute(executionContext, curRound); new DelayNode(workflowDag.getIntermittentDelayMins()).execute(executionContext, curRound);
} }
// After each level, report and flush the metrics
Metrics.flush();
} while (curRound++ < workflowDag.getRounds()); } while (curRound++ < workflowDag.getRounds());
log.info("Finished workloads"); log.info("Finished workloads");
} }

2
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
View File

@@ -846,7 +846,7 @@ public class DeltaSync implements Serializable {
} }
return newWriteSchema; return newWriteSchema;
} catch (Exception e) { } catch (Exception e) {
throw new HoodieException("Failed to fetch schema from table."); throw new HoodieException("Failed to fetch schema from table ", e);
} }
} }