From f20a130e3ac3cf5434bf58cc6b0b64cd4d9a6931 Mon Sep 17 00:00:00 2001 From: yungthuis66 <59256868+yungthuis66@users.noreply.github.com> Date: Fri, 27 Dec 2019 01:03:43 +0800 Subject: [PATCH] [MINOR] typo fix (#1142) --- .../hudi/utilities/deltastreamer/HoodieDeltaStreamer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 d4f3ec42e..a8eab1da0 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 @@ -74,7 +74,7 @@ import java.util.stream.IntStream; * * In continuous mode, DeltaStreamer runs in loop-mode going through the below operations (a) pull-from-source (b) * write-to-sink (c) Schedule Compactions if needed (d) Conditionally Sync to Hive each cycle. For MOR table with - * continuous mode enabled, a seperate compactor thread is allocated to execute compactions + * continuous mode enabled, a separate compactor thread is allocated to execute compactions */ public class HoodieDeltaStreamer implements Serializable {