Repository: flink Updated Branches: refs/heads/master f3d4011f8 -> 635612886
[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/57b3ce8c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/57b3ce8c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/57b3ce8c Branch: refs/heads/master Commit: 57b3ce8ce84b5bfa47ca6afcff811842dad8e7cc Parents: f3d4011 Author: Nico Kruber <n...@data-artisans.com> Authored: Fri Mar 9 12:11:55 2018 +0100 Committer: Nico Kruber <n...@data-artisans.com> Committed: Thu Apr 12 10:40:14 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/57b3ce8c/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/57b3ce8c/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);
