ClusterStreamManagerImpl Subscription can request too many remote entries ------------------------------------------------------------------------- Key: ISPN-8806 URL: https://issues.jboss.org/browse/ISPN-8806 Project: Infinispan Issue Type: Bug Components: Streams Affects Versions: 9.2.0.CR2 Reporter: William Burns Assignee: William Burns Fix For: 9.2.0.CR3 The ClusterStreamManagerImpl.ClusterStreamSubscription stores a requestedAmount variable to ensure that only the correct number of entries are requested. It also ensures that only a single request per node can be done at at time by protecting calls via pendingRequest variable. Unfortunately there is an interleaving of code that allows for a request to possibly send 2 batches worth. This can cause the downstream queues that rely on only a specific number of entries to fail sometimes.