tim yu created FLINK-21547:
------------------------------
Summary: Fix improper log level in TwoPhaseCommitSinkFunction
Key: FLINK-21547
URL: https://issues.apache.org/jira/browse/FLINK-21547
Project: Flink
Issue Type: Bug
Components: Connectors / Common
Reporter: tim yu
{code:java}
LOG.info(
"{} - checkpoint {} complete, committing transaction {}
from checkpoint {}",
name(),
checkpointId,
pendingTransaction,
pendingTransactionCheckpointId);
logWarningIfTimeoutAlmostReached(pendingTransaction);
try {
commit(pendingTransaction.handle);
} catch (Throwable t) {
if (firstError == null) {
firstError = t;
}
}
LOG.debug("{} - committed checkpoint transaction {}", name(),
pendingTransaction);
{code}
I think "committing transaction ..." should be the same log level as "
committed checkpoint transaction ...".
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
