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

ASF GitHub Bot commented on METRON-1031:
----------------------------------------

Github user simonellistonball commented on a diff in the pull request:

    https://github.com/apache/metron/pull/647#discussion_r127474849
  
    --- Diff: 
metron-interface/metron-rest/src/main/java/org/apache/metron/rest/service/impl/StormCLIWrapper.java
 ---
    @@ -75,37 +81,50 @@ public int stopIndexingTopology(boolean stopNow) throws 
RestException {
       protected int runCommand(String[] command) throws RestException {
         ProcessBuilder pb = getProcessBuilder(command);
         pb.inheritIO();
    -    Process process = null;
    +    LOG.debug("Running command: cmd={}", String.join(" ", command));
    +
    +    Process process;
         try {
           process = pb.start();
           process.waitFor();
    +
         } catch (Exception e) {
           throw new RestException(e);
         }
    -    return process.exitValue();
    +
    +    int exitValue = process.exitValue();
    +    LOG.debug("Command completed: cmd={}, exit={}", String.join(" ", 
command), exitValue);
    +
    +    return exitValue;
       }
     
       protected String[] getParserStartCommand(String name) {
    -    String[] command = new String[7];
    +    String[] command = new String[9];
         command[0] = 
environment.getProperty(MetronRestConstants.PARSER_SCRIPT_PATH_SPRING_PROPERTY);
         command[1] = "-k";
         command[2] = 
environment.getProperty(MetronRestConstants.KAFKA_BROKER_URL_SPRING_PROPERTY);
         command[3] = "-z";
         command[4] = 
environment.getProperty(MetronRestConstants.ZK_URL_SPRING_PROPERTY);
         command[5] = "-s";
         command[6] = name;
    +    command[7] = "-ksp";
    +    command[8] = 
environment.getProperty(MetronRestConstants.KAFKA_SECURITY_PROTOCOL_SPRING_PROPERTY);
         return command;
       }
     
       protected String[] getEnrichmentStartCommand() {
    -    String[] command = new String[1];
    +    String[] command = new String[3];
    --- End diff --
    
    right, my bad, it was just parser script I had to change


> Management UI Cannot Start Topologies in Kerberized Environment
> ---------------------------------------------------------------
>
>                 Key: METRON-1031
>                 URL: https://issues.apache.org/jira/browse/METRON-1031
>             Project: Metron
>          Issue Type: Bug
>            Reporter: Nick Allen
>            Assignee: Nick Allen
>
> The Metron Management UI cannot start topologies in a kerberized environment. 
>  This includes the parser, indexing, and enrichment topologies.
> It seems that Metron REST does not pass "-ksp" to the start topology 
> commands. As a result, topologies that are started with the Management UI 
> cannot start a producer against a kerberized Kafka.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to