Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2085
Detached per job submission is not working (`./bin/flink run -m
yarn-cluster -yd -yn 1 ./examples/batch/WordCount.jar `)
```
2016-06-13 07:28:22,423 INFO org.apache.flink.yarn.ApplicationClient
- Trying to register at JobManager
akka.tcp://[email protected]:45521/user/jobmanager.
2016-06-13 07:28:22,829 INFO org.apache.flink.yarn.ApplicationClient
- Successfully registered at the ResourceManager using
JobManager Actor[akka.tcp://[email protected]:45521/user/jobmanager#1868998090]
TaskManager status (0/1)
TaskManager status (0/1)
TaskManager status (0/1)
TaskManager status (0/1)
TaskManager status (0/1)
TaskManager status (0/1)
TaskManager status (0/1)
TaskManager status (0/1)
All TaskManagers are connected
Cluster started
Using address /10.0.2.15:45521 to connect to JobManager.
JobManager web interface address
http://quickstart.cloudera:8088/proxy/application_1447844011707_0039/
Starting execution of program
Executing WordCount example with default input data set.
Use --input to specify file input.
Printing result to stdout. Use --output to specify output path.
------------------------------------------------------------
The program finished with the following exception:
Job was submitted in detached mode. Results of job execution, such as
accumulators, runtime, job id etc. are not available. Please make sure your
program doesn't call an eager execution function [collect, print, printToErr,
count].
org.apache.flink.client.program.DetachedEnvironment$DetachedJobExecutionResult.getAccumulatorResult(DetachedEnvironment.java:103)
org.apache.flink.api.java.DataSet.collect(DataSet.java:412)
org.apache.flink.api.java.DataSet.print(DataSet.java:1605)
org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:92)
2016-06-13 07:28:27,206 INFO org.apache.flink.yarn.YarnClusterClient
- Disconnecting YarnClusterClient from ApplicationMaster
2016-06-13 07:28:27,208 INFO org.apache.flink.yarn.ApplicationClient
- Stopped Application client.
2016-06-13 07:28:27,208 INFO org.apache.flink.yarn.ApplicationClient
- Disconnect from JobManager
Actor[akka.tcp://[email protected]:45521/user/jobmanager#1868998090].
2016-06-13 07:28:27,307 INFO org.apache.flink.yarn.YarnClusterClient
- Application application_1447844011707_0039 finished with
state RUNNING and final state UNDEFINED at 0
[cloudera@quickstart build-target]
```
In the JobManager logs, there is no sign of a job being submitted.
---
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.
---
