[INLONG-453] TubemqSourceFunction class prints too many logs problem

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.8.0
• Labels: pull-request-available
• Assignee: xianle cao
• Reporter: xianle cao
• Created: 15/Dec/20 08:43
• Updated: 25/Jun/22 09:23
• Resolved: 17/Dec/20 03:37

Description

module:

tubemq-connector-flink

class:

TubemqSourceFunction

 

```

Instant lastConsumeInstant = Instant.now();

while (running) {

ConsumerResult consumeResult = messagePullConsumer.getMessage();
if (!consumeResult.isSuccess()) {

...
Duration idleTime =
Duration.between(lastConsumeInstant, Instant.now());
if (idleTime.compareTo(maxIdleTime) > 0)

{ LOG.info("Mark this source as temporarily idle."); ctx.markAsTemporarilyIdle(); }

continue;
}

...

}

possible problems:

print too much log content: Mark this source as temporarily idle.

possible solution:

remove the log and print this line of code

Issue Links

• duplicates: INLONG-454 TubemqSourceFunction class prints too many logs problem
• links to: GitHub Pull Request #454
• links to: GitHub Pull Request #1042