commit ab6b6f69a10bf57c1b46a6519d57ca423d99558c
author Meng (Ethan) Li <ethanopensource@gmail.com> Wed Dec 23 09:08:51 2020 -0600
committer GitHub <noreply@github.com> Wed Dec 23 09:08:51 2020 -0600
tree d93b7c160f761bed5afbdccdd3e04c5182040066
parent d0027d97323375120f8c17540f698a3f66489aa7

[STORM-3728] Fix Worker LoginException issue with pacemaker when pacemaker.auth.method is KERBEROS (#3367)

storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java

diff --git a/storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java b/storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
index aef4997..f7b352c 100644
--- a/storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
+++ b/storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
@@ -121,6 +121,12 @@
 
         this.topologyConf = ConfigUtils.overrideLoginConfigWithSystemProperty(ConfigUtils.readSupervisorStormConf(conf, topologyId));
 
+        // See STORM-3728.
+        // Writes to Pacemaker are currently always allowed.
+        // Ignore Config.PACEMAKER_AUTH_METHOD on Workers.
+        topologyConf.put(Config.PACEMAKER_AUTH_METHOD, "NONE");
+        conf.put(Config.PACEMAKER_AUTH_METHOD, "NONE");
+
         if (supervisorIfaceSupplier == null) {
             this.supervisorIfaceSupplier = () -> {
                 try {