Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1097#issuecomment-158340342
I'm wondering whether you are trying to run the examples I'm posting here:
```java
RequiredParameters rq = new RequiredParameters();
rq.add("input");
rq.add(new
Option("parallelism").alt("p").defaultValue("1").type(OptionType.INTEGER));
ParameterTool pt = ParameterTool.fromArgs(args);
rq.applyTo(pt);
```
with `--input abc`
leads to:
```
Exception in thread "main"
org.apache.flink.api.java.utils.RequiredParametersException: Value for
parameter parallelism cannot be cast to type INTEGER
at
org.apache.flink.api.java.utils.RequiredParameters.applyTo(RequiredParameters.java:123)
at
org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:65)
```
I didn't provide any value for parallelism and I was expecting it to be set
automatically to 1.
I would recommend you to at least add the examples I'm posting here as test
cases.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
