You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/04/13 19:18:26 UTC
[4/4] flink git commit: [hotfix][typo] fix some typos
[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 <ni...@data-artisans.com>
Authored: Fri Mar 9 12:11:55 2018 +0100
Committer: Till Rohrmann <tr...@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);