session step InclusionObligations (4 step) execution update bugfix
This commit is contained in:
parent
b7158efbde
commit
adcc2d7b3f
1 changed files with 1 additions and 1 deletions
|
|
@ -260,12 +260,12 @@ public class InclusionObligations implements ISessionStage {
|
||||||
while (j < execs.size() && j < i + 100) {
|
while (j < execs.size() && j < i + 100) {
|
||||||
ExecutionCommon other = execs.get(j);
|
ExecutionCommon other = execs.get(j);
|
||||||
if (!Objects.equals(other.type(), execType)) {
|
if (!Objects.equals(other.type(), execType)) {
|
||||||
i = j;
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
m.put(other.getId(), other);
|
m.put(other.getId(), other);
|
||||||
j++;
|
j++;
|
||||||
}
|
}
|
||||||
|
i = j;
|
||||||
log.debug("batch size {} type {}", m.size(), execType);
|
log.debug("batch size {} type {}", m.size(), execType);
|
||||||
if (!m.isEmpty()) {
|
if (!m.isEmpty()) {
|
||||||
switch (execType) {
|
switch (execType) {
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue