[jira] [Created] (FLINK-15173) perjob on yarn appcluster shutdown depend on CliFrontend

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-15173) perjob on yarn appcluster shutdown depend on CliFrontend

Shang Yuanchun (Jira)
xiaodao created FLINK-15173:
-------------------------------

             Summary: perjob on yarn appcluster shutdown depend on CliFrontend
                 Key: FLINK-15173
                 URL: https://issues.apache.org/jira/browse/FLINK-15173
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Coordination
    Affects Versions: 1.9.1
            Reporter: xiaodao


i submit a job by command like:

./bin/flink run -m yarn-cluster -yjm 1024m -ytm 1024m -ynm test -yqu c -class com.xxx.SocketWordCount /data/tmp/test.jar

after the job run on yarn, i close the client, and then if the job failed with some problem,the yarn application not exit with failed status, but it still running and the job in the application failed. just like run on a session mode. i check the code , the org.apache.flink.runtime.dispatcher.Dispatcher#shutDownCluster whick call by CliFrontend.

so when i close submit client, the cluster not exit. i think it may be a bug,

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)