xianle cao created TUBEMQ-453:
---------------------------------
Summary: TubemqSourceFunction class prints too many logs problem
Key: TUBEMQ-453
URL: https://issues.apache.org/jira/browse/TUBEMQ-453
Project: Apache TubeMQ
Issue Type: Bug
Reporter: xianle cao
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
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
