[STORM-2804] TopoCache is not caching ACLs correctly

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Labels: pull-request-available
• Assignee: Ethan Li
• Reporter: Ethan Li
• Created: 08/Nov/17 20:08
• Updated: 09/Nov/17 21:04
• Resolved: 09/Nov/17 21:04

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

Issue Links

• links to: GitHub Pull Request #2404