Repository: flink Updated Branches: refs/heads/master af477563e -> 2598709fa
[FLINK-2777] [docs] Fix Scala API description in programming_guide.html def createLocalEnvironment(parallelism: Int = Runtime.getRuntime.availableProcessors())) //issue1: In the end, there is a extra ")" def createRemoteEnvironment(host: String, port: String, jarFiles: String*) def createRemoteEnvironment(host: String, port: String, parallelism: Int, jarFiles: String*) //issue2: the parameter of port should be "Int", not "String" This closes #1193 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb899f70 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bb899f70 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bb899f70 Branch: refs/heads/master Commit: bb899f708b536d1056d106bf131e67d9f1e545c7 Parents: af47756 Author: Liang Chen <[email protected]> Authored: Tue Sep 29 23:53:02 2015 +0800 Committer: Stephan Ewen <[email protected]> Committed: Tue Sep 29 18:14:20 2015 +0200 ---------------------------------------------------------------------- docs/apis/programming_guide.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/bb899f70/docs/apis/programming_guide.md ---------------------------------------------------------------------- diff --git a/docs/apis/programming_guide.md b/docs/apis/programming_guide.md index ff831a9..3959dc9 100644 --- a/docs/apis/programming_guide.md +++ b/docs/apis/programming_guide.md @@ -331,13 +331,13 @@ obtain one using these static methods on class `ExecutionEnvironment`: {% highlight scala %} def getExecutionEnvironment -def createLocalEnvironment(parallelism: Int = Runtime.getRuntime.availableProcessors())) +def createLocalEnvironment(parallelism: Int = Runtime.getRuntime.availableProcessors()) def createLocalEnvironment(customConfiguration: Configuration) def createCollectionsEnvironment -def createRemoteEnvironment(host: String, port: String, jarFiles: String*) -def createRemoteEnvironment(host: String, port: String, parallelism: Int, jarFiles: String*) +def createRemoteEnvironment(host: String, port: Int, jarFiles: String*) +def createRemoteEnvironment(host: String, port: Int, parallelism: Int, jarFiles: String*) {% endhighlight %} Typically, you only need to use `getExecutionEnvironment()`, since this
