You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "tim yu (Jira)" <ji...@apache.org> on 2021/03/01 16:53:00 UTC
[jira] [Created] (FLINK-21547) Fix improper log level in
TwoPhaseCommitSinkFunction
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)