You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by tillrohrmann <gi...@git.apache.org> on 2017/10/02 12:15:47 UTC
[GitHub] flink pull request #4742: [FLINK-7072] [REST] Add Flip-6 client for submit/j...
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4742#discussion_r141868129
--- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -635,6 +650,18 @@ protected int cancel(String[] args) {
return 1;
}
+ // FLIP-6 specific branch
+ try {
+ CustomCommandLine<?> activeCommandLine = getActiveCustomCommandLine(options.getCommandLine());
+ if (activeCommandLine instanceof Flip6DefaultCLI) {
+ ClusterClient client = activeCommandLine.retrieveCluster(options.getCommandLine(), config, configurationDirectory);
+ client.cancel(jobId);
--- End diff --
Same here for cancel.
---