[hotfix][typo] fix some typos
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e61c8b1f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e61c8b1f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e61c8b1f Branch: refs/heads/release-1.5 Commit: e61c8b1f5c4ab04061a08804427d2154811b8d3f Parents: 833b83b Author: Nico Kruber <n...@data-artisans.com> Authored: Fri Mar 9 12:11:55 2018 +0100 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Fri Apr 13 12:17:57 2018 -0700 ---------------------------------------------------------------------- .../org/apache/flink/client/program/ContextEnvironmentFactory.java | 2 +- .../java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/e61c8b1f/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironmentFactory.java ---------------------------------------------------------------------- diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironmentFactory.java b/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironmentFactory.java index 64b1863..8c1d9eb 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironmentFactory.java +++ b/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironmentFactory.java @@ -64,7 +64,7 @@ public class ContextEnvironmentFactory implements ExecutionEnvironmentFactory { @Override public ExecutionEnvironment createExecutionEnvironment() { if (isDetached && lastEnvCreated != null) { - throw new InvalidProgramException("Multiple enviornments cannot be created in detached mode"); + throw new InvalidProgramException("Multiple environments cannot be created in detached mode"); } lastEnvCreated = isDetached http://git-wip-us.apache.org/repos/asf/flink/blob/e61c8b1f/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java ---------------------------------------------------------------------- diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java b/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java index ef266f0..9d504d3 100644 --- a/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java +++ b/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java @@ -1070,7 +1070,7 @@ public abstract class AbstractYarnClusterDescriptor implements ClusterDescriptor LOG.info("The Flink YARN client has been started in detached mode. In order to stop " + "Flink on YARN, use the following command or a YARN web interface to stop " + "it:\nyarn application -kill " + appId + "\nPlease also note that the " + - "temporary files of the YARN session in the home directoy will not be removed."); + "temporary files of the YARN session in the home directory will not be removed."); } // since deployment was successful, remove the hook ShutdownHookUtil.removeShutdownHook(deploymentFailureHook, getClass().getSimpleName(), LOG);
