DBZ-7313 Use parameterized types
This commit is contained in:
parent
12a99f33f7
commit
c2eac1714e
@ -1427,7 +1427,7 @@ public void abandonTransactions(Duration retention) throws InterruptedException
|
||||
if (first) {
|
||||
LOGGER.warn("All transactions with SCN <= {} will be abandoned.", thresholdScn);
|
||||
if (LOGGER.isDebugEnabled()) {
|
||||
try (Stream s = getTransactionCache().keySet().stream()) {
|
||||
try (Stream<String> s = getTransactionCache().keySet().stream()) {
|
||||
LOGGER.debug("List of transactions in the cache before transactions being abandoned: [{}]",
|
||||
s.collect(Collectors.joining(",")));
|
||||
}
|
||||
@ -1452,7 +1452,7 @@ public void abandonTransactions(Duration retention) throws InterruptedException
|
||||
}
|
||||
}
|
||||
if (LOGGER.isDebugEnabled()) {
|
||||
try (Stream s = getTransactionCache().keySet().stream()) {
|
||||
try (Stream<String> s = getTransactionCache().keySet().stream()) {
|
||||
LOGGER.debug("List of transactions in the cache after transactions being abandoned: [{}]",
|
||||
s.collect(Collectors.joining(",")));
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user