You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/05/17 06:08:52 UTC
[06/13] flink git commit: [FLINK-9283][docs] Update port in cluster
execution docs
[FLINK-9283][docs] Update port in cluster execution docs
This closes #6022.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29c34612
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/29c34612
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/29c34612
Branch: refs/heads/release-1.5
Commit: 29c34612ad889d4fcfad6273c6d745bbbfb4bf7f
Parents: 3bc2ca3
Author: hzyuqi1 <hz...@corp.netease.com>
Authored: Wed May 16 16:06:33 2018 +0800
Committer: zentol <ch...@apache.org>
Committed: Wed May 16 20:22:32 2018 +0200
----------------------------------------------------------------------
docs/dev/cluster_execution.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/29c34612/docs/dev/cluster_execution.md
----------------------------------------------------------------------
diff --git a/docs/dev/cluster_execution.md b/docs/dev/cluster_execution.md
index 7ea8c22..2b29054 100644
--- a/docs/dev/cluster_execution.md
+++ b/docs/dev/cluster_execution.md
@@ -62,7 +62,7 @@ The following illustrates the use of the `RemoteEnvironment`:
{% highlight java %}
public static void main(String[] args) throws Exception {
ExecutionEnvironment env = ExecutionEnvironment
- .createRemoteEnvironment("flink-master", 6123, "/home/user/udfs.jar");
+ .createRemoteEnvironment("flink-master", 8081, "/home/user/udfs.jar");
DataSet<String> data = env.readTextFile("hdfs://path/to/file");