[FLINK-21547] Fix improper log level in TwoPhaseCommitSinkFunction

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: Connectors / Common
• Assignee: Unassigned
• Reporter: tim yu
• Created: 01/Mar/21 16:52
• Updated: 01/Mar/21 17:03

Description

            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);

I think "committing transaction ..." should be the same log level as " committed checkpoint transaction ...".