diff --git a/hudi-client/src/main/java/org/apache/hudi/metrics/Metrics.java b/hudi-client/src/main/java/org/apache/hudi/metrics/Metrics.java index 2b524a74c..a9cf14e69 100644 --- a/hudi-client/src/main/java/org/apache/hudi/metrics/Metrics.java +++ b/hudi-client/src/main/java/org/apache/hudi/metrics/Metrics.java @@ -97,8 +97,7 @@ public class Metrics { guage.setValue(value); } catch (Exception e) { // Here we catch all exception, so the major upsert pipeline will not be affected if the - // metrics system - // has some issues. + // metrics system has some issues. LOG.error("Failed to send metrics: ", e); } } diff --git a/hudi-examples/src/main/java/org/apache/hudi/examples/common/ExampleDataSchemaProvider.java b/hudi-examples/src/main/java/org/apache/hudi/examples/common/ExampleDataSchemaProvider.java index 3a07cc597..4486a4286 100644 --- a/hudi-examples/src/main/java/org/apache/hudi/examples/common/ExampleDataSchemaProvider.java +++ b/hudi-examples/src/main/java/org/apache/hudi/examples/common/ExampleDataSchemaProvider.java @@ -35,6 +35,6 @@ public class ExampleDataSchemaProvider extends SchemaProvider { @Override public Schema getSourceSchema() { - return org.apache.hudi.examples.common.HoodieExampleDataGenerator.avroSchema; + return HoodieExampleDataGenerator.avroSchema; } } diff --git a/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java b/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java index 6f96fe966..655e549d9 100644 --- a/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java +++ b/hudi-examples/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java @@ -51,8 +51,10 @@ import java.util.stream.Collectors; * Simple examples of #{@link HoodieWriteClient}. * * To run this example, you should - * 1. For running in IDE, set VM options `-Dspark.master=local[2]` - * 2. For running in shell, using `spark-submit` + *
+ * 1. For running in IDE, set VM options `-Dspark.master=local[2]`; + * 2. For running in shell, using `spark-submit`. + ** * Usage: HoodieWriteClientExample