[
https://issues.apache.org/jira/browse/STORM-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034119#comment-17034119
]
Ethan Li edited comment on STORM-3579 at 2/11/20 3:56 AM:
----------------------------------------------------------
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
was (Author: ethanli):
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)
