1. A method, with an information processing system, for reducing message flow on a message bus, the method comprising: determining if at least one logical operator in a plurality of logical operators requires processing on a given physical processing node in a group of physical nodes; pinning, in response to determining that the logical operator requires processing on the given physical processing node, the logical operator to the given physical processing node; and assigning each logical operator in the plurality of logical operators to an initial physical processing node in the group of physical processing nodes on a message bus.