[ 
https://issues.apache.org/jira/browse/FLINK-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438883#comment-15438883
 ] 

Maximilian Michels commented on FLINK-4487:
-------------------------------------------

{quote}
1. If there is already a yarn-session running then yarn-session does not start 
a new one (or it kills the old one?). Note that the file with ip/port may exist 
yet the corresponding JobManager may have been killed in an other way.
{quote}

The yarn properties file does not contain the ip/port anymore. Instead, it uses 
the Yarn application id. A new Yarn session always overrides the previous 
session information.

{quote}
2. A script that effectively lets me stop a yarn session and cleanup the file 
that contains the ip/port of this yarn session and the .flink directory on HDFS.
{quote}

If you use the non-detached Yarn session, cleanup is automatically done. If you 
use the detached session, you will have to stop the yarn application (using 
yarn commands) and delete the yarn properties file in the temp directory. Good 
idea to let a script do that! We can now do that reliably because we have the 
yarn application id in the properties file.

> Need tools for managing the yarn-session better
> -----------------------------------------------
>
>                 Key: FLINK-4487
>                 URL: https://issues.apache.org/jira/browse/FLINK-4487
>             Project: Flink
>          Issue Type: Improvement
>          Components: YARN Client
>    Affects Versions: 1.1.0
>            Reporter: Niels Basjes
>
> There is a script yarn-session.sh which starts an empty JobManager on a Yarn 
> cluster. 
> Desired improvements:
> # If there is already a yarn-session running then yarn-session does not start 
> a new one (or it kills the old one?). Note that the file with ip/port may 
> exist yet the corresponding JobManager may have been killed in an other way.
> # A script that effectively lets me stop a yarn session and cleanup the file 
> that contains the ip/port of this yarn session and the .flink directory on 
> HDFS.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to