This is an automated email from the ASF dual-hosted git repository. forwardxu pushed a commit to branch release-0.12.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 6dbe53e6232de8b85c7548fefda670d6f4359ec1 Author: XuQianJin-Stars <forwar...@apache.com> AuthorDate: Sun Jun 5 15:06:30 2022 +0800 fix zhiyan reporter for metadata --- .../main/java/org/apache/hudi/config/HoodieWriteConfig.java | 8 ++++++++ .../apache/hudi/metadata/HoodieBackedTableMetadataWriter.java | 11 +++++++++++ 2 files changed, 19 insertions(+) diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java index 23bc0ee329..9610ad382b 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java @@ -2234,6 +2234,8 @@ public class HoodieWriteConfig extends HoodieConfig { private boolean isPreCommitValidationConfigSet = false; private boolean isMetricsJmxConfigSet = false; private boolean isMetricsGraphiteConfigSet = false; + + private boolean isMetricsZhiyanConfig = false; private boolean isLayoutConfigSet = false; private boolean isTdbankConfigSet = false; @@ -2429,6 +2431,12 @@ public class HoodieWriteConfig extends HoodieConfig { return this; } + public Builder withMetricsZhiyanConfig(HoodieMetricsZhiyanConfig metricsZhiyanConfig) { + writeConfig.getProps().putAll(metricsZhiyanConfig.getProps()); + isMetricsZhiyanConfig = true; + return this; + } + public Builder withPreCommitValidatorConfig(HoodiePreCommitValidatorConfig validatorConfig) { writeConfig.getProps().putAll(validatorConfig.getProps()); isPreCommitValidationConfigSet = true; diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java index 962875fb92..405db43a51 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java @@ -65,6 +65,7 @@ import org.apache.hudi.config.HoodieWriteConfig; import org.apache.hudi.config.metrics.HoodieMetricsConfig; import org.apache.hudi.config.metrics.HoodieMetricsGraphiteConfig; import org.apache.hudi.config.metrics.HoodieMetricsJmxConfig; +import org.apache.hudi.config.metrics.HoodieMetricsZhiyanConfig; import org.apache.hudi.exception.HoodieException; import org.apache.hudi.exception.HoodieIndexException; import org.apache.hudi.exception.HoodieMetadataException; @@ -316,6 +317,16 @@ public abstract class HoodieBackedTableMetadataWriter implements HoodieTableMeta .toJmxHost(writeConfig.getJmxHost()) .build()); break; + case ZHIYAN: + builder.withMetricsZhiyanConfig(HoodieMetricsZhiyanConfig.newBuilder() + .withReportServiceUrl(writeConfig.getZhiyanReportServiceURL()) + .withApiTimeout(writeConfig.getZhiyanApiTimeoutSeconds()) + .withAppMask(writeConfig.getZhiyanAppMask()) + .withReportPeriodSeconds(writeConfig.getZhiyanReportPeriodSeconds()) + .withSeclvlEnvName(writeConfig.getZhiyanSeclvlEnvName()) + .withJobName(writeConfig.getZhiyanHoodieJobName()) + .build()); + break; case DATADOG: case PROMETHEUS: case PROMETHEUS_PUSHGATEWAY: