From aaa6cf9a989e88d3273cc0a9fffc1eaa8a6e6b92 Mon Sep 17 00:00:00 2001 From: wangxianghu Date: Sat, 15 Feb 2020 08:55:23 +0800 Subject: [PATCH] [MINOR] Fix some typos --- .../src/main/java/org/apache/hudi/HoodieWriteClient.java | 8 ++++---- .../hudi/utilities/deltastreamer/HoodieDeltaStreamer.java | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) 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 {