diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java index efe3a86f4c27f..8f434a007a0b2 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java @@ -69,7 +69,7 @@ public static Pair calculateBeginAndEndInstants(JavaSparkContext return lastInstant.map(hoodieInstant -> getStrictlyLowerTimestamp(hoodieInstant.getTimestamp())).orElse("000"); } else { throw new IllegalArgumentException("Missing begin instant for incremental pull. For reading from latest " - + "committed instant set hoodie.deltastreamer.source.hoodie.read_latest_on_midding_ckpt to true"); + + "committed instant set hoodie.deltastreamer.source.hoodieincr.read_latest_on_missing_ckpt to true"); } });