diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java index e77765a30c228..9a6e1a1bbe36b 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java +++ b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java @@ -216,7 +216,7 @@ public class CliFrontendParser { "d", "drain", false, - "Send MAX_WATERMARK before taking the savepoint and stopping the pipelne."); + "Send MAX_WATERMARK before taking the savepoint and stopping the pipeline."); public static final Option PY_OPTION = new Option(