Data is received from a plurality of processes of a distributed computing arrangement. The computing arrangement contains a plurality of processing nodes. In a first processing node of the plurality of processing nodes data objects are received from a subset of the plurality of processes. A set of non-responsive processes of the plurality of processes is determined based on arrival times of the data objects relative to a current time. The data objects are aggregated into a set of data objects without waiting for data objects associated with the non-responsive processes. The set of data objects are sent to a second processing node of the plurality of processing nodes.