Я создал топологию, которая имеет 1 носик и 2 экземпляра болта, каждый из которых работает на отдельном работнике.И выделил 2048 МБ каждому из них, используя «дочерние банки».Во время бега я отследил рабочие порты болтов и обнаружил, что они превышают выделенную им память.
Как ограничить его представленным в конфигурациях топологии?
String workerChildOpts = String.format("-Xmx%sm -
Djava.net.preferIPv4Stack=true", topology.getMemoryPerBolt().getSizeInMByte());
topologyConfig.put(Config.TOPOLOGY_WORKER_CHILDOPTS, workerChildOpts);
topologyConfig.put(Config.TOPOLOGY_WORKER_MAX_HEAP_SIZE_MB, 2048.0);