Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FLINK-3937] Implemented -yid option to Flink cli list, savepoint, cancel and stop subcommands #2034

Closed
wants to merge 3 commits into from

Conversation

packet23
Copy link
Contributor

I created a PR from the patch I already attached to the JIRA issue.

@@ -91,6 +93,7 @@

public FlinkYarnSessionCli(String shortPrefix, String longPrefix) {
QUERY = new Option(shortPrefix + "q", longPrefix + "query", false, "Display available YARN resources (memory, cores)");
APPLICATION_ID = new Option(shortPrefix + "id", longPrefix + "applicationId", true, "Attach to running YARN session");
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The APPLICATION_ID option is integrated here but the FlinkYarnSessionCli doesn't support attaching to existing applications. I think it could be useful to check during instantiation of the YarnSessionCli in the run(..) method whether we want to start a new application or resume.

@mxm
Copy link
Contributor

mxm commented May 25, 2016

Thanks for the pull request! Looks good! Do you think we could integrate with the FlinkYarnSessionCli as well? Once we merge this I will port this to the client changes in #1978.

@mxm
Copy link
Contributor

mxm commented Jun 3, 2016

Thanks for the update!

@mxm
Copy link
Contributor

mxm commented Jun 17, 2016

Merged. Thank you for your contribution!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
4 participants