diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java index c1b1b1706..337928b39 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java @@ -260,12 +260,12 @@ public class InclusionObligations implements ISessionStage { while (j < execs.size() && j < i + 100) { ExecutionCommon other = execs.get(j); if (!Objects.equals(other.type(), execType)) { - i = j; break; } m.put(other.getId(), other); j++; } + i = j; log.debug("batch size {} type {}", m.size(), execType); if (!m.isEmpty()) { switch (execType) {