Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2531#discussion_r164209531
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -2638,6 +2647,34 @@ private int getNumOfAckerExecs(Map<String, Object>
totalConf, StormTopology topo
}
}
+ private void upsertWorkerTokensInCreds(Map<String, String> creds,
String user, String topologyId) {
+ if (workerTokenManager != null) {
--- End diff --
from https://en.wikipedia.org/wiki/Merge_(SQL)
"A relational database management system uses SQL MERGE (also called
upsert) statements to INSERT new records or UPDATE existing records depending
on whether condition matches."
---
