diff --git a/src/main/java/org/folio/service/transactions/batch/BatchTransactionHolder.java b/src/main/java/org/folio/service/transactions/batch/BatchTransactionHolder.java index 27810109..0456513c 100644 --- a/src/main/java/org/folio/service/transactions/batch/BatchTransactionHolder.java +++ b/src/main/java/org/folio/service/transactions/batch/BatchTransactionHolder.java @@ -255,9 +255,8 @@ private Future loadFunds(DBConn conn) { } private Future loadBudgets(DBConn conn) { - // NOTE: (Stream) is redundant but needed by the Java compiler Map> fiscalYearIdToFundIds = allTransactions.stream().collect(groupingBy(Transaction::getFiscalYearId, - flatMapping(tr -> (Stream)Stream.of(tr.getFromFundId(), tr.getToFundId()).filter(Objects::nonNull), toSet()))); + flatMapping(tr -> Stream.of(tr.getFromFundId(), tr.getToFundId()).filter(Objects::nonNull), toSet()))); if (fiscalYearIdToFundIds.isEmpty()) { allBudgets = emptyList(); return succeededFuture();