flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetzger <...@git.apache.org>
Subject [GitHub] flink issue #2085: [FLINK-3937] programmatic resuming of clusters
Date Mon, 13 Jun 2016 14:30:35 GMT
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://flink@10.0.2.15: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://flink@10.0.2.15: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://flink@10.0.2.15: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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message