[jira] [Created] (FLINK-21547) Fix improper log level in TwoPhaseCommitSinkFunction

[Shang Yuanchun (Jira)]

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)