You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/06/24 09:51:26 UTC
[1/2] flink git commit: [FLINK-2262][utils] rename method for default
integer value in ParameterTool
Repository: flink
Updated Branches:
refs/heads/release-0.9 61f17f825 -> b5702c2bf
[FLINK-2262][utils] rename method for default integer value in ParameterTool
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f0da5b3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9f0da5b3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9f0da5b3
Branch: refs/heads/release-0.9
Commit: 9f0da5b30cd3321d4973d53407f597943b55beae
Parents: 61f17f8
Author: Maximilian Michels <mx...@apache.org>
Authored: Tue Jun 23 15:45:37 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Wed Jun 24 09:50:44 2015 +0200
----------------------------------------------------------------------
.../main/java/org/apache/flink/api/java/utils/ParameterTool.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/9f0da5b3/flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java b/flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java
index e7e5195..2afdff2 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java
@@ -197,7 +197,7 @@ public class ParameterTool extends ExecutionConfig.GlobalJobParameters implement
return Integer.valueOf(value);
}
- public int getLong(String key, int defaultValue) {
+ public int getInt(String key, int defaultValue) {
addToDefaults(key, Integer.toString(defaultValue));
String value = get(key);
if(value == null) {
[2/2] flink git commit: [docs] correct yarn command-line example
Posted by mx...@apache.org.
[docs] correct yarn command-line example
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5702c2b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5702c2b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b5702c2b
Branch: refs/heads/release-0.9
Commit: b5702c2bfe8baf4639ba3a1ca1ad05410191964c
Parents: 9f0da5b
Author: Maximilian Michels <mx...@apache.org>
Authored: Wed Jun 24 09:48:14 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Wed Jun 24 09:50:47 2015 +0200
----------------------------------------------------------------------
docs/setup/yarn_setup.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b5702c2b/docs/setup/yarn_setup.md
----------------------------------------------------------------------
diff --git a/docs/setup/yarn_setup.md b/docs/setup/yarn_setup.md
index 71d0b04..2f1d66e 100644
--- a/docs/setup/yarn_setup.md
+++ b/docs/setup/yarn_setup.md
@@ -46,7 +46,7 @@ Once the session has been started, you can submit jobs to the cluster using the
# {{ site.download_url }}
tar xvzf flink-{{ site.version }}-bin-hadoop2.tgz
cd flink-{{ site.version }}/
-./bin/flink -m yarn-cluster -yn 4 -yjm 1024 -ytm 4096 ./examples/flink-java-examples-{{ site.version }}-WordCount.jar
+./bin/flink run -m yarn-cluster -yn 4 -yjm 1024 -ytm 4096 ./examples/flink-java-examples-{{ site.version }}-WordCount.jar
~~~
## Apache Flink on Hadoop YARN using a YARN Session