Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
Description
In the code addTopology
public void addTopology(final String topoId, final Subject who, final StormTopology topo) throws AuthorizationException, KeyAlreadyExistsException, IOException { final String key = ConfigUtils.masterStormCodeKey(topoId); final List<AccessControl> acl = BlobStoreAclHandler.DEFAULT; store.createBlob(key, Utils.serialize(topo), new SettableBlobMeta(acl), who); topos.put(topoId, new WithAcl<>(acl, topo)); }
acl is being modified in store.createBlob(). But it's not populated to the topos.
The same applies to the addTopoConf() function
Attachments
Issue Links
- links to