[jira] [Commented] (STORM-3579) Fix Kerberos connection from Worker to Nimbus/Supervisor

["Ethan Li (Jira)" <ji...@apache.org>]

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

Ethan Li commented on STORM-3579:
---------------------------------

The root cause here is that a wrong conf is used for SupervisorClient and NimbuClient in Worker. 

[https://github.com/apache/storm/blob/master/storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java#L446-L447]

 
{code:java}
   try (NimbusClient nimbusClient = NimbusClient.getConfiguredClient(conf)) {                       
    nimbusClient.getClient().sendSupervisorWorkerHeartbeat(workerHeartbeat);            
  } catch (Exception tr2) {
{code}
 

while this should be topology conf.

Note that we override "java.security.auth.login.config" from Worker system property in topology conf:

 
{code:java}
final Map<String, Object> topologyConf =            ConfigUtils.overrideLoginConfigWithSystemProperty(ConfigUtils.readSupervisorStormConf(conf, topologyId));
{code}
so the right one will be picked up

 

 

> Fix Kerberos connection from Worker to Nimbus/Supervisor
> --------------------------------------------------------
>
>                 Key: STORM-3579
>                 URL: https://issues.apache.org/jira/browse/STORM-3579
>             Project: Apache Storm
>          Issue Type: Sub-task
>            Reporter: Ethan Li
>            Assignee: Ethan Li
>            Priority: Major
>
> BUG2 in the parent JIRA



--
This message was sent by Atlassian Jira
(v8.3.4#803005)