[
https://issues.apache.org/jira/browse/FLINK-21547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293028#comment-17293028
]
tim yu commented on FLINK-21547:
--------------------------------
Hi [~lzljs3620320]， If you agree with me, please assign this issue to me.
> 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
> Priority: Minor
>
> {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)
