diff --git a/hudi-client/src/main/java/org/apache/hudi/HoodieWriteClient.java b/hudi-client/src/main/java/org/apache/hudi/HoodieWriteClient.java index 7e91df155..23055da6b 100644 --- a/hudi-client/src/main/java/org/apache/hudi/HoodieWriteClient.java +++ b/hudi-client/src/main/java/org/apache/hudi/HoodieWriteClient.java @@ -101,7 +101,7 @@ public class HoodieWriteClient extends AbstractHo /** - * Create a wirte client, without cleaning up failed/inflight commits. + * Create a write client, without cleaning up failed/inflight commits. * * @param jsc Java Spark Context * @param clientConfig instance of HoodieWriteConfig @@ -111,7 +111,7 @@ public class HoodieWriteClient extends AbstractHo } /** - * Create a wirte client, with new hudi index. + * Create a write client, with new hudi index. * * @param jsc Java Spark Context * @param clientConfig instance of HoodieWriteConfig @@ -127,7 +127,7 @@ public class HoodieWriteClient extends AbstractHo } /** - * Create a wirte client, allows to specify all parameters. + * Create a write client, allows to specify all parameters. * * @param jsc Java Spark Context * @param clientConfig instance of HoodieWriteConfig @@ -1054,7 +1054,7 @@ public class HoodieWriteClient extends AbstractHo /** * Perform compaction operations as specified in the compaction commit file. * - * @param compactionInstant Compacton Instant time + * @param compactionInstant Compaction Instant time * @param activeTimeline Active Timeline * @param autoCommit Commit after compaction * @return RDD of Write Status diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java index 9c05f315c..820875c34 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java @@ -485,7 +485,7 @@ public class HoodieDeltaStreamer implements Serializable { } /** - * Async Compactor Service tha runs in separate thread. Currently, only one compactor is allowed to run at any time. + * Async Compactor Service that runs in separate thread. Currently, only one compactor is allowed to run at any time. */ public static class AsyncCompactService extends AbstractDeltaStreamerService {