diff options
Diffstat (limited to 'ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java')
| -rw-r--r-- | ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java b/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java index 2de8297..41885b8 100644 --- a/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java +++ b/ncomp-cdap-adaptor/src/main/java/org/openecomp/ncomp/servers/cdap/CdapCdapClusterProvider.java @@ -420,8 +420,11 @@ public class CdapCdapClusterProvider extends BasicAdaptorProvider { return customRunCDAPcliCommand(namespace, "set stream ttl " + streamName + " " + ttlSeconds); } - public String stopApp(String namespace, String appName) { - return customRunCDAPcliCommand(namespace, "stop app " + appName + " programs"); + public String stopApp(String namespace, String appName, String programTypes) { + if (programTypes == null) + return customRunCDAPcliCommand(namespace, "stop app " + appName + " programs"); + else + return customRunCDAPcliCommand(namespace, "stop app " + appName + " programs " + programTypes); } public String startWorker(String namespace, String appName, |